@Transactional事务提交后触发异步方法

1、问题复现

1.场景

2个service方法, 方法A中调用方法B。

方法A 是核心业务方法，涉及多张表数据变动，为了保持数据一致，用spring事务注解：@Transactional(rollbackFor = Exception.class)

方法B 比较耗时，为了避免影响核心业务，方法B 用@Async注解，单独开启一个线程去异步执行。（方法B在另一个类里边，不能和A在同一个类）。

2.出错缘由

方法B是异步方法，致使方法A事务还没提交时（不必定出错，具体就看哪一个线程执行的快了）方法B就执行了。

3.指望

指望方法A上的大事务commit后再执行方法B。

 

2、解决方案

 

1 // 注册事务同步处理
2 TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronizationAdapter() {
3 @Override
4 public void afterCommit() {
5     // 事务提交完毕时，触发：funcB
6     funB()；
7 }

 

3、原理

提交一个事务同步处理，在事务commit以后执行，具体存放在threadLocal（线程本地变量）中，事务commit时会去threadLocal里边取。源码afterCommit是空的，没有任何操做，可见是spring专门预留给你们使用的。

源码：

TransactionSynchronizationAdapter是一个接口适配器，这样不用实现接口的所有方法，按需Override便可。类图以下图所示：

TransactionSynchronizationAdapter实现了2个接口：

• TransactionSynchronization事务同步接口,
• Ordered执行优先级

咱们这里就是实现了TransactionSynchronization接口的afterCommit()方法，最终在事务commit提交后执行。
关于spring事务执行过程图：

 

4、总结

遇到问题后，很快就想到了处理方式，由于我提早储备了相关知识：

1.spring事务系列（具体在第三章 事务源码，里边有连接）

spring事务详解（一）初探事务

2.@Async实现异步

异步任务spring @Async注解源码解析

3.threadLocal线程本地变量

ThreadLocal终极源码剖析-一篇足矣！