@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
這就出現(xiàn)問題了,方法A和方法B兩個的事務都是事務A,所以方法B里面的事務將不會被執(zhí)行。
場景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現(xiàn)在是沒有事務管理了。所以方法B中是不會出現(xiàn)回滾的。
場景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方法中執(zhí)行,但還是添加了異步的注解
[ ] 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方法中執(zhí)行,也沒有加異步的注解
[ ] 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
預料之內(nèi),是會延續(xù)調(diào)用方法的事務處理器的。
總結(jié):
1.如果只加異步,將沒有事務管理器;
2.建議還是在需要異步的情況下,把@Async("taskExecutor") @Transactional(propagation = Propagation.REQUIRES_NEW)都加上
3.在不用到異步的情況下,沒必要重新開啟事務管理器,或者沒必要放在aftercommit中執(zhí)行。