温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

怎么在SpringBoot中使用AOP技术操作日志

发布时间:2021-03-23 15:29:02 来源:亿速云 阅读:210 作者:Leah 栏目:编程语言

怎么在SpringBoot中使用AOP技术操作日志?相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。

一、基本概念

项目描述
Aspect(切面)跨越多个类的关注点的模块化,切面是通知和切点的结合。通知和切点共同定义了切面的全部内容——它是什么,在何时和何处完成其功能。事务处理和日志处理可以理解为切面
Join point(连接点)程序执行过程中的一个点,如方法的执行或异常的处理
Advice(通知)切面在特定连接点上采取的动作
Pointcut(切点)匹配连接点的断言。通知与切入点表达式相关联,并在切入点匹配的任何连接点上运行(例如,具有特定名称的方法的执行)。切入点表达式匹配的连接点概念是AOP的核心,Spring默认使用AspectJ切入点表达式语言
Introduction(引用)为类型声明其他方法或字段。Spring AOP允许您向任何建议的对象引入新的接口(和相应的实现)。例如,您可以使用介绍使bean实现IsModified接口,以简化缓存
Target object(目标)由一个或多个切面通知的对象。也称为“通知对象”。由于Spring AOP是通过使用运行时代理实现的,所以这个对象始终是代理对象
AOP proxy(代理)AOP框架为实现切面契约(通知方法执行等)而创建的对象。在Spring框架中,AOP代理是JDK动态代理或CGLIB代理
Weaving(织入)织入是将通知添加对目标类具体连接点上的过程,可以在编译时(例如使用AspectJ编译器)、加载时或运行时完成

Spring切面可以应用5种类型的通知:

  • 前置通知(Before):在目标方法被调用之前调用通知

  • 后置通知(After):在目标方法完成之后调用通知(无论是正常还是异常退出)

  • 返回通知(After-returning):在目标方法成功执行之后调用通知

  • 异常通知(After-throwing):在目标方法抛出异常后调用通知

  • 环绕通知(Around):通知包裹了被通知的方法,在被通知的方法调用之前和调用之后执行自定义的行为

其执行的顺序为:

怎么在SpringBoot中使用AOP技术操作日志

怎么在SpringBoot中使用AOP技术操作日志

后续的基本应用,会将 环绕通知前置通知后置通知返回通知异常通知进行实现,并演示其执行顺序。

二、基本应用

声明通知
大家可以将下面的代码复制出来,验证上面的执行顺序。

@Aspect public class Test {  private static int step = 0;  @Pointcut("@annotation(com.chenyanwu.erp.erpframework.annotation.Log)") // the pointcut expression  private void operation() {}  @Before("operation()")  public void doBeforeTask() {   System.out.println(++step + " 前置通知");  }  @After("operation()")  public void doAfterTask() {   System.out.println(++step + " 后置通知");  }  @AfterReturning(pointcut = "operation()", returning = "retVal")  public void doAfterReturnningTask(Object retVal) {   System.out.println(++step + " 返回通知,返回值为:" + retVal.toString());  }  @AfterThrowing(pointcut = "operation()", throwing = "ex")  public void doAfterThrowingTask(Exception ex) {   System.out.println(++step + " 异常通知,异常信息为:" + ex.getMessage());  }  /**   * 环绕通知需要携带ProceedingJoinPoint类型的参数    * 环绕通知类似于动态代理的全过程ProceedingJoinPoint类型的参数可以决定是否执行目标方法    * 且环绕通知必须有返回值,返回值即目标方法的返回值   */  //@Around("operation()")  public Object doAroundTask(ProceedingJoinPoint pjp) {   String methodname = pjp.getSignature().getName();   Object result = null;   try {    // 前置通知    System.out.println("目标方法" + methodname + "开始,参数为" + Arrays.asList(pjp.getArgs()));    // 执行目标方法    result = pjp.proceed();    // 返回通知    System.out.println("目标方法" + methodname + "执行成功,返回" + result);   } catch (Throwable e) {    // 异常通知    System.out.println("目标方法" + methodname + "抛出异常: " + e.getMessage());   }   // 后置通知   System.out.println("目标方法" + methodname + "结束");   return result;  } }

其中需要注意的是切入点:@Pointcut的表达式
格式:

execution(modifiers-pattern? ret-type-pattern declaring-type-pattern? name-pattern(param-pattern)throws-pattern?)
括号中各个pattern分别表示:

