Spring5.0源码深度解析之SpringBean的Aop的使用

SpringAOP

什么是Aop编程

Aop面向切面编程，在方法以前和以后实现处理 应用场景在于：日志打印、事务实现、安全等。

由于AOP能够解决咱们程序上的代码冗余问题

Spring的AOP

前置通知

后置通知

环绕通知

运行通知

异常通知

Aop编程底层的原理

动态代理技术

• 基于Jdk实现InvocationHandler 底层使用反射技术
• 基于CGLIB实现 字节码技术

基于注解方式启动Aop

<dependencies>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-context</artifactId>
        <version>5.0.5.RELEASE</version>
    </dependency>
    <dependency>
        <groupId>org.aspectj</groupId>
        <artifactId>aspectjweaver</artifactId>
        <version>1.8.13</version>
    </dependency>
</dependencies>

日志AOP

@Aspect//定义切面类
@Component//注入spring容器
@EnableAspectJAutoProxy//开启AOP
public class LogAop {
    //定义切入点,表示开始拦截的入口
    @Pointcut("execution (* com.xuyu.service..*.*(..))")
    public void logAop(){

    }
    @Before("logAop()")
    public void doBefor(){
        System.out.println("前置通知....在调用方法以前拦截");
    }
    @After("logAop()")
    public void doAfter(){
        System.out.println("后置通知....在调用方法以后拦截");
    }
}

Config

@Configuration
@ComponentScan(basePackages = {"com.xuyu.service","com.xuyu.aop"})
public class MyConfig {
}

service

@Component
public class OrderService {

    public void addOrder(){
        System.out.println("执行目标方法....");
    }
}

启动类

public class App {
    public static void main(String[] args) {
        AnnotationConfigApplicationContext applicationContext = new AnnotationConfigApplicationContext(MyConfig.class);
        OrderService orderService = applicationContext.getBean("orderService", OrderService.class);
        orderService.addOrder();
    }
}

执行结果

前置通知....在调用方法以前拦截
执行目标方法....
后置通知....在调用方法以后拦截

咱们开始分析下源码

因此咱们能够直接使用@Import注解把AspectJAutoProxyRegistrar这个类注入IOC容器中

@Import(AspectJAutoProxyRegistrar.class)

等价于这个注解

@EnableAspectJAutoProxy//开启AOP

完整的五个通知

@Aspect//定义切面类
@Component//注入spring容器
@EnableAspectJAutoProxy//开启AOP
public class LogAop {
    //定义切入点,表示开始拦截的入口
    @Pointcut("execution (* com.xuyu.service..*.*(..))")
    public void logAop(){

    }
    @Before("logAop()")
    public void doBefore(){
        System.out.println("前置通知....在调用方法以前拦截");
    }
    @After("logAop()")
    public void doAfter(){
        System.out.println("后置通知....在调用方法以后拦截");
    }
    @AfterReturning("logAop()")
    public void  around(JoinPoint joinpoint) throws Throwable {
        String name = joinpoint.getSignature().getName();
        System.out.println("返回通知...."+name);
    }
    @AfterThrowing("logAop()")
    public void afterThrowing(JoinPoint joinPoint) {
        System.out.println("异常通知....");
    }
    @Around("logAop()")
    public void doAround(ProceedingJoinPoint joinPoint) throws Throwable {
        System.out.println("环绕通知，在目标方法以前处理....");
        joinPoint.proceed();//执行目标方法
        System.out.println("环绕通知，在目标方法以后处理....");
    }
}

打印结果

环绕通知，在目标方法以前处理....
前置通知....在调用方法以前拦截
目标方法执行....
环绕通知，在目标方法以后处理....
后置通知....在调用方法以后拦截
返回通知....addOrder

springBoot手动事务实现方式

手动begin commit rollback

@Component
public class TransactionalUtils {
    //TransactionAspectSupport currentTransactionStatus().setRollbackOnly();
    /**
     * 获取当前事务管理器
     */
    @Autowired
    private DataSourceTransactionManager dataSourceTransactionManager;

    public TransactionStatus begin() {
        TransactionStatus transaction = dataSourceTransactionManager.getTransaction(new DefaultTransactionAttribute());
        System.out.println("获取当前的事务>>>>>");
        return transaction;
    }
    /**
     * 提交事务
     */
    public void commit(TransactionStatus transactionStatus) {
        System.out.println("提交当前的事务>>>>>");
        dataSourceTransactionManager.commit(transactionStatus);
    }
    public void rollback(TransactionStatus transactionStatus) {
        System.out.println("回滚当前的事务>>>>>");
        dataSourceTransactionManager.rollback(transactionStatus);
    }
}

@Service
public class OrderService {
    @Autowired
    private OrderInfoMapper orderInfoMapper;
    @Autowired
    private TransactionalUtils transactionalUtils;


        public int addOrderInfo(int j) {
        TransactionStatus begin = transactionalUtils.begin();
        try {
            int i = orderInfoMapper.addOrderInfo();
            int result = 1 / j;
            transactionalUtils.commit(begin);
        } catch (Exception e) {
            e.printStackTrace();
            transactionalUtils.rollback(begin);
        }
        return 1;
    }

手动begin commit rollback代码会冗余，因此咱们使用AOP重构下手动事务

使用SpringAop实现重构实现声明式事务

@Aspect
@Component
@Scope("prototype")//单例会有问题，这里设置为多例
public class TransactionalAop {
    //Aspect 定义切点类
    @Autowired
    private TransactionalUtils transactionalUtils;
    /**
     * @Pointcut 定义切入点
     */
    @Pointcut("execution (* com.mayikt.service..*.*(..))")
    public void transactionalAop() {
    }
    @Around("transactionalAop()")
    public Object around(ProceedingJoinPoint joinPoint) throws Throwable {
        // 获取方法名称
        String methodName = joinPoint.getSignature().getName();
        // 获取目标对象
        Class<?> classTarget = joinPoint.getTarget().getClass();
        // 获取目标对象类型
        Class<?>[] par = ((MethodSignature) joinPoint.getSignature()).getParameterTypes();
        // 获取目标对象方法
        Method objMethod = classTarget.getMethod(methodName, par);
        // 判断该目标方法上是否有加上自定义事务注解
        ExtTransactional extTransactional = objMethod.getDeclaredAnnotation(ExtTransactional.class);
        if (extTransactional == null) {
            return joinPoint.proceed();// 执行目标方法
        }
        TransactionStatus begin = transactionalUtils.begin();
        try {
            System.out.println(">>>>环绕通知以前执行...>>>>>>");
            Object proceed = joinPoint.proceed();// 执行目标方案
            System.out.println(">>>>环绕通知以后执行...>>>>>>");
            transactionalUtils.commit(begin);
            return proceed;
        } catch (Exception e) {
            // 目标方法抛出异常的状况下 回滚当前事务
            transactionalUtils.rollback(begin);
            return 0;
        }
    }
}

@Target({ElementType.METHOD, ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface  ExtTransactional {
}

@ExtTransactional
public int addOrderInfo(int j) {
    int i = orderInfoMapper.addOrderInfo();
    return i;
}

注意的问题 若是在service 层 抛出异常的状况下 最好使用 TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();

本文参考：

蚂蚁课堂：http://www.mayikt.com/