Contents

面向切面编程--AOP概述

AOP:Aspect Oriented Programming(面向切面编程、面向方面编程),其实就是面向特定方法编程。

1. 场景示例

案例部分功能运行较慢,定位执行耗时较长的业务方法,此时需要统计每一个业务方法的执行耗时

如何实现? 一种策略是为为每个执行方法都添加获取执行耗时的逻辑. 缺点在于: 它需要更改原先的所有的业务代码, 同时获取执行耗时的代码逻辑相同, 造成了大量重复.

一种解决思想是: 使用动态代理, 也即在执行指定的部分代码时会在合适的节点转到代理逻辑中执行. 动态代理是面向切面编程最主流的实现。而 SpringAOP 是Spring框架的高级技术,旨在管理bean对象的过程中,主要通过底层的动态代理机制,对特定的方法进行编程。

Spring AOP快速入门:统计各个业务层方法执行耗时

  1. 先引入 aop 依赖

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-aop</artifactId>
    </dependency>
    
  2. 连包带类创建并编写AOP程序: 针对于特定方法根据业务需要进行编程. 通过使用 @Aspect 注解来表明这是一个切面类, 该类同时还是一个 java-bean.

@Component
@Aspect
public class TimeAspect {
    @Around("execution(* com.itheima.service.*.*(..))")
    public Object recordTime(ProceedingJoinPoint proceedingJoinPoint) throws Throwable {
        long begin = System.currentTimeMillis();
        Object object = proceedingJoinPoint.proceed(); //调用原始方法运
        long end = System.currentTimeMillis();
        log.info(proceedingJoinPoint.getSignature()+"执行耗时: {}ms", end - begin);
        return object;
    }
}

2. AOP核心概念

连接点: JoinPoint, 可以被AOP控制的方法(暗含方法执行时的相关信息) 通知: Advice, 指哪些重复的逻辑,也就是共性功能(最终体现为一个方法) 切入点: PointCut, 匹配连接点的条件,通知仅会在切入点方法执行时被应用 切面: Aspect, 描述通知与切入点的对应关系(通知+切入点) 目标对象: Target,通知所应用的对象

参考1中的程序, 其中 @Around("execution(* com.itheima.service.*.*(..))") 就是切入点, 引号内的表达式即为切入点表达式, 它规定了哪些类中的哪些方法需要被代理执行. @Around 注解是通知类型, 它指明了连接点在额外逻辑的执行位置, 这里是被环绕, 也即原方法执行前后均存在代理逻辑.

2.1 通知类型

通知类型 @Before(前置通知) @After(后置通知) @Around(环绕通知,重点) @AfterReturning(返回后通知,了解) @AfterThrowing(异常后通知,了解)

注解 通知类型 执行顺序
@Around 环绕通知 此注解标注的通知方法在目标方法前、后都被执行
@Before 前置通知 此注解标注的通知方法在目标方法前被执行
@After 后置通知 此注解标注的通知方法在目标方法后被执行,无论是否有异常都会执行
@AfterReturning 返回后通知 此注解标注的通知方法在目标方法后被执行,有异常不会执行
@AfterThrowing 异常后通知 此注解标注的通知方法发生异常后执行
  • @Around环绕通知需要自己调用 ProceedingJoinPoint.proceed() 来让原始方法执行,其他通知不需要考虑目标方法执行
  • @Around环绕通知方法的返回值,必须指定为Object,来接收原始方法的返回值。

2.2 PointCut

@PointCut: 该注解的作用是将公共的切点表达式抽取出来,需要用到时引用该切点表达式即可。

@Pointcut("execution(* com.example.mytliasaop.controller.DeptController.getDeptById())")
public void allDeptCut(){}

@Around("allDeptCut()")
public Object aroundNoticeFunA(ProceedingJoinPoint point) throws Throwable {
    // some code
}

该表达式也可以使用访问权限修饰符修饰:
private:仅能在当前切面类中引用该表达式
public:在其他外部的切面类中也可以引用该表达式

2.3 通知顺序

当有多个切面的切入点都匹配到了目标方法,目标方法运行时,多个通知方法都会被执行。

不同切面类中,默认按照切面类的类名字母排序:
目标方法前的通知方法:字母排名靠前的先执行
目标方法后的通知方法:字母排名靠前的后执行

@Order(数字) 加在切面类上来控制顺序 目标方法前的通知方法:数字小的先执行

@Aspect
@Component
@Slf4j
@Order(3)
public class NoticeTypeAsp {
}

