Transactional事务提交后触发异步方法
一、问题复现
1.场景
2个service方法, 方法A中调用方法B。
方法A 是核心业务方法，涉及多张表数据变更，为了保持数据一致，用 spring事务注解 ：@Transactional(rollbackFor = Exception.class)
方法B 比较耗时 ，为了不影响核心业务，方法B 用 @Async注解，单独开启一个线程去异步执行 。（方法B在另外一个类里边，不能和A在同一个类）。
2.出错原因
方法B是异步方法，导致 方法A事务还没提交时（不一定出错，具体就看哪个线程执行的快了）方法B就执行了。
3.期望
期望方法A上的大事务commit后再执行方法B。
二、解决方案
1 // 注册事务同步处理
2 TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronizationAdapter() {
3 @Override
4 public void afterCommit() {
5 // 事务提交完毕时，触发：funcB
6 funB()；
7 }
三、原理
提交一个事务同步处理，在事务commit之后执行，具体存放在threadLocal（线程本地变量）中，事务commit时会去threadLocal里边取。源码 afterCommit 是空的，没有任何操作，可见是spring专门预留给大家使用的。
源码：
TransactionSynchronizationAdapter是一个接口适配器，这样不用实现接口的全部方法，按需Override即可。类图如下图所示：
TransactionSynchronizationAdapter实现了2个接口：
- TransactionSynchronization事务同步接口,
- Ordered执行优先级
我们这里就是实现了 TransactionSynchronization 接口的 afterCommit ()方法，最终在事务commit提交后执行。
关于spring事务执行过程图：
四、总结
遇到问题后，很快就想到了处理方式，因为我 提前储备了相关知识 ：
1.spring事务系列（具体在第三章 事务源码，里边有链接）
spring事务详解（一）初探事务
2.@Async实现异步
异步任务spring @Async注解源码解析
3.threadLocal线程本地变量
ThreadLocal终极源码剖析-一篇足矣！
正文到此结束
热门推荐
相关文章
Loading...
![[HBLOG]公众号](http://www.liuhaihua.cn/img/qrcode_gzh.jpg)
