SpringBoot配置全局事务管理

电玩女神 2021-09-21 23:48 383阅读 0赞

### 目录 ###

*  一、注解方式
 *  二、AOP的方式

> 基于 SpringBoot 4.5

# 一、注解方式 #

**1、在SpringBoot的启动类上加入**

@EnableTransactionManagement

@SpringBootApplication
    // 开启事务支持
    @EnableTransactionManagement
    public class Application { 
    	public static void main(String[] args) { 
    		SpringApplication.run(Application.class, args);
    	}
    }

**2、在需要事务支持的类（class）或方法（method）上，加上注解并设置其属性**

/* * 表明该类（class）或方法（method）受事务控制 * @param propagation 设置隔离级别 * @param isolation 设置传播行为 * @param rollbackFor 设置需要回滚的异常类，默认为RuntimeException */
    @Transactional(propagation = Propagation.REQUIRED, isolation = Isolation.READ_COMMITTED, rollbackFor = Exception.class)

@Service
    public class UserServiceImpl implements UserService { 
        @Override
        @Transactional(propagation = Propagation.REQUIRED, isolation = Isolation.READ_COMMITTED, rollbackFor = Exception.class)
        public int addUser(User user) { 
            return userMapper.addUser(user);
        }
    }

# 二、AOP的方式 #

package com.pro.config;
    
    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.TransactionDefinition;
    import org.springframework.transaction.TransactionManager;
    import org.springframework.transaction.interceptor.NameMatchTransactionAttributeSource;
    import org.springframework.transaction.interceptor.RollbackRuleAttribute;
    import org.springframework.transaction.interceptor.RuleBasedTransactionAttribute;
    import org.springframework.transaction.interceptor.TransactionInterceptor;
    
    import java.util.Collections;
    
    
    /** * 全局事务配置类 */
    @Aspect
    @Configuration
    public class TransactionConfig { 
        // 切入点
        private static final String AOP_POINTCUT_EXPRESSION = "execution(* com.pro.service.*.*(..))";
        // 需要添加事务切入的方法列表, 使用这些前缀的方法都会被添加事务
        private static final String[] REQUIRED_RULE_TRANSACTION = { "insert*", "create*", "add*", "save*", "update*", "del*", "delete*"};
        private static final String[] READ_RULE_TRANSACTION = { "select*", "get*", "query*", "search*", "count*", "find*"};
    
        @Autowired
    // private PlatformTransactionManager transactionManager;
        private TransactionManager transactionManager;
    
        @Bean
        public TransactionInterceptor txAdvice() { 
            // 增删改事务
            RuleBasedTransactionAttribute REQUIRED = new RuleBasedTransactionAttribute();
            // 当抛出设置的对应异常后，进行事务回滚（此处设置为“Exception”级别）
            REQUIRED.setRollbackRules(Collections.singletonList(new RollbackRuleAttribute(Exception.class)));
            // 设置隔离级别（读已提交的数据）
            REQUIRED.setIsolationLevel(TransactionDefinition.ISOLATION_READ_COMMITTED);
            // 设置传播行为（存在事务则加入其中，不存在则新建事务）
            REQUIRED.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
    
            // 只读事务，不做更新操作
            RuleBasedTransactionAttribute READONLY = new RuleBasedTransactionAttribute();
            // 当抛出设置的对应异常后，进行事务回滚（此处设置为“Exception”级别）
            READONLY.setRollbackRules(Collections.singletonList(new RollbackRuleAttribute(Exception.class)));
            // 设置隔离级别（读已提交的数据）
            READONLY.setIsolationLevel(TransactionDefinition.ISOLATION_READ_COMMITTED);
            // 设置传播行为（如果当前存在事务，则加入这个事务，如果当前没有事务，就以非事务方式执行）
            READONLY.setPropagationBehavior(TransactionDefinition.PROPAGATION_SUPPORTS);
            // 设置事务是否“只读”（非必需，只是声明该事务中不会进行修改数据库的操作，可减轻由事务造成的数据库压力，属于性能优化的推荐配置）
            READONLY.setReadOnly(true);
    
            // 事务管理规则，承载需要进行事务管理的方法名（模糊匹配）及设置的事务管理属性
            NameMatchTransactionAttributeSource source = new NameMatchTransactionAttributeSource();
    
            // 增删改方法的前缀
            for (String s : REQUIRED_RULE_TRANSACTION) { 
                source.addTransactionalMethod(s, REQUIRED);
            }
            // 查询方法的前缀
            for (String s : READ_RULE_TRANSACTION) { 
                source.addTransactionalMethod(s, READONLY);
            }
    
            // 实例化事务拦截器
            return new TransactionInterceptor(transactionManager, source);
        }
    
        @Bean
        public Advisor txAdviceAdvisor() { 
            // 声明切点要切入的面
            AspectJExpressionPointcut pointcut = new AspectJExpressionPointcut();
            // 设置需要被拦截的路径
            pointcut.setExpression(AOP_POINTCUT_EXPRESSION);
            // 设置切面和配置好的事务管理
            return new DefaultPointcutAdvisor(pointcut, txAdvice());
        }
    }