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

雨点打透心脏的1/2处 2022-12-31 12:21 160阅读 0赞

**目录**

*  [一、问题复现][Link 1]
    
     *  [1.场景][1.]
     *  [2.出错原因][2.]
     *  [3.期望][3.]
 *  [二、解决方案][Link 2]
 *  [三、原理][Link 3]
 *  [四、总结][Link 4]

**正文**

[回到顶部][Link 5]

## 一、问题复现 ##

### 1.场景 ###

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

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

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

### **2.出错原因** ###

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

### 3.期望 ###

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

[回到顶部][Link 5]

## 二、解决方案 ##

![复制代码][48304ba5e6f9fe08f3fa1abda7d326ab.png]

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

![复制代码][48304ba5e6f9fe08f3fa1abda7d326ab.png]

[回到顶部][Link 5]

## 三、原理 ##

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

源码：

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

![6cefe7ba99eb214e4e1479f61df27348.png][]

TransactionSynchronizationAdapter实现了2个接口：

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

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

[回到顶部][Link 5]

## 四、总结 ##

遇到问题后，很快就想到了处理方式，因为我**提前储备了相关知识**：

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

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

2.@Async实现异步

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

3.threadLocal线程本地变量

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

示例：

@ApiOperation(value = "分派线上餐厅菜单", notes = "分派线上餐厅菜单")
    @OperationLogging(name = "菜单预发布", recordResult = true)
    @GetMapping("/assgin")
    public PcmResult<Map<String, Object>> assginSplit(@RequestParam("id") Long id, @RequestParam("flag") String flag) throws ParseException, SQLException {
        log.info("[菜单预发布] 启动开始 {},{}", id, flag);
        Map<String, Object> result = new HashMap<>(PcmConstants.HUNDRED_CONSTANT);
        TemplateVersion templateVersion = templateVersionService.getTemplateVersion(id);
        if(null !=templateVersion){
            //异步生成菜单
            String isStop = redisUtils.getObject("assignStopId" + "_" + templateVersion.getPosMenuVersion() + "_" + templateVersion.getSequenceNo()) + "";
            if (PcmConstants.FLAG_TRUE.equals(isStop)){
                result.put("code", "3");
                result.put("msg", "当前版本正在中止中，请稍后发布！");
                return new PcmResult<>(result);
            }else{
                String userName = RequestContextProxy.getRequestUsername();
                TemplateVersion templateVersionParam = new TemplateVersion();
                templateVersionParam.setUpdatedUser(userName);
                storeOnlineVersionService.changeStatus(id, EnumTemplateVersionStatus.MAKING.getKey(), templateVersionParam);
                // 注册事务同步处理
                TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronizationAdapter() {
                                                                              @SneakyThrows
                                                                              @Override
                                                                              public void afterCommit() {
                                                                                  // 事务提交完毕时，触发：funcB
                                                                                  storeOnlineMenuService.assignMenuOnlineVersion(id, flag, userName, null);
                                                                              }
                                                                          });
    
    
                log.info("[菜单预发布] 启动结束 {},{}", id, flag);
                result.put("code", "1");
                result.put("msg", "菜单发布成功!");
                return new PcmResult<>(result);
            }
        }else{
            result.put("code", "2");
            result.put("msg", "菜单发布失败,获取不到对应的菜单版本!");
            return new PcmResult<>(result);
        }
    }

[Link 1]: https://www.cnblogs.com/dennyzhangdd/p/11649569.html#_label0
[1.]: https://www.cnblogs.com/dennyzhangdd/p/11649569.html#_label0_0
[2.]: https://www.cnblogs.com/dennyzhangdd/p/11649569.html#_label0_1
[3.]: https://www.cnblogs.com/dennyzhangdd/p/11649569.html#_label0_2
[Link 2]: https://www.cnblogs.com/dennyzhangdd/p/11649569.html#_label1
[Link 3]: https://www.cnblogs.com/dennyzhangdd/p/11649569.html#_label2
[Link 4]: https://www.cnblogs.com/dennyzhangdd/p/11649569.html#_label3
[Link 5]: https://www.cnblogs.com/dennyzhangdd/p/11649569.html#_labelTop
[48304ba5e6f9fe08f3fa1abda7d326ab.png]: /images/20221120/e0ad6fa521b9404180b3eae6d7b193f1.png
[6cefe7ba99eb214e4e1479f61df27348.png]: https://img-blog.csdnimg.cn/img_convert/6cefe7ba99eb214e4e1479f61df27348.png
[72b133a9fbbf667dddebf64c6b1ebe89.png]: https://img-blog.csdnimg.cn/img_convert/72b133a9fbbf667dddebf64c6b1ebe89.png
[spring]: https://www.cnblogs.com/dennyzhangdd/p/9549535.html
[spring _Async]: https://www.cnblogs.com/dennyzhangdd/p/9026303.html
[ThreadLocal_-]: https://www.cnblogs.com/dennyzhangdd/p/7978455.html