快捷導(dǎo)航

淺談Spring嵌套事務(wù)是怎么回滾的

更新時(shí)間：2021年11月26日 15:53:37 作者：JavaEdge.

本文主要介紹了Spring嵌套事務(wù)是怎么回滾的，文中通過示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

最后用戶和選課的信息都被回滾了，顯然這不符預(yù)期。
期待結(jié)果是即便內(nèi)部事務(wù)regCourse()發(fā)生異常，外部事務(wù)saveStudent()俘獲該異常后，內(nèi)部事務(wù)應(yīng)自行回滾，不影響外部事務(wù)。
這是什么原因造成的呢？

源碼解析

偽代碼梳理整個(gè)事務(wù)的結(jié)構(gòu)：

整個(gè)業(yè)務(wù)包含2層事務(wù)：

外層 saveUser() 的事務(wù)
內(nèi)層 regCourse() 事務(wù)

Spring聲明式事務(wù)中的propagation屬性，表示對(duì)這些方法使用怎樣的事務(wù)，即：
一個(gè)帶事務(wù)的方法調(diào)用了另一個(gè)帶事務(wù)的方法，被調(diào)用的方法它怎么處理自己事務(wù)和調(diào)用方法事務(wù)之間的關(guān)系。

propagation 有7種配置：

REQUIRED：默認(rèn)值，如果本來有事務(wù)，則加入該事務(wù)，如果沒有事務(wù)，則創(chuàng)建新的事務(wù)。
SUPPORTS
MANDATORY
REQUIRES_NEW
NOT_SUPPORTED
NEVER
NESTED

因?yàn)椋?/p>

在 saveUser() 上聲明了一個(gè)外部的事務(wù)，就已經(jīng)存在一個(gè)事務(wù)了
在propagation值為默認(rèn)REQUIRED時(shí)

regCourse() 就會(huì)加入到已有的事務(wù)中，兩個(gè)方法共用一個(gè)事務(wù)。

Spring 事務(wù)處理的核心：

TransactionAspectSupport.invokeWithinTransaction()

protected Object invokeWithinTransaction(Method method, @Nullable Class<?> targetClass,
      final InvocationCallback invocation) throws Throwable {
 
   TransactionAttributeSource tas = getTransactionAttributeSource();
   final TransactionAttribute txAttr = (tas != null ? tas.getTransactionAttribute(method, targetClass) : null);
   final PlatformTransactionManager tm = determineTransactionManager(txAttr);
   final String joinpointIdentification = methodIdentification(method, targetClass, txAttr);
   if (txAttr == null || !(tm instanceof CallbackPreferringPlatformTransactionManager)) {
      // 是否需要?jiǎng)?chuàng)建一個(gè)事務(wù)
      TransactionInfo txInfo = createTransactionIfNecessary(tm, txAttr, joinpointIdentification);
      Object retVal = null;
      try {
         // 調(diào)用具體的業(yè)務(wù)方法
         retVal = invocation.proceedWithInvocation();
      }
      catch (Throwable ex) {
         // 當(dāng)發(fā)生異常時(shí)進(jìn)行處理
         completeTransactionAfterThrowing(txInfo, ex);
         throw ex;
      }
      finally {
         cleanupTransactionInfo(txInfo);
      }
      // 正常返回時(shí)提交事務(wù)
      commitTransactionAfterReturning(txInfo);
      return retVal;
   }
   //......省略非關(guān)鍵代碼.....
}

整個(gè)方法完成了事務(wù)的一整套處理邏輯，如下：

檢查是否需要?jiǎng)?chuàng)建事務(wù)
調(diào)用具體的業(yè)務(wù)方法進(jìn)行處理
提交事務(wù)
處理異常

當(dāng)前案例是兩個(gè)事務(wù)嵌套，外層事務(wù) saveUser()和內(nèi)層事務(wù) regCourse()，每個(gè)事務(wù)都會(huì)調(diào)用到這個(gè)方法。所以，該方法會(huì)被調(diào)兩次。

內(nèi)層事務(wù)

當(dāng)捕獲了異常，會(huì)調(diào)用

TransactionAspectSupport.completeTransactionAfterThrowing()

進(jìn)行異常處理：

對(duì)異常類型做了一些檢查，當(dāng)符合聲明中的定義后，執(zhí)行具體的 rollback 操作，這個(gè)操作是通過如下方法完成：

AbstractPlatformTransactionManager rollback()

該回滾實(shí)現(xiàn)負(fù)責(zé)處理正參與到已有事務(wù)集的事務(wù)。委托執(zhí)行Rollback和doSetRollbackOnly。

繼續(xù)調(diào)用

processRollback()

該方法里區(qū)分了三種場(chǎng)景：

是否有保存點(diǎn)
是否為一個(gè)新的事務(wù)
是否處于一個(gè)更大的事務(wù)中