  • 修饰符匹配(modifier-pattern?)

  • 返回值匹配(ret-type-pattern)可以为*表示任何返回值,全路径的类名等

  • 类路径匹配(declaring-type-pattern?)

  • 方法名匹配(name-pattern)可以指定方法名 或者 代表所有, set 代表以set开头的所有方法

  • 参数匹配((param-pattern))可以指定具体的参数类型,多个参数间用“,”隔开,各个参数也可以用“”来表示- 匹配任意类型的参数,如(String)表示匹配一个String参数的方法;(,String) 表示匹配有两个参数的方法,第一个参数可以是任意类型,而第二个参数是String类型;可以用(…)表示零个或多个任意参数

  • 异常类型匹配(throws-pattern?)

  • 其中后面跟着“?”的是可选项

示例:

1)execution(* (…))
//表示匹配所有方法
2)execution(public * com. savage.service.UserService.
(…))
//表示匹配com.savage.server.UserService中所有的公有方法
3)execution(* com.savage.server….(…))
//表示匹配com.savage.server包及其子包下的所有方法

三、日志管理实战

有了上面基本应用的理解,现在我们直接就贴代码:

1、依赖的jar包

<!-- aop依赖 --> <dependency>  <groupId>org.springframework.boot</groupId>  <artifactId>spring-boot-starter-aop</artifactId> </dependency>

2、自定义注解

@Target(ElementType.METHOD) @Retention(RetentionPolicy.RUNTIME) public @interface Log {  String value() default ""; }

3、实现切面

