ITPub博客
首页 博客 专栏 学院 社区 IT新媒体评选
发博

首页 > 应用开发 > Java > Java interceptor 拦截器

Java interceptor 拦截器

原创 Java 作者：百联达 时间：2016-12-08 16:27:12 0 删除 编辑
一：拦截器的应用场景

1、日志记录：记录请求信息的日志，以便进行信息监控、信息统计、计算PV（Page VIEW）等。
2、权限检查：如登录检测，进入处理器检测检测是否登录，如果没有直接返回到登录页面；
3、性能监控：有时候系统在某段时间莫名其妙的慢，可以通过拦截器在进入处理器之前记录开始时间，在处理完后记录结束时间，从而得到该请求的处理时间（如果有反向代理，如apache可以自动记录）；
4、通用行为：读取cookie得到用户信息并将用户对象放入请求，从而方便后续流程使用，还有如提取Locale、Theme信息等，只要是多个处理器都需要的即可使用拦截器实现。
5、OpenSessionInView：如Hibernate，在进入处理器打开SESSION，在完成后关闭SESSION。

二：拦截器与过滤器的区别

 1、拦截器是基于Java的反射机制的，而过滤器是基于函数回调。
 2、拦截器不依赖与servlet容器，过滤器依赖与servlet容器。
 3、拦截器只能对ACTION请求起作用，而过滤器则可以对几乎所有的请求起作用。
 4、拦截器可以访问ACTION上下文、值栈里的对象，而过滤器不能访问。
 5、在ACTION的生命周期中，拦截器可以多次被调用，而过滤器只能在容器初始化时被调用一次。
 6、拦截器可以获取IOC容器中的各个bean，而过滤器就不行，这点很重要，在拦截器里注入一个service，可以调用业务逻辑。


三：拦截器的实现

1.过滤器是JavaEE标准，采用函数回调的方式进行。是在请求进入容器之后，还未进入Servlet之前进行预处理，并且在请求结束返回给前端这之间进行后期处理。

点击(此处)折叠或打开

  1. @Override
  2.     public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {
  3.         System.out.println("before...");
  4.         chain.doFilter(request, response);
  5.         System.out.println("after...");
  6.     }
chain.doFilter(request, response);这个方法的调用作为分水岭。事实上调用Servlet的doService()方法是在chain.doFilter(request, response);这个方法中进行的。

2.拦截器是被包裹在过滤器之中的。

点击(此处)折叠或打开

  1. @Override
  2.     public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
  3.         System.out.println("preHandle");
  4.         return true;
  5.     }

  7.     @Override
  8.     public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler, ModelAndView modelAndView) throws Exception {
  9.         System.out.println("postHandle");
  10.     }

  12.     @Override
  13.     public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
  14.         System.out.println("afterCompletion");
  15.     }
a.preHandle()这个方法是在过滤器的chain.doFilter(request, response)方法的前一步执行，也就是在 [System.out.println("before...")][chain.doFilter(request, response)]之间执行。
b.preHandle()方法之后，在RETURN ModelAndView之前进行，可以操控Controller的ModelAndView内容。
c.afterCompletion()方法是在过滤器返回给前端前一步执行，也就是在[chain.doFilter(request, response)][System.out.println("after...")]之间执行。

四：SpringMvc 拦截器和过滤器执行流程




五：实例

