Java 开发

@Transactional 事务提交之后执行 @Async 修饰的方法

言七墨 · 1月9日 · 2020年 · · 6355次已读

需求

一个 @Transactional 修饰的方法A 的内部要调用另一个用 @Async 修饰的方法B,并且方法B 要在方法A 的事务提交之后,异步执行,大致如下:

@Transactional
public void updateA(..) {
    batchInsert(..);
    update(..);
    updateB(..);
}

@Async
public void updateB(..) {
    update(..)
}

分析

  • 方法A 和 方法B 假如在同一个类中七墨博客,则方法B 的 @Async 注解会失效:

首先解释下 @Transactional 注解失效的原因:Sprinhttps://qimok.cng 在扫描 bean 的时候会扫描方法上是否包含 @Transactional 注解,如果包含,Spring 会为这个 bean 动态地生成一个子类(即代理类 proxy),代理类是继承原来那个 bean 的。此时,当这个有注解的方法被调用的时候,实际上是由代理类来调用的,代理类在调用之前就会启动 Transaction。然而,如果这个有注解的方法是被同一个类中的其他方法调用的,那么该方法的调用并没有通过代理类,而是直接通过原来的那个bean,所以就不会启动 https://qimok.cnTransaction,我们看到的现象就是 @Transactional 注解无效。

因为 @Transactional 和 @Async 注解的实现都是基于 Spring 的 AOP ,而 AOP 的实现是基于动态代理实现的,故 @Async 失效的原理和 @Transactional 原理是一样的。(排除配置错误导致失效的原因)

常用的解决办法是将调用方法和被调用方法(@七墨博客Transactional 或 @Async 修饰的方法)放到两个类中,保证通过代理类去调用被 @Transact七墨博客ional 或 @Async 修饰的方法。

  • 如何保证方法A 的内部方法 batchInsert(..) 和 update(..) 事务提交之后再异步执行方法B?

通过以下代码实现:

TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronizationAdapter() {
3 @Override
4 public void afterCommit() {
5     // 事务提交完毕时,触发:方法B
6     updateB(..);
7 }

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

解决

最终实现:

class A {

    @Autowired
    private B b;
    
    @Transactional
    public void updateA(..) {
        batchInsert(..);
        update(..);
        TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronizationAdapter() {
            @Override
            public void afterCommit() {
                b.updateB(..);
            }
        });
    }

}
    
class B {

    @Async
    public void updateB(..) {
        update(..)
    }

}
0 条回应