@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中执行。