因?yàn)槟J(rèn)傳播類型REQUIRED，嵌套的事務(wù)并未開啟一個(gè)新事務(wù)，所以屬于當(dāng)前事務(wù)處于一個(gè)更大事務(wù)中，所以會(huì)走到分支1。

如下的判斷條件確定是否設(shè)置為僅回滾：

if (status.isLocalRollbackOnly() ||
	 isGlobalRollbackOnParticipationFailure())

滿足任一，都會(huì)執(zhí)行 doSetRollbackOnly()：

isLocalRollbackOnly

默認(rèn) false，當(dāng)前場(chǎng)景為 falseisGlobalRollbackOnParticipationFailure()

所以，就只由該方法來確定了，默認(rèn)值為 true，即是否回滾交由外層事務(wù)統(tǒng)一決定

條件得到滿足，執(zhí)行

DataSourceTransactionManager#doSetRollbackOnly

最終調(diào)用

DataSourceTransactionObject#setRollbackOnly()

內(nèi)層事務(wù)操作執(zhí)行完畢。

外層事務(wù)

外層事務(wù)中，業(yè)務(wù)代碼就捕獲了內(nèi)層所拋異常，所以該異常不會(huì)繼續(xù)往上拋，最后的事務(wù)會(huì)在 TransactionAspectSupport.invokeWithinTransaction() 中的

TransactionAspectSupport#commitTransactionAfterReturning()

該方法里執(zhí)行了commit 操作：

AbstractPlatformTransactionManager#commit

當(dāng)滿足 !shouldCommitOnGlobalRollbackOnly() &&defStatus.isGlobalRollbackOnly()，就會(huì)回滾，否則繼續(xù)提交事務(wù)：

shouldCommitOnGlobalRollbackOnly()
若發(fā)現(xiàn)事務(wù)被標(biāo)記了全局回滾，且在發(fā)生全局回滾時(shí)，判斷是否應(yīng)該提交事務(wù)，這個(gè)方法的默認(rèn)返回 false，這里無需關(guān)注

isGlobalRollbackOnly()

該方法最終進(jìn)入

DataSourceTransactionObject#isRollbackOnly()

之前內(nèi)部事務(wù)處理最終調(diào)用到DataSourceTransactionObject#setRollbackOnly()

public void setRollbackOnly() {
   getConnectionHolder().setRollbackOnly();
}

isRollbackOnly()
setRollbackOnly()

兩個(gè)方法本質(zhì)都是對(duì)ConnectionHolder.rollbackOnly屬性標(biāo)志位的存取
但ConnectionHolder則存在于DefaultTransactionStatus#transaction屬性。

綜上：外層事務(wù)是否回滾的關(guān)鍵，最終取決于DataSourceTransactionObject#isRollbackOnly()，該方法返回值正是在內(nèi)層異常時(shí)設(shè)置的。
所以最終外層事務(wù)也被回滾，從而在控制臺(tái)中打印上述日志。

這就明白了，Spring默認(rèn)事務(wù)傳播屬性為REQUIRED：若已有事務(wù)，則加入該事務(wù)，若無事務(wù)，則創(chuàng)建新事務(wù)，因而內(nèi)外兩層事務(wù)都處于同一事務(wù)。
在 regCourse()中拋異常，并觸發(fā)回滾操作時(shí)，這個(gè)回滾會(huì)繼續(xù)傳播，從而把 saveUser() 也回滾，最終整個(gè)事務(wù)都被回滾！

修正

Spring事務(wù)默認(rèn)傳播屬性 REQUIRED，在整個(gè)事務(wù)的調(diào)用鏈上，任一環(huán)節(jié)拋異常都會(huì)導(dǎo)致全局回滾。

所以只需將傳播屬性改成 REQUIRES_NEW ：

運(yùn)行：

異常正常拋出，注冊(cè)課程部分的數(shù)據(jù)沒有保存，但用戶還是正常注冊(cè)成功。這意味著此時(shí)Spring 只對(duì)注冊(cè)課程這部分的數(shù)據(jù)進(jìn)行了回滾，并沒有傳播到外層：

當(dāng)子事務(wù)聲明為 Propagation.REQUIRES_NEW 時(shí)，在 TransactionAspectSupport.invokeWithinTransaction() 中調(diào)用 createTransactionIfNecessary() 就會(huì)創(chuàng)建一個(gè)新的事務(wù)，獨(dú)立于外層事務(wù)而在 AbstractPlatformTransactionManager.processRollback() 進(jìn)行 rollback 處理時(shí)，因?yàn)?status.isNewTransaction() 會(huì)因?yàn)樗幱谝粋€(gè)新的事務(wù)中而返回 true，所以它走入到了另一個(gè)分支，執(zhí)行了 doRollback() 操作，讓這個(gè)子事務(wù)單獨(dú)回滾，不會(huì)影響到主事務(wù)。

到此這篇關(guān)于淺談Spring嵌套事務(wù)是怎么回滾的的文章就介紹到這了,更多相關(guān)Spring嵌套事務(wù)回滾內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: