@Transactional事务提交后触发异步方法
2023-02-18 16:36:29 时间
一、问题复现
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事务系列(具体在第三章 事务源码,里边有链接)
2.@Async实现异步
3.threadLocal线程本地变量
相关文章
- 5天不再惧怕多线程——第二天 锁机制
- 5天不再惧怕多线程——第一天 尝试Thread
- 算法洗脑系列(8篇)——第八篇 概率思想
- 算法洗脑系列(8篇)——第七篇 动态规划
- 算法洗脑系列(8篇)——第六篇 回溯思想
- 算法洗脑系列(8篇)——第五篇 分治思想
- 12篇学通C#网络编程——第二篇 HTTP应用编程(上)
- 算法洗脑系列(8篇)——第四篇 枚举思想
- 算法洗脑系列(8篇)——第三篇 贪心思想
- chrome插件 - Redirect Path(揪出隐藏起来的小尾巴)
- 忙活了一年的开源社区,终于赶上了春节前的末班车!
- ChatGPT 会开源吗?
- 7 款殿堂级的开源 CMS(内容管理系统)
- 请收下这 10 个安全相关的开源项目
- MySQL 5.7 升级到 8.0
- 越折腾越好用的 3 款开源 APP
- 10 款更先进的开源命令行工具
- 对开源框架跃跃欲试,却在写的时候犯了难?
- 一大波开源小抄来袭
- 物联网?快来看 Arduino 上云啦