点击(此处)折叠或打开

  1. public class SystemAccessInterceper extends HandlerInterceptorAdapter {

  3.     private final String checkpointName = "DO_CHECKPOINT";
  4.     private final String shareType = "enjoylink_share";
  5.     String[] noFilters = ConfigureUtil.getStringArray("nofilter.urls");

  7.     private final Logger logger = Logger.getLogger(getClass());

  9.     @Override
  10.     public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler)
  11.             throws Exception {
  12.         String userAgent = request.getHeader("user-agent");
  13.         userAgent = StringUtils.startsWith(userAgent, Constants.USER_AGENT) ? userAgent
  14.                 : request.getHeader("x-user-agent");
  15.         String type = request.getParameter("shareType");
  16.         String requestUri = request.getRequestURI();
  17.         if (isFilter(requestUri)) {
  18.             return true;
  19.         }
  20.         logger.info("User-Agent:" + userAgent);
  21.         if (!StringUtils.equalsIgnoreCase(shareType, type) && (!StringUtils.startsWith(userAgent, Constants.USER_AGENT)
  22.                 || 2 > StringUtils.indexOfAny(userAgent, "|"))) {
  23.             logger.info("非法请求接口！！");
  24.             return false;
  25.         }

  27.         try {
  28.             if (StringUtils.contains(userAgent, "|")) {
  29.                 String[] agts = userAgent.split("\\|");
  30.                 request.setAttribute(Constants.HEAD_SYS, agts[1]);
  31.                 request.setAttribute(Constants.HEAD_VERSION, agts[2]);
  32.             }
  33.             request.setAttribute(Constants.LOG_ACCESS_TIME, System.currentTimeMillis());
  34.             return super.preHandle(request, response, handler);
  35.         }
  36.         catch (Exception e) {
  37.             logger.error("拦截器验证失败！", e);
  38.             return false;
  39.         }
  40.     }

  42.     /**
  43.      * TODO: 检查是否需要过滤
  44.      *
  45.      * @param uri
  46.      * @return
  47.      */
  48.     private boolean isFilter(String uri) {
  49.         if (org.apache.commons.lang3.ArrayUtils.isEmpty(noFilters)) {
  50.             return Boolean.TRUE;
  51.         }

  53.         for (String noFilter : noFilters) {
  54.             if (StringUtils.contains(uri, noFilter)) {
  55.                 return Boolean.TRUE;
  56.             }
  57.         }

  59.         return Boolean.FALSE;
  60.     }

  62.     @Override
  63.     public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex)
  64.             throws Exception {
  65.         super.afterCompletion(request, response, handler, ex);
  66.         Object obj = request.getAttribute(Constants.LOG_ACCESS_TIME);
  67.         if (null != obj) {
  68.             Object rb = request.getAttribute(Constants.RETURN_BODY);
  69.             long accessTime = (long) obj;
  70.             if (null == rb || StringUtils.isEmpty(rb.toString())) {
  71.                 logger.info("不进行检查点处理！");
  72.                 logger.info("处理请求" + request.getRequestURI() +"耗时"+ (System.currentTimeMillis() - accessTime) + "毫秒！");
  73.                 return;
  74.             }
  75.             Object userId = request.getAttribute(Constants.REQUEST_USERID);
  76.             String system = request.getAttribute(Constants.HEAD_SYS).toString();
  77.             String version = request.getAttribute(Constants.HEAD_VERSION).toString();

  79.             logger.warn("处理请求|" + ((null == userId || "".equals(userId.toString())) ? "0" : userId.toString()) + "|"
  80.                     + system + "|" + version + "|" + request.getRequestURI() + "|"
  81.                     + GbdDateUtils.format(Calendar.getInstance().getTime(), "yyyy-MM-dd HH:mm:ss") + "|"
  82.                     + (System.currentTimeMillis() - accessTime) + "|毫秒！");
  83.             try {
  84.                 HandlerMethod handlerMethod = (HandlerMethod) handler;
  85.                 BusinessCheckPoint checkPoint = handlerMethod.getMethodAnnotation(BusinessCheckPoint.class);
  86.                 if (null != checkPoint) {
  87.                     String checkpointKey = checkPoint.checkName();

  89.                     // 业务处理结果为正确时。发送积分或者信用累积
  90.                     if (null != rb && null != userId && StringUtils.isNotEmpty(userId.toString())) {
  91.                         ReturnBody returnBody = (ReturnBody) rb;
  92.                         // 检查点检测，如果是检查点则发送消息
  93.                         if (returnBody.getCode() > 0) {
  94.                             // 发送检查点消息
  95.                             CodeDesc codeDesc = new CodeDesc();
  96.                             codeDesc.setJmsType(checkpointName);
  97.                             codeDesc.setName(checkpointKey);
  98.                             codeDesc.setBusinessCode(returnBody.getCheckpointCode());
  99.                             codeDesc.setUserId(Integer.valueOf(userId.toString()));
  100.                             JmsUtil.pushToUserQueue(codeDesc);
  101.                         }
  102.                     }
  103.                 }
  104.             }
  105.             catch (Exception e) {
  106.                 logger.error("发送积分消息失败！", e);
  107.             }
  108.         }
  109.     }

  111. }


点击(此处)折叠或打开

  1. <!-- 拦截器配置 -->
  2.     <mvc:interceptors>
  3.         <bean class="com.gemdale.ghome.business.intercepter.SystemAccessInterceper" />
  4.     </mvc:interceptors>



来自 “ ITPUB博客 ” ，链接：https://blog.itpub.net/28624388/viewspace-2130071/ ，如需转载，请注明出处，否则将追究法律责任。

0
0
上一篇： Java Annotation 注解
下一篇： BOSS系统三户模型
请登录后发表评论 登录
全部评论
百联达
专家姓名：耿冲
15年以上互联网经验，先后从事过制造业，证券业，物业行业和物流行业信息系统和互联网产品的设计落地实施，8年系统架构经验。最近关注企业数字化转型、财务数字化服务共享、大语言模型、Kubernetes微服务架构和Istio微服务治理框架。

注册时间：2013-02-05

  • 博文量
    332
  • 访问量
    1265641

最新文章

支持我们 作者招募 用户协议 FAQ Contact Us

北京盛拓优讯信息技术有限公司. 版权所有  京ICP备16024965号-8 北京市公安局海淀分局网监中心备案编号：11010802021510 niuxiaotong@pcpop.com 17352615567 未成年人举报专区

广播电视节目制作经营许可证(京) 字第1234号 中国互联网协会会员

违法和不良信息举报电话:18101376593