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.*.*(..))";

  // 事务管理
  @Lazy
  private TransactionManager transactionManager;

  public TransactionAdviceConfig() {
  }

  @Bean
  public 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);
  }

  @Bean
  public Advisor txAdviceAdvisor() {
      AspectJExpressionPointcut pointcut = new AspectJExpressionPointcut();
      pointcut.setExpression("execution(* com.wang..*.service.*.*(..))");
      return new DefaultPointcutAdvisor(pointcut, this.txAdvice());
  }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61

因为使用了@Aspect注解，所以这里为自动注入容器。如果有方法不想使用事务也很见到，方法或类上加上@Transactional(propagation = Propagation.NOT_SUPPORTED)