2.4 使用通知函数的参数

若有参数, 则只有一个, 也即连接点, 在Spring中用JoinPoint抽象表示连接点,用它可以获得方法执行时的相关信息,如目标类名、方法名、方法参数等。

  • 对于 @Around 通知,获取连接点信息只能使用 ProceedingJoinPoint

  • 对于其他四种通知,获取连接点信息只能使用 JoinPoint ,它是 ProceedingJoinPoint 的父类型

@Before("execution(* com.itheima.service.DeptService.*(..))")
public void before(JoinPoint joinPoint) {
    String className = joinPoint.getTarget().getClass().getName(); //获取目标类名
    Signature signature = joinPoint.getSignature(); //获取目标方法签名
    String methodName = joinPoint.getSignature().getName(); //获取目标方法名
    Object[] args = joinPoint.getArgs(); //获取目标方法运行参数 
}

2.5 示例

编写如下示例程序:

@Aspect
@Component
@Slf4j
public class NoticeTypeAsp {
    @Pointcut("execution(* com.example.mytliasaop.controller.DeptController.getDeptById(..))")
    public void allDeptCut(){}

    @Around("allDeptCut()")
    public Object aroundNoticeFunA(ProceedingJoinPoint point) throws Throwable {
        log.info("Around Notice: enter ... ...");
        Object res = point.proceed();
        log.info("Around Notice: after point.proceed(), before return ... ...");
        return res;
    }

    @Before("allDeptCut()")
    public void beforeNotice() {
        log.info("Before Notice: execute ... ...");
    }

    @After("allDeptCut()")
    public void afterNotice() {
        log.info("After Notice: execute ... ...");
    }

    @AfterReturning("allDeptCut()")
    public void afterReturnNotice(){
        log.info("After returning Notice: execute ... ...");
    }

    @AfterThrowing("allDeptCut()")
    public void afterThrowNotice() {
        log.info("After Throw Notice: enter ... ...");
    }

    @Before("allDeptCut()")
    public void beforeWithArgs(JoinPoint point){
        log.info("Before Notice with join-point args: enter ... ...");
        log.info("Before Notice with join-point args: 方法名 {}", point.getSignature());
        log.info("Before Notice with join-point args: 方法参数 {}}", point.getArgs());
        log.info("Before Notice with join-point args: 类名 {}", point.getTarget().getClass().getName());
    }
}

getDeptById() 方法正常执行完毕哪些通知会被执行? 出现异常时哪些通知会被执行?

example.mytliasaop.aop.NoticeTypeAsp   : Around Notice: enter ... ...
example.mytliasaop.aop.NoticeTypeAsp   : Before Notice: execute ... ...
example.mytliasaop.aop.NoticeTypeAsp   : Before Notice with join-point args: enter ... ...
example.mytliasaop.aop.NoticeTypeAsp   : Before Notice with join-point args: 方法名 Result com.example.mytliasaop.controller.DeptController.getDeptById(Integer)
example.mytliasaop.aop.NoticeTypeAsp   : Before Notice with join-point args: 方法参数 2}
example.mytliasaop.aop.NoticeTypeAsp   : Before Notice with join-point args: 类名 com.example.mytliasaop.controller.DeptController
e.m.controller.DeptController          : 依据id获取部门信息: 2
... ... ...
example.mytliasaop.aop.NoticeTypeAsp   : After returning Notice: execute ... ...
example.mytliasaop.aop.NoticeTypeAsp   : After Notice: execute ... ...
example.mytliasaop.aop.NoticeTypeAsp   : Around Notice: after point.proceed(), before return ... ...

异常时:

example.mytliasaop.aop.NoticeTypeAsp   : Around Notice: enter ... ...
example.mytliasaop.aop.NoticeTypeAsp   : Before Notice: execute ... ...
example.mytliasaop.aop.NoticeTypeAsp   : Before Notice with join-point args: enter ... ...
example.mytliasaop.aop.NoticeTypeAsp   : Before Notice with join-point args: 方法名 Result com.example.mytliasaop.controller.DeptController.getDeptById(Integer)
example.mytliasaop.aop.NoticeTypeAsp   : Before Notice with join-point args: 方法参数 4}
example.mytliasaop.aop.NoticeTypeAsp   : Before Notice with join-point args: 类名 com.example.mytliasaop.controller.DeptController
e.m.controller.DeptController          : 依据id获取部门信息: 4
example.mytliasaop.aop.NoticeTypeAsp   : After Throw Notice: enter ... ...
example.mytliasaop.aop.NoticeTypeAsp   : After Notice: execute ... ...

3. 切入点表达式

切入点表达式:描述切入点方法的一种表达式 作用:主要用来决定项目中的哪些方法需要加入通知 常见形式: execution(...):根据方法的签名来匹配 @annotation(...) :根据注解匹配

3.1 切入点表达式-execution

execution 主要根据方法的返回值、包名、类名、方法名、方法参数等信息来匹配,语法为:

execution(访问修饰符? 返回值 包名.类名.?方法名(方法参数) throws 异常?)

其中带 ? 的表示可以省略的部分 访问修饰符:可省略(比如: public、protected) 包名.类名: 可省略 throws 异常:可省略(注意是方法上声明抛出的异常,不是实际抛出的异常)

可以使用通配符描述切入点 *: 单个独立的任意符号,可以通配任意返回值、包名、类名、方法名、任意类型的一个参数,也可以通配包、类、方法名的一部分. execution(* com.*.service.*.update*(*))

..: 多个连续的任意符号,可以通配任意层级的包,或任意类型、任意个数的参数 execution(* com.itheima..DeptService.*(..))

  • 根据业务需要,可以使用 且(&&)、或(||)、非(!) 来组合比较复杂的切入点表达式。

切入点表达式-execution书写建议:

  • 所有业务方法名在命名时尽量规范,方便切入点表达式快速匹配。如:查询类方法都是 find 开头,更新类方法都是 update开头。

  • 描述切入点方法通常基于接口描述,而不是直接描述实现类,增强拓展性。

  • 在满足业务需要的前提下,尽量缩小切入点的匹配范围。如:包名匹配尽量不使用.., 使用 * 匹配单个包。

3.2 切入点表达式-@annotation

@annotation(com.itheima.anno.Log) 通过注解匹配 先编写一个注解: 只起到标记作用

package com.example.mytliasaop.ana;

import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
public @interface MyAnalog {
}

这表示这是一个用于方法上的在运行时起作用的注解. 然后使用它

@Around("@annotation(com.example.mytliasaop.ana.MyAnalog)")
public Object around(ProceedingJoinPoint pt) throws Throwable {
    // some code
}

4. 案例

将案例中 增、删、改 相关接口的操作日志记录到数据库表中。 日志信息包含:操作人、操作时间、执行方法的全类名、执行方法名、方法运行时参数、返回值、方法执行时长

准备:

  • 在案例工程中引入AOP的起步依赖
  • 导入资料中准备好的数据库表结构,并引入对应的实体类
  • 编码:
    • 自定义注解 @Log
    • 定义切面类,完成记录操作日志的逻辑
    • 获取request对象,从请求头中获取到jwt令牌,解析令牌获取出当前用户的id。
@Aspect
@Component
@Slf4j
public class LoggerAspect {
    @Autowired
    HttpServletRequest request;

    @Autowired
    private OperateLogMapper mp;

    @Around("@annotation(com.example.mytliasaop.ana.MyAnalog)")
    public Object logRecord(ProceedingJoinPoint pt) throws Throwable{
        log.info("进入logRecord代理");
        // 1. 获取登录者的信息
        String jwt = request.getHeader("token");
        Claims claims = JWTUtils.parse(jwt);
        Integer operateUser = Integer.parseInt((String) claims.get("id"));
        // 2. 操作时间
        LocalDateTime operateTime = LocalDateTime.now();
        // 3. 操作类名
        String className = pt.getTarget().getClass().getName();
        // 4. 方法名
        String methodName = pt.getSignature().getName();
        // 5. 方法参数
        String methodParams = Arrays.toString(pt.getArgs());
        // 6. 返回值
        long st = System.currentTimeMillis();
        Object res = pt.proceed();
        String returnValue = JSONObject.toJSONString(res);
        // 7. 操作耗时
        Long costTime = System.currentTimeMillis() - st;

        OperateLog operateLog = new OperateLog(null, operateUser, operateTime, className,
                methodName, methodParams, returnValue, costTime);
        log.info("{}", operateLog);
        // 插入 log 记录
        mp.insertLog(operateLog);
        return res;
    }
}

注意, 其中的 request 对象是在 spring web 项目启动时已经由 java-bean 进行管理 此外, 关于 MyAnalog 的位置, 可以放到 controller 层的各个已实现的方法(新增修改删除)上.