@Aspect @Order(5) @Component public class LogAspect {  private Logger logger = LoggerFactory.getLogger(LogAspect.class);  @Autowired  private ErpLogService logService;  @Autowired  ObjectMapper objectMapper;  private ThreadLocal<Date> startTime = new ThreadLocal<Date>();  @Pointcut("@annotation(com.chenyanwu.erp.erpframework.annotation.Log)")  public void pointcut() {  }  /**   * 前置通知,在Controller层操作前拦截   *   * @param joinPoint 切入点   */  @Before("pointcut()")  public void doBefore(JoinPoint joinPoint) {   // 获取当前调用时间   startTime.set(new Date());  }  /**   * 正常情况返回   *   * @param joinPoint 切入点   * @param rvt  正常结果   */  @AfterReturning(pointcut = "pointcut()", returning = "rvt")  public void doAfter(JoinPoint joinPoint, Object rvt) throws Exception {   handleLog(joinPoint, null, rvt);  }  /**   * 异常信息拦截   *   * @param joinPoint   * @param e   */  @AfterThrowing(pointcut = "pointcut()", throwing = "e")  public void doAfter(JoinPoint joinPoint, Exception e) throws Exception {   handleLog(joinPoint, e, null);  }  @Async  private void handleLog(final JoinPoint joinPoint, final Exception e, Object rvt) throws Exception{   // 获得注解   Method method = getMethod(joinPoint);   Log log = getAnnotationLog(method);   if (log == null) {    return;   }   Date now = new Date();   // 操作数据库日志表   ErpLog erpLog = new ErpLog();   erpLog.setErrorCode(0);   erpLog.setIsDeleted(0);   // 请求信息   HttpServletRequest request = ToolUtil.getRequest();   erpLog.setType(ToolUtil.isAjaxRequest(request) ? "Ajax请求" : "普通请求");   erpLog.setTitle(log.value());   erpLog.setHost(request.getRemoteHost());   erpLog.setUri(request.getRequestURI().toString()); //  erpLog.setHeader(request.getHeader(HttpHeaders.USER_AGENT));   erpLog.setHttpMethod(request.getMethod());   erpLog.setClassMethod(joinPoint.getSignature().getDeclaringTypeName() + "." + joinPoint.getSignature().getName());   // 请求的方法参数值   Object[] args = joinPoint.getArgs();   // 请求的方法参数名称   LocalVariableTableParameterNameDiscoverer u     = new LocalVariableTableParameterNameDiscoverer();   String[] paramNames = u.getParameterNames(method);   if (args != null && paramNames != null) {    StringBuilder params = new StringBuilder();    params = handleParams(params, args, Arrays.asList(paramNames));    erpLog.setParams(params.toString());   }   String retString = JsonUtil.bean2Json(rvt);   erpLog.setResponseValue(retString.length() > 5000 ? JsonUtil.bean2Json("请求参数数据过长不与显示") : retString);   if (e != null) {    erpLog.setErrorCode(1);    erpLog.setErrorMessage(e.getMessage());   }   Date stime = startTime.get();   erpLog.setStartTime(stime);   erpLog.setEndTime(now);   erpLog.setExecuteTime(now.getTime() - stime.getTime());   erpLog.setUsername(MySysUser.loginName());   HashMap<String, String> browserMap = ToolUtil.getOsAndBrowserInfo(request);   erpLog.setOperatingSystem(browserMap.get("os"));   erpLog.setBrower(browserMap.get("browser"));   erpLog.setId(IdUtil.simpleUUID());   logService.insertSelective(erpLog);  }  /**   * 是否存在注解,如果存在就获取   */  private Log getAnnotationLog(Method method) {   if (method != null) {    return method.getAnnotation(Log.class);   }   return null;  }  private Method getMethod(JoinPoint joinPoint) {   Signature signature = joinPoint.getSignature();   MethodSignature methodSignature = (MethodSignature) signature;   Method method = methodSignature.getMethod();   if (method != null) {    return method;   }   return null;  }  private StringBuilder handleParams(StringBuilder params, Object[] args, List paramNames) throws JsonProcessingException {   for (int i = 0; i < args.length; i++) {    if (args[i] instanceof Map) {     Set set = ((Map) args[i]).keySet();     List list = new ArrayList();     List paramList = new ArrayList<>();     for (Object key : set) {      list.add(((Map) args[i]).get(key));      paramList.add(key);     }     return handleParams(params, list.toArray(), paramList);    } else {     if (args[i] instanceof Serializable) {      Class<?> aClass = args[i].getClass();      try {       aClass.getDeclaredMethod("toString", new Class[]{null});       // 如果不抛出NoSuchMethodException 异常则存在 toString 方法 ,安全的writeValueAsString ,否则 走 Object的 toString方法       params.append(" ").append(paramNames.get(i)).append(": ").append(objectMapper.writeValueAsString(args[i]));      } catch (NoSuchMethodException e) {       params.append(" ").append(paramNames.get(i)).append(": ").append(objectMapper.writeValueAsString(args[i].toString()));      }     } else if (args[i] instanceof MultipartFile) {      MultipartFile file = (MultipartFile) args[i];      params.append(" ").append(paramNames.get(i)).append(": ").append(file.getName());     } else {      params.append(" ").append(paramNames.get(i)).append(": ").append(args[i]);     }    }   }   return params;  } }

4、对应代码添加注解

@Log("新增学生")  @RequestMapping(value = "/create", method = RequestMethod.POST)  @ResponseBody  public ResultBean<String> create(@RequestBody @Validated ErpStudent item) {   if(service.insertSelective(item) == 1) {    // 插入    insertErpSFamilyMember(item);    return new ResultBean<String>("");   }   return new ResultBean<String>(ExceptionEnum.BUSINESS_ERROR, "新增学生异常!", "新增失败!", "");  }

看完上述内容,你们掌握怎么在SpringBoot中使用AOP技术操作日志的方法了吗?如果还想学到更多技能或想了解更多相关内容,欢迎关注亿速云行业资讯频道,感谢各位的阅读!

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI