SpringBoot全局事务处理

桃扇骨 2022-12-10 05:59 113阅读 0赞

1.pom.xml

<dependency>
        <groupId>org.aspectj</groupId>
        <artifactId>aspectjweaver</artifactId>
        <version>1.8.9</version>
    </dependency>

2.全局事务配置类

/**
     * @Description: 配置全局事务
     * @author: zsq
     */
    @Aspect
    @Configuration
    public class TransactionManagerConfig {
        private final static Logger logger = LoggerFactory.getLogger(TransactionManagerConfig.class);
    
        private static final int AOP_TIME_OUT = 50000;
    
        private static final String AOP_POINTCUT_EXPRESSION = "(execution(* com.zhang..*Impl.*(..)))";
    
        @Autowired
        private PlatformTransactionManager transactionManager;
    
        @Bean
        public TransactionInterceptor txAdvice(){
            NameMatchTransactionAttributeSource source = new NameMatchTransactionAttributeSource();
    
            /** 只读事务，不做更新操作 注:此事务下做修改操作会报错*/
            RuleBasedTransactionAttribute readOnlyTx = new RuleBasedTransactionAttribute();
            readOnlyTx.setReadOnly(true);
            readOnlyTx.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED); //支持当前事务；如果不存在，请创建一个新的
    
            /** 非只读事务 , 如果没有事务,就以非事务执行*/
    //        readOnlyTx.setReadOnly(false);
    //        readOnlyTx.setPropagationBehavior(TransactionDefinition.PROPAGATION_SUPPORTS); //支持当前事务；如果不存在，则以非事务方式执行。
    
            /** 事务类型*/
           // readOnlyTx.setPropagationBehavior(TransactionDefinition.PROPAGATION_NOT_SUPPORTED);//不支持当前交易；而是始终以非事务方式执行。
    
            /** 当前存在事务就使用当前事务，当前不存在事务就创建一个新的事务 */
            RuleBasedTransactionAttribute requiredTx = new RuleBasedTransactionAttribute();
    
            /** 什么异常需要回滚 */
            requiredTx.setRollbackRules(Collections.singletonList(new RollbackRuleAttribute(Exception.class)));
            requiredTx.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);//支持当前事务；如果不存在，请创建一个新的
            requiredTx.setTimeout(AOP_TIME_OUT);
    
            Map<String, TransactionAttribute> methodMap = new HashMap<>();
    
            /** 可以提及事务或回滚事务的方法 */
            methodMap.put("add*", requiredTx);
            methodMap.put("save*", requiredTx);
            methodMap.put("update*", requiredTx);
            methodMap.put("modify*", requiredTx);
            methodMap.put("edit*", requiredTx);
            methodMap.put("insert*", requiredTx);
            methodMap.put("delete*", requiredTx);
            methodMap.put("remove*", requiredTx);
            methodMap.put("repair*", requiredTx);
            methodMap.put("binding*", requiredTx);
    
            /** 其他方法无事务，只读 */
            methodMap.put("*", readOnlyTx);
            source.setNameMap(methodMap);
    
            TransactionInterceptor txAdvice = new TransactionInterceptor(transactionManager, source);
            return txAdvice;
        }
    
        @Bean(name = "txAdviceAdvisor")
        public Advisor txAdviceAdvisor() {
            logger.info("===============================创建txAdviceAdvisor===================================");
            AspectJExpressionPointcut pointcut = new AspectJExpressionPointcut();
            pointcut.setExpression(AOP_POINTCUT_EXPRESSION);
            return new DefaultPointcutAdvisor(pointcut, txAdvice());
        }
    }

3.注意事项,其他操作的时候,根据需要选择事务类型 .当选择,只读状态. 操作只能是查询,不可做修改操作,不然会报错,

当选择非事务的话,则增删改查都能执行,错误不会滚;