SpringBoot自定义全局事务

1.说明

关于@EnableTransactionManagement注解，可加可不加，加注解保证规范性。

2.核心代码

/**
* @author: wangning
* @date: 2024/1/23 16:19
*/
@Aspect
@Configuration
@ConditionalOnClass({TransactionManager.class, TransactionFactory.class})
public class TransactionAdviceConfig {private static final String AOP_POINTCUT_EXPRESSION = "execution(* com.wang..*.service.*.*(..))";// 事务管理@Lazyprivate TransactionManager transactionManager;public TransactionAdviceConfig() {}@Beanpublic TransactionInterceptor txAdvice() {// 设置第一个事务管理模式用于增删改RuleBasedTransactionAttribute txAttrRequired = new RuleBasedTransactionAttribute();// 设置事务的传播行为(当前存在事务则加入其中，不存在则修改)txAttrRequired.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);// 指定事务回滚异常级别，设置为Exception级别txAttrRequired.setRollbackRules(Collections.singletonList(new RollbackRuleAttribute(Exception.class)));// 设置第二个事务管理模式用于查RuleBasedTransactionAttribute txAttrRequiredReadonly = new RuleBasedTransactionAttribute();// 设置事务的传播行为txAttrRequiredReadonly.setPropagationBehavior(0);// 没有设置事务的隔离级别，默认为数据库的隔离级别// 设置事务是否为“只读”（非必须，只是声明该事务中不会进行修改数据库的操作，可减轻由事务机制造成的数据库，属压力于性能优化推荐配置）txAttrRequiredReadonly.setReadOnly(true);// 事务管理规则，承载需要事务管理的方法名，以及事务传播行为和隔离级别NameMatchTransactionAttributeSource source = new NameMatchTransactionAttributeSource();source.addTransactionalMethod("insert*", txAttrRequired);source.addTransactionalMethod("save*", txAttrRequired);source.addTransactionalMethod("add*", txAttrRequired);source.addTransactionalMethod("create*", txAttrRequired);source.addTransactionalMethod("delete*", txAttrRequired);source.addTransactionalMethod("remove*", txAttrRequired);source.addTransactionalMethod("update*", txAttrRequired);source.addTransactionalMethod("modify*", txAttrRequired);source.addTransactionalMethod("exec*", txAttrRequired);source.addTransactionalMethod("set*", txAttrRequired);source.addTransactionalMethod("reset*", txAttrRequired);source.addTransactionalMethod("batch*", txAttrRequired);source.addTransactionalMethod("lock*", txAttrRequired);source.addTransactionalMethod("register*", txAttrRequired);source.addTransactionalMethod("*", txAttrRequiredReadonly);return new TransactionInterceptor(this.transactionManager, source);}@Beanpublic Advisor txAdviceAdvisor() {AspectJExpressionPointcut pointcut = new AspectJExpressionPointcut();pointcut.setExpression("execution(* com.wang..*.service.*.*(..))");return new DefaultPointcutAdvisor(pointcut, this.txAdvice());}
}