【SpringBoot10】SpringBoot中利用AOP切面开启全局事务管理

╰半夏微凉° 2024-03-26 19:30 63阅读 0赞

**在 JavaEE 的开发过程中，service 方法用于处理主要的业务逻辑，而业务逻辑的处理往往伴随着对数据库的多个操作，我们并不能保证业务逻辑可以完全正确地执行，我们需要在业务逻辑中加入事务管理，一旦程序出错，数据库可以回滚，保证数据的准确性**

#### 1、引入依赖文件 ####

<dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-aspects</artifactId>
    </dependency>

#### 2、创建 TransactionConfig.java 文件 ####

import org.aspectj.lang.annotation.Aspect;
    import org.springframework.aop.Advisor;
    import org.springframework.aop.aspectj.AspectJExpressionPointcut;
    import org.springframework.aop.support.DefaultPointcutAdvisor;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.transaction.PlatformTransactionManager;
    import org.springframework.transaction.TransactionDefinition;
    import org.springframework.transaction.interceptor.DefaultTransactionAttribute;
    import org.springframework.transaction.interceptor.NameMatchTransactionAttributeSource;
    import org.springframework.transaction.interceptor.TransactionInterceptor;
    
    /**
     * @ClassName TransactionConfig
     * 事务管理配置，拦截service包下所有方法
     * @Author Lizhou
     * @Date 2019-09-05 17:39:39
     * @Version 1.0
     **/
    @Aspect
    @Configuration
    public class TransactionConfig {
    
        /**
         * 切面地址
         */
        private static final String AOP_POINTCUT_EXPRESSION = "execution(* com.lzzy.meet.service.*.*(..))";
        /**
         * 事务失效时间
         */
        private static final int TX_METHOD_TIMEOUT = 5;
    
        @Autowired
        private PlatformTransactionManager transactionManager;
    
        /**
         * 事务配置
         *
         * @return
         */
        @Bean
        public TransactionInterceptor txAdvice() {
    
            DefaultTransactionAttribute txAttr_REQUIRED = new DefaultTransactionAttribute();
            /**
             * PROPAGATION_REQUIRED:事务隔离性为 1
             * 若当前存在事务，则加入该事务
             * 如果当前没有事务，则创建一个新的事务，这是默认值
             */
            txAttr_REQUIRED.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
            /**
             * 设置事务失效时间，如果超过5秒，则回滚事务
             */
            txAttr_REQUIRED.setTimeout(TX_METHOD_TIMEOUT);
    
            DefaultTransactionAttribute txAttr_REQUIRED_READONLY = new DefaultTransactionAttribute();
            /**
             * transactiondefinition 定义事务的隔离级别；
             * PROPAGATION_NOT_SUPPORTED 事务传播级别5，以非事务运行，如果当前存在事务，则把当前事务挂起
             */
            txAttr_REQUIRED_READONLY.setPropagationBehavior(TransactionDefinition.PROPAGATION_NOT_SUPPORTED);
            /**
             * 设置当前事务是否为只读事务
             * true为只读
             */
            txAttr_REQUIRED_READONLY.setReadOnly(true);
    
            /**
             * 事务管理规则，声明具备事务管理的方法名
             */
            NameMatchTransactionAttributeSource source = new NameMatchTransactionAttributeSource();
    
            source.addTransactionalMethod("save*", txAttr_REQUIRED);
            source.addTransactionalMethod("add*", txAttr_REQUIRED);
            source.addTransactionalMethod("delete*", txAttr_REQUIRED);
            source.addTransactionalMethod("update*", txAttr_REQUIRED);
    
            source.addTransactionalMethod("get*", txAttr_REQUIRED_READONLY);
            source.addTransactionalMethod("query*", txAttr_REQUIRED_READONLY);
            source.addTransactionalMethod("find*", txAttr_REQUIRED_READONLY);
            source.addTransactionalMethod("list*", txAttr_REQUIRED_READONLY);
            source.addTransactionalMethod("count*", txAttr_REQUIRED_READONLY);
    
            return new TransactionInterceptor(transactionManager, source);
        }
    
        /**
         * 利用AspectJExpressionPointcut设置切面=切点+通知（写成内部bean的方式）
         *
         * @return
         */
        @Bean
        public Advisor txAdviceAdvisor() {
            /**
             * 声明切点的面
             * 切面（Aspect）：切面就是通知和切入点的结合。
             * 通知和切入点共同定义了关于切面的全部内容——它的功能、在何时和何地完成其功能
             */
            AspectJExpressionPointcut pointcut = new AspectJExpressionPointcut();
            /**
             * 声明和设置需要拦截的方法,用切点语言描写
             */
            pointcut.setExpression(AOP_POINTCUT_EXPRESSION);
            /**
             * 设置切面=切点pointcut+通知TxAdvice
             */
            return new DefaultPointcutAdvisor(pointcut, txAdvice());
        }
    }

3、解析  
通过 @Aspect 定义一个切面，使用 @Configuration 声明当前类是一个配置类

我们业务逻辑一般都放在 service 层进行处理，所以我们定义的切入点为：com.lzzy.meet.service..(…)，即 service 下的所有方法

我们设置了事务失效时间为：5秒，超过五秒，则回滚事务，并定义了事务的隔离性和隔离级别，并声明该事务为只读

最后我们利用 AspectJExpressionPointcut 设置切面 = 切点 + 通知（写成内部bean的方式）

SpringBoot 中利用 AOP 切面开启全局事务管理就到这儿