前言

常见的有三种，serverlet ，spring Interceptor， aop 。

serverlet filter实现

图解

image.png

使用

  2. public class LogFilter implements Filter {
  3.   @Override
  4.   public void init(FilterConfig filterConfig) throws ServletException {
  5.     // 在创建Filter时自动调用，
  6.     // 其中filterConfig包含这个Filter的配置参数，比如name之类的（从配置文件中读取的）
  7.   }
  9.   @Override
  10.   public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {
  11.     System.out.println("拦截客户端发送来的请求.");
  12.     chain.doFilter(request, response);
  13.     System.out.println("拦截发送给客户端的响应.");
  14.   }
  16.   @Override
  17.   public void destroy() {
  18.     // 在销毁Filter时自动调用
  19.   }
  20. }
  22. // 在web.xml配置文件中如下配置：
  23. <filter>
  24.   <filter-name>logFilter</filter-name>
  25.   <filter-class>com.xzg.cd.LogFilter</filter-class>
  26. </filter>
  27. <filter-mapping>
  28.     <filter-name>logFilter</filter-name>
  29.     <url-pattern>/*</url-pattern>
  30. </filter-mapping>

源码实现

实现思路：
1 维护过滤器数组
2 增加时更新数组，并根据需要扩容
3 执行时，递归执行，直到所有完成

  2. public final class ApplicationFilterChain implements FilterChain {
  3.   private int pos = 0; //当前执行到了哪个filter
  4.   private int n; //filter的个数
  5.   private ApplicationFilterConfig[] filters;
  6.   private Servlet servlet;
  8.   @Override
  9.   public void doFilter(ServletRequest request, ServletResponse response) {
  10.     if (pos < n) {
  11.       ApplicationFilterConfig filterConfig = filters[pos++];
  12.       Filter filter = filterConfig.getFilter();
  13.       filter.doFilter(request, response, this);
  14.     } else {
  15.       // filter都处理完毕后，执行servlet
  16.       servlet.service(request, response);
  17.     }
  18.   }
  20.   public void addFilter(ApplicationFilterConfig filterConfig) {
  21.     for (ApplicationFilterConfig filter:filters)
  22.       if (filter==filterConfig)
  23.          return;
  25.     if (n == filters.length) {//扩容
  26.       ApplicationFilterConfig[] newFilters = new ApplicationFilterConfig[n + INCREMENT];
  27.       System.arraycopy(filters, 0, newFilters, 0, n);
  28.       filters = newFilters;
  29.     }
  30.     filters[n++] = filterConfig;
  31.   }
  32. }

spring Interceptor

图解

image.png

使用代码

  2. public class LogInterceptor implements HandlerInterceptor {
  4.   @Override
  5.   public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
  6.     System.out.println("拦截客户端发送来的请求.");
  7.     return true; // 继续后续的处理
  8.   }
  10.   @Override
  11.   public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler, ModelAndView modelAndView) throws Exception {
  12.     System.out.println("拦截发送给客户端的响应.");
  13.   }
  15.   @Override
  16.   public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
  17.     System.out.println("这里总是被执行.");
  18.   }
  19. }
  21. //在Spring MVC配置文件中配置interceptors
  22. <mvc:interceptors>
  23.    <mvc:interceptor>
  24.        <mvc:mapping path="/*"/>
  25.        <bean class="com.xzg.cd.LogInterceptor" />
  26.    </mvc:interceptor>
  27. </mvc:interceptors>

源码实现

  2. public class HandlerExecutionChain {
  3.  private final Object handler;
  4.  private HandlerInterceptor[] interceptors;
  6.  public void addInterceptor(HandlerInterceptor interceptor) {
  7.   initInterceptorList().add(interceptor);
  8.  }
  10.  boolean applyPreHandle(HttpServletRequest request, HttpServletResponse response) throws Exception {
  11.   HandlerInterceptor[] interceptors = getInterceptors();
  12.   if (!ObjectUtils.isEmpty(interceptors)) {
  13.    for (int i = 0; i < interceptors.length; i++) {
  14.     HandlerInterceptor interceptor = interceptors[i];
  15.     if (!interceptor.preHandle(request, response, this.handler)) {
  16.      triggerAfterCompletion(request, response, null);
  17.      return false;
  18.     }
  19.    }
  20.   }
  21.   return true;
  22.  }
  24.  void applyPostHandle(HttpServletRequest request, HttpServletResponse response, ModelAndView mv) throws Exception {
  25.   HandlerInterceptor[] interceptors = getInterceptors();
  26.   if (!ObjectUtils.isEmpty(interceptors)) {
  27.    for (int i = interceptors.length - 1; i >= 0; i--) {
  28.     HandlerInterceptor interceptor = interceptors[i];
  29.     interceptor.postHandle(request, response, this.handler, mv);
  30.    }
  31.   }
  32.  }
  34.  void triggerAfterCompletion(HttpServletRequest request, HttpServletResponse response, Exception ex)
  35.    throws Exception {
  36.   HandlerInterceptor[] interceptors = getInterceptors();
  37.   if (!ObjectUtils.isEmpty(interceptors)) {
  38.    for (int i = this.interceptorIndex; i >= 0; i--) {
  39.     HandlerInterceptor interceptor = interceptors[i];
  40.     try {
  41.      interceptor.afterCompletion(request, response, this.handler, ex);
  42.     } catch (Throwable ex2) {
  43.      logger.error("HandlerInterceptor.afterCompletion threw exception", ex2);
  44.     }
  45.    }
  46.   }
  47.  }
  48. }

小结与对比

对比

AOP、Servlet Filter、Spring Interceptor这三者可以从不同权限检查的范围大小的视角来应用：
1. Servlet Filter
运维部门需要对只供内部访问的服务进行IP限制或访问审查时，在容器这一层增加一个Filter，在发布时发布系统自动加挂这个Filter，这样对上层应用就是透明的，内网IP地址段增减或审查规则调整都不需要上层应用的开发人员去关心。
2. Spring Interceptor
由框架或基础服务部门来提供的微服务间相互调用的授权检查时，可以提供统一的SDK，由程序员在需要的服务上配置。
3. AOP
业务应用内权限检查，可以把权限检查在统一模块中实现，通过配置由AOP加插拦截检查。

其他类似设计

netty的ChannelPipeline的实现逻辑：
1、每一个SocketChannel对象维护这一个ChannelPipeline对象，该对象支持bind,connect,disconnect,read,write等IO时间的触发链条；
2、ChannelPipeline对外提供ChannelHandler的增删改查的接口、对内使用AbstractChannelHandlerContext对象将ChannelHandler包装了一层，维护了一个AbstractChannelHandlerContext的双向链表。
3、当SocketChannel发生IO事件时，比如发生了read事件，SocketChannel委托ChannelPipeline去处理这些时间，从而启动了责任链的操作。

说明

内容整理自极客《设计模式专栏》