真实的国产乱ⅩXXX66竹夫人,五月香六月婷婷激情综合,亚洲日本VA一区二区三区,亚洲精品一区二区三区麻豆

成都創(chuàng)新互聯(lián)網(wǎng)站制作重慶分公司

詳解SpringBoot中使用AOP統(tǒng)一處理Web請求日志

在spring boot中,簡單幾步,使用spring AOP實現(xiàn)一個攔截器:

創(chuàng)新互聯(lián)建站專業(yè)為企業(yè)提供呼倫貝爾網(wǎng)站建設(shè)、呼倫貝爾做網(wǎng)站、呼倫貝爾網(wǎng)站設(shè)計、呼倫貝爾網(wǎng)站制作等企業(yè)網(wǎng)站建設(shè)、網(wǎng)頁設(shè)計與制作、呼倫貝爾企業(yè)網(wǎng)站模板建站服務(wù),十余年呼倫貝爾做網(wǎng)站經(jīng)驗,不只是建網(wǎng)站,更提供有價值的思路和整體網(wǎng)絡(luò)服務(wù)。

1、引入依賴

 
  org.springframework.boot 
  spring-boot-starter-aop 
 
   org.springframework.boot 
   spring-boot-starter-aop 
  

 2、創(chuàng)建攔截器類(在該類中,定義了攔截規(guī)則:攔截com.xjj.web.controller包下面的所有類中,有@RequestMapping注解的方法。):

/** 
 * 攔截器:記錄用戶操作日志,檢查用戶是否登錄…… 
 * @author XuJijun 
 */ 
@Aspect 
@Component 
public class ControllerInterceptor { 
  private static final Logger logger = LoggerFactory.getLogger(ControllerInterceptor.class); 
   
  @Value(“${spring.profiles}”) 
  private String env; 
   
  /** 
   * 定義攔截規(guī)則:攔截com.xjj.web.controller包下面的所有類中,有@RequestMapping注解的方法。 
   */ 
  @Pointcut(“execution(* com.xjj.web.controller..*(..)) and @annotation(org.springframework.web.bind.annotation.RequestMapping)”) 
  public void controllerMethodPointcut(){} 
   
  /** 
   * 攔截器具體實現(xiàn) 
   * @param pjp 
   * @return JsonResult(被攔截方法的執(zhí)行結(jié)果,或需要登錄的錯誤提示。) 
   */ 
  @Around(“controllerMethodPointcut()”) //指定攔截器規(guī)則;也可以直接把“execution(* com.xjj………)”寫進(jìn)這里 
  public Object Interceptor(ProceedingJoinPoint pjp){ 
    long beginTime = System.currentTimeMillis(); 
    MethodSignature signature = (MethodSignature) pjp.getSignature(); 
    Method method = signature.getMethod(); //獲取被攔截的方法 
    String methodName = method.getName(); //獲取被攔截的方法名 
     
    Set allParams = new LinkedHashSet<>(); //保存所有請求參數(shù),用于輸出到日志中 
     
    logger.info(”請求開始,方法:{}”, methodName); 
     
    Object result = null; 
 
    Object[] args = pjp.getArgs(); 
    for(Object arg : args){ 
      //logger.debug(“arg: {}”, arg); 
      if (arg instanceof Map<?, ?>) { 
        //提取方法中的MAP參數(shù),用于記錄進(jìn)日志中 
        @SuppressWarnings(“unchecked”) 
        Map map = (Map) arg; 
 
        allParams.add(map); 
      }else if(arg instanceof HttpServletRequest){ 
        HttpServletRequest request = (HttpServletRequest) arg; 
        if(isLoginRequired(method)){ 
          if(!isLogin(request)){ 
            result = new JsonResult(ResultCode.NOT_LOGIN, “該操作需要登錄!去登錄嗎?\n\n(不知道登錄賬號?請聯(lián)系老許。)”, null); 
          } 
        } 
         
        //獲取query string 或 posted form data參數(shù) 
        Map paramMap = request.getParameterMap(); 
        if(paramMap!=null && paramMap.size()>0){ 
          allParams.add(paramMap); 
        } 
      }else if(arg instanceof HttpServletResponse){ 
        //do nothing… 
      }else{ 
        //allParams.add(arg); 
      } 
    } 
     
    try { 
      if(result == null){ 
        // 一切正常的情況下,繼續(xù)執(zhí)行被攔截的方法 
        result = pjp.proceed(); 
      } 
    } catch (Throwable e) { 
      logger.info(”exception: ”, e); 
      result = new JsonResult(ResultCode.EXCEPTION, “發(fā)生異常:”+e.getMessage()); 
    } 
     
    if(result instanceof JsonResult){ 
      long costMs = System.currentTimeMillis() - beginTime; 
      logger.info(”{}請求結(jié)束,耗時:{}ms”, methodName, costMs); 
    } 
     
    return result; 
  } 
   
  /** 
   * 判斷一個方法是否需要登錄 
   * @param method 
   * @return 
   */ 
  private boolean isLoginRequired(Method method){ 
    if(!env.equals(“prod”)){ //只有生產(chǎn)環(huán)境才需要登錄 
      return false; 
    } 
     
    boolean result = true; 
    if(method.isAnnotationPresent(Permission.class)){ 
      result = method.getAnnotation(Permission.class).loginReqired(); 
    } 
     
    return result; 
  } 
   
  //判斷是否已經(jīng)登錄 
  private boolean isLogin(HttpServletRequest request) { 
    return true; 
    /*String token = XWebUtils.getCookieByName(request, WebConstants.CookieName.AdminToken); 
    if(“1”.equals(redisOperator.get(RedisConstants.Prefix.ADMIN_TOKEN+token))){ 
      return true; 
    }else { 
      return false; 
    }*/ 
  } 
} 

/** 
 * 攔截器:記錄用戶操作日志,檢查用戶是否登錄…… 
 * @author XuJijun 
 */ 
@Aspect 
@Component 
public class ControllerInterceptor { 
  private static final Logger logger = LoggerFactory.getLogger(ControllerInterceptor.class); 
 
  @Value("${spring.profiles}") 
  private String env; 
 
  /** 
   * 定義攔截規(guī)則:攔截com.xjj.web.controller包下面的所有類中,有@RequestMapping注解的方法。 
   */ 
  @Pointcut("execution(* com.xjj.web.controller..*(..)) and @annotation(org.springframework.web.bind.annotation.RequestMapping)") 
  public void controllerMethodPointcut(){} 
 
  /** 
   * 攔截器具體實現(xiàn) 
   * @param pjp 
   * @return JsonResult(被攔截方法的執(zhí)行結(jié)果,或需要登錄的錯誤提示。) 
   */ 
  @Around("controllerMethodPointcut()") //指定攔截器規(guī)則;也可以直接把“execution(* com.xjj.........)”寫進(jìn)這里 
  public Object Interceptor(ProceedingJoinPoint pjp){ 
    long beginTime = System.currentTimeMillis(); 
    MethodSignature signature = (MethodSignature) pjp.getSignature(); 
    Method method = signature.getMethod(); //獲取被攔截的方法 
    String methodName = method.getName(); //獲取被攔截的方法名 
 
    Set allParams = new LinkedHashSet<>(); //保存所有請求參數(shù),用于輸出到日志中 
 
    logger.info("請求開始,方法:{}", methodName); 
 
    Object result = null; 
 
    Object[] args = pjp.getArgs(); 
    for(Object arg : args){ 
      //logger.debug("arg: {}", arg); 
      if (arg instanceof Map<?, ?>) { 
        //提取方法中的MAP參數(shù),用于記錄進(jìn)日志中 
        @SuppressWarnings("unchecked") 
        Map map = (Map) arg; 
 
        allParams.add(map); 
      }else if(arg instanceof HttpServletRequest){ 
        HttpServletRequest request = (HttpServletRequest) arg; 
        if(isLoginRequired(method)){ 
          if(!isLogin(request)){ 
            result = new JsonResult(ResultCode.NOT_LOGIN, "該操作需要登錄!去登錄嗎?\n\n(不知道登錄賬號?請聯(lián)系老許。)", null); 
          } 
        } 
 
        //獲取query string 或 posted form data參數(shù) 
        Map paramMap = request.getParameterMap(); 
        if(paramMap!=null && paramMap.size()>0){ 
          allParams.add(paramMap); 
        } 
      }else if(arg instanceof HttpServletResponse){ 
        //do nothing... 
      }else{ 
        //allParams.add(arg); 
      } 
    } 
 
    try { 
      if(result == null){ 
        // 一切正常的情況下,繼續(xù)執(zhí)行被攔截的方法 
        result = pjp.proceed(); 
      } 
    } catch (Throwable e) { 
      logger.info("exception: ", e); 
      result = new JsonResult(ResultCode.EXCEPTION, "發(fā)生異常:"+e.getMessage()); 
    } 
 
    if(result instanceof JsonResult){ 
      long costMs = System.currentTimeMillis() - beginTime; 
      logger.info("{}請求結(jié)束,耗時:{}ms", methodName, costMs); 
    } 
 
    return result; 
  } 
 
  /** 
   * 判斷一個方法是否需要登錄 
   * @param method 
   * @return 
   */ 
  private boolean isLoginRequired(Method method){ 
    if(!env.equals("prod")){ //只有生產(chǎn)環(huán)境才需要登錄 
      return false; 
    } 
 
    boolean result = true; 
    if(method.isAnnotationPresent(Permission.class)){ 
      result = method.getAnnotation(Permission.class).loginReqired(); 
    } 
 
    return result; 
  } 
 
  //判斷是否已經(jīng)登錄 
  private boolean isLogin(HttpServletRequest request) { 
    return true; 
    /*String token = XWebUtils.getCookieByName(request, WebConstants.CookieName.AdminToken); 
    if("1".equals(redisOperator.get(RedisConstants.Prefix.ADMIN_TOKEN+token))){ 
      return true; 
    }else { 
      return false; 
    }*/ 
  } 
} 

3、測試

瀏覽器中輸入:http://localhost:8082/api/admin/login

測試結(jié)果:

2016-07-26 11:58:12,057:INFO http-nio-8082-exec-1 (ControllerInterceptor.java:58) - 請求開始,方法:login 
2016-07-26 11:58:12,061:INFO http-nio-8082-exec-1 (ControllerInterceptor.java:103) - login請求結(jié)束,耗時:8ms 

2016-07-26 11:58:12,057:INFO http-nio-8082-exec-1 (ControllerInterceptor.java:58) - 請求開始,方法:login 
2016-07-26 11:58:12,061:INFO http-nio-8082-exec-1 (ControllerInterceptor.java:103) - login請求結(jié)束,耗時:8ms 

證明攔截器已經(jīng)生效。

源代碼參考:https://github.com/xujijun/my-spring-boot

以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持創(chuàng)新互聯(lián)。


分享文章:詳解SpringBoot中使用AOP統(tǒng)一處理Web請求日志
轉(zhuǎn)載來源:http://weahome.cn/article/jhegjo.html

在線咨詢

微信咨詢

電話咨詢

028-86922220(工作日)

18980820575(7×24)

提交需求

返回頂部