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

這就出現(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í)行。

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容