spring事务操作后进行异步操作

开发中有很多需要事务 A 操作后进行异步 B 操作, 如发送 mq, 或者开线程做其他事情. 有一部分的异步操作需要查询当前事务方法的保存 / 修改数据. 所以, 如果直接在事务方法中调用异步方法的话, 如果异步方法的逻辑查询对应的数据库记录时, 还没有刷到数据库, 那就会获取不到最新值

解决方法

方案一: 调用异步的方法不要写在 A 操作的方法中, 如下伪代码

@RequestMapping("doWork")
@ResponseBody
public String doWork(){
    doWorkA();//事务操作
    doWorkB(); //异步操作 
}

但是这样并不友好, 因为逻辑上这两个操作应该是一起的, 以后维护的程序猿可能不知道这个.

方案二: 使用spring的 TransactionSynchronizationManager 来保证在当前事务提交成功后执行异步操作

@Transactional
public String doWorkA(){
    saveOrUpdate();//业务逻辑
    TransactionSynchronizationManager.registerSynchronization(new      TransactionSynchronizationAdapter() {
                @Override
                public void afterCommit() {
                    doWorkB();//异步操作
                }
            });
}

另外注意的是, 如果前面的业务逻辑发送错误导致回滚, 不会执行 afterCommit 内的方法。

‍