快捷導(dǎo)航

Java 中責(zé)任鏈模式實現(xiàn)的三種方式

更新時間：2017年09月11日 11:16:25 作者：atheva

本文重點給大家介紹java中如何編寫責(zé)任鏈模式。主要從下面3個框架中的代碼中介紹。非常不錯，需要的朋友參考下吧

責(zé)任鏈模式

責(zé)任鏈模式的定義：使多個對象都有機會處理請求，從而避免請求的發(fā)送者和接受者之間的耦合關(guān)系，將這個對象連成一條鏈，并沿著這條鏈傳遞該請求，直到有一個對象處理他為止。這里就不再過多的介紹什么是責(zé)任鏈模式，主要來說說java中如何編寫。主要從下面3個框架中的代碼中介紹。

servlet中的filter
dubbo中的filter
mybatis中的plugin 這3個框架在實現(xiàn)責(zé)任鏈方式不盡相同。

servlet中的Filter

servlet中分別定義了一個 Filter和FilterChain的接口，核心代碼如下：

public final class ApplicationFilterChain implements FilterChain {
  private int pos = 0; //當(dāng)前執(zhí)行filter的offset
  private int n; //當(dāng)前filter的數(shù)量
  private ApplicationFilterConfig[] filters; //filter配置類，通過getFilter()方法獲取Filter
  private Servlet servlet
  @Override
  public void doFilter(ServletRequest request, ServletResponse response) {
    if (pos < n) {
      ApplicationFilterConfig filterConfig = filters[pos++];
      Filter filter = filterConfig.getFilter();
      filter.doFilter(request, response, this);
    } else {
      // filter都處理完畢后，執(zhí)行servlet
      servlet.service(request, response);
    }
  }
}

代碼還算簡單，結(jié)構(gòu)也比較清晰，定義一個Chain，里面包含了Filter列表和servlet，達到在調(diào)用真正servlet之前進行各種filter邏輯。

Dubbo中的Filter

Dubbo在創(chuàng)建Filter的時候是另外一個方法，通過把Filter封裝成 Invoker的匿名類，通過鏈表這樣的數(shù)據(jù)結(jié)構(gòu)來完成責(zé)任鏈，核心代碼如下：

private static <T> Invoker<T> buildInvokerChain(final Invoker<T> invoker, String key, String group) {
  Invoker<T> last = invoker;
  //只獲取滿足條件的Filter
  List<Filter> filters = ExtensionLoader.getExtensionLoader(Filter.class).getActivateExtension(invoker.getUrl(), key, group);
  if (filters.size() > 0) {
    for (int i = filters.size() - 1; i >= 0; i --) {
      final Filter filter = filters.get(i);
      final Invoker<T> next = last;
      last = new Invoker<T>() {
        ...
        public Result invoke(Invocation invocation) throws RpcException {
          return filter.invoke(next, invocation);
        }
        ...
      };
    }
  }
  return last;
}

Dubbo的責(zé)任鏈就沒有類似FilterChain這樣的類吧Filter和調(diào)用Invoker結(jié)合起來，而是通過創(chuàng)建一個鏈表，調(diào)用的時候我們只知道第一個節(jié)點，每個節(jié)點包含了下一個調(diào)用的節(jié)點信息。這里的雖然Invoker封裝Filter沒有顯示的指定next，但是通過java匿名類和final的機制達到同樣的效果。

Mybatis中的Plugin

Mybatis可以配置各種Plugin，無論是官方提供的還是自己定義的，Plugin和Filter類似，就在執(zhí)行Sql語句的時候做一些操作。Mybatis的責(zé)任鏈則是通過動態(tài)代理的方式，使用Plugin代理實際的Executor類。（這里實際還使用了組合模式，因為Plugin可以嵌套代理），核心代碼如下：

public class Plugin implements InvocationHandler{
  private Object target;
  private Interceptor interceptor;
  @Override
  public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {   
    if (滿足代理條件) {
      return interceptor.intercept(new Invocation(target, method, args));
    }
    return method.invoke(target, args);   
  }
  //對傳入的對象進行代理，可能是實際的Executor類，也可能是Plugin代理類
  public static Object wrap(Object target, Interceptor interceptor) {
    Class<?> type = target.getClass();
    Class<?>[] interfaces = getAllInterfaces(type, signatureMap);
    if (interfaces.length > 0) {
      return Proxy.newProxyInstance(
          type.getClassLoader(),
          interfaces,
          new Plugin(target, interceptor, signatureMap));
    }
    return target;
  }
}

　簡單的示意圖如下：