Java事务处理器

@Service
public class CheckItemService {

@Transactional
public void A( ) throws Exception { 
  String currentTransactionName = TransactionSynchronizationManager.getCurrentTransactionName();
        log.error("C currentTransactionName is {}",currentTransactionName);
        TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronizationAdapter() {
                @Override
                public void afterCommit() {
                    try {
 
                        asyncService.B(orgSections, result, latch);
                      
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }
            });
}
}

@Component
public class AsyncService {

@Async("taskExecutor")
@Transactional()
public Boolean B( ) {
  String currentTransactionName = TransactionSynchronizationManager.getCurrentTransactionName();
        log.error("C currentTransactionName is {}",currentTransactionName);
}
}

场景1：
B方法添加了异步和事务注解@Async("taskExecutor")@Transactional()

[ ] 22-03-11 09:56:05.526 ERROR 42276 [XNIO-2 task-4] c.f.f.A       : c currentTransactionName  is cn.flydiy.xxx.A
[ ] 22-03-11 09:56:05.772 ERROR 42276 [FlyAsync-2] c.f.f.B        : C currentTransactionName is cn.flydiy.xxx.B

场景2：
B方法只添加事务注解@Transactional()

[ ] 22-03-11 10:18:44.089 ERROR 28736 [XNIO-2 task-10] c.f.f.o.check.resource.CheckItemResource.A              : c currentTransactionName  is cn.flydiy.xxx.A
[ ] 22-03-11 10:18:44.322 ERROR 28736 [XNIO-2 task-10] c.f.f.o.check.service.SyncService.B                     : C currentTransactionName is cn.flydiy.xxx.A

这就出现问题了，方法A和方法B两个的事务都是事务A，所以方法B里面的事务将不会被执行。

场景3：
B方法只添加事务注解@Async("taskExecutor")

[ ] 22-03-11 10:34:15.671 ERROR 24760 [XNIO-2 task-8] c.f.f.o.check.resource.CheckItemResource.A              :  C currentTransactionName  is cn.flydiy.flyauto.organtalenteview.check.resource.CheckItemResource.A
[ ] 22-03-11 10:34:15.945 ERROR 24760 [FlyAsync-1] c.f.f.o.check.service.SyncService.B                     : C currentTransactionName is null

可以看到方法B现在是没有事务管理了。所以方法B中是不会出现回滚的。

场景4：
B方法添加注解异步和传播范围是REQUIRES_NEW的事务注解
@Async("taskExecutor") @Transactional(propagation = Propagation.REQUIRES_NEW)

[ ] 22-03-11 10:52:34.296 ERROR 39404 [XNIO-2 task-5] c.f.f.o.check.resource.CheckItemResource.A              : C currentTransactionName  is cn.flydiy.flyauto.organtalenteview.check.resource.CheckItemResource.A
[ ] 22-03-11 10:52:34.538 ERROR 39404 [FlyAsync-2] c.f.f.o.check.service.SyncService.B                     : C currentTransactionName is cn.flydiy.flyauto.organtalenteview.check.service.AsyncService.B

场景5：
方法B不在afterCommit方法中执行，但还是添加了异步的注解

[ ] 22-03-11 11:26:38.068  INFO 17672 [FlyAsync-1] c.f.f.o.check.service.SyncService.B                     : currentTransactionName is null

可以看到是没有事务处理器的

场景6：
方法B不在afterCommit方法中执行，也没有加异步的注解

[ ] 22-03-11 11:35:36.850 ERROR 38160 [XNIO-2 task-8] c.f.f.o.check.service.SyncService.ExecRealTimeSy        : currentTransactionName is cn.flydiy.flyauto.organtalenteview.check.resource.CheckItemResource.launchCheck

预料之内，是会延续调用方法的事务处理器的。

总结：
1.如果只加异步，将没有事务管理器；
2.建议还是在需要异步的情况下，把@Async("taskExecutor") @Transactional(propagation = Propagation.REQUIRES_NEW)都加上
3.在不用到异步的情况下，没必要重新开启事务管理器，或者没必要放在aftercommit中执行。