欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

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

 更新時(shí)間:2021年11月26日 15:53:37   作者:JavaEdge.  
本文主要介紹了Spring嵌套事務(wù)是怎么回滾的,文中通過(guò)示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下

更深入理解 Spring 事務(wù)。

用戶注冊(cè)完成后,需要給該用戶登記一門(mén)PUA必修課,并更新該門(mén)課的登記用戶數(shù)。
為此,我添加了兩個(gè)表。
課程表 course,記錄課程名稱和注冊(cè)的用戶數(shù)。

用戶選課表 user_course,記錄用戶表 user 和課程表 course 之間的多對(duì)多關(guān)聯(lián)。

同時(shí)為課程表初始化了一條課程信息

接下來(lái)我們完成用戶的相關(guān)操作,主要包括兩部分:

新增用戶選課記錄

課程登記學(xué)生數(shù) + 1

新增業(yè)務(wù)類(lèi) CourseService實(shí)現(xiàn)相關(guān)業(yè)務(wù)邏輯,分別調(diào)用了上述方法保存用戶與課程的關(guān)聯(lián)關(guān)系,并給課程注冊(cè)人數(shù)+1

為避免注冊(cè)課程的業(yè)務(wù)異常導(dǎo)致用戶信息無(wú)法保存,這里 catch 注冊(cè)課程方法中拋出的異常。希望當(dāng)注冊(cè)課程發(fā)生錯(cuò)誤時(shí),只回滾注冊(cè)課程部分,保證用戶信息依然正常。

為驗(yàn)證異常是否符合預(yù)期,在 regCourse() 里拋一個(gè)注冊(cè)失敗異常:

執(zhí)行代碼:

注冊(cè)失敗部分的異常符合預(yù)期,但是后面又多了一個(gè)這樣的錯(cuò)誤提示:Transaction rolled back because it has been marked as rollback-only

最后用戶和選課的信息都被回滾了,顯然這不符預(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)值,如果本來(lái)有事務(wù),則加入該事務(wù),如果沒(méi)有事務(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ì)異常類(lèi)型做了一些檢查,當(dāng)符合聲明中的定義后,執(zhí)行具體的 rollback 操作,這個(gè)操作是通過(guò)如下方法完成:

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)傳播類(lèi)型REQUIRED,嵌套的事務(wù)并未開(kāi)啟一個(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()

所以,就只由該方法來(lái)確定了,默認(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,這里無(wú)需關(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ú)事務(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ù)沒(méi)有保存,但用戶還是正常注冊(cè)成功。這意味著此時(shí)Spring 只對(duì)注冊(cè)課程這部分的數(shù)據(jù)進(jìn)行了回滾,并沒(méi)有傳播到外層:

當(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)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • 關(guān)于springboot整合swagger問(wèn)題及解決方法

    關(guān)于springboot整合swagger問(wèn)題及解決方法

    這篇文章主要介紹了關(guān)于springboot整合swagger問(wèn)題及解決方法,本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
    2021-04-04
  • SSH框架網(wǎng)上商城項(xiàng)目第11戰(zhàn)之查詢和刪除商品功能實(shí)現(xiàn)

    SSH框架網(wǎng)上商城項(xiàng)目第11戰(zhàn)之查詢和刪除商品功能實(shí)現(xiàn)

    這篇文章主要為大家詳細(xì)介紹了SSH框架網(wǎng)上商城項(xiàng)目第11戰(zhàn)之查詢和刪除商品功能實(shí)現(xiàn)的相關(guān)資料,文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2016-06-06
  • idea中打開(kāi)項(xiàng)目時(shí)import project和open區(qū)別詳解

    idea中打開(kāi)項(xiàng)目時(shí)import project和open區(qū)別詳解

    本文主要介紹了idea中打開(kāi)項(xiàng)目時(shí)import project和open區(qū)別詳解,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2023-06-06
  • Java詳細(xì)講解異常Exception的處理

    Java詳細(xì)講解異常Exception的處理

    異常就是不正常,比如當(dāng)我們身體出現(xiàn)了異常我們會(huì)根據(jù)身體情況選擇喝開(kāi)水、吃藥、看病、等?異常處理方法。?java異常處理機(jī)制是我們java語(yǔ)言使用異常處理機(jī)制為程序提供了錯(cuò)誤處理的能力,程序出現(xiàn)的錯(cuò)誤,程序可以安全的退出,以保證程序正常的運(yùn)行等
    2022-06-06
  • Java實(shí)現(xiàn)創(chuàng)建運(yùn)行時(shí)類(lèi)的對(duì)象操作示例

    Java實(shí)現(xiàn)創(chuàng)建運(yùn)行時(shí)類(lèi)的對(duì)象操作示例

    這篇文章主要介紹了Java實(shí)現(xiàn)創(chuàng)建運(yùn)行時(shí)類(lèi)的對(duì)象操作,結(jié)合實(shí)例形式分析了Java動(dòng)態(tài)創(chuàng)建對(duì)象的原理與相關(guān)實(shí)現(xiàn)技巧,需要的朋友可以參考下
    2018-08-08
  • go語(yǔ)言題解LeetCode88合并兩個(gè)有序數(shù)組示例

    go語(yǔ)言題解LeetCode88合并兩個(gè)有序數(shù)組示例

    這篇文章主要為大家介紹了go語(yǔ)言題解LeetCode88合并兩個(gè)有序數(shù)組示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2022-12-12
  • Java 類(lèi)與對(duì)象超基礎(chǔ)講解

    Java 類(lèi)與對(duì)象超基礎(chǔ)講解

    類(lèi)(class)和對(duì)象(object)是兩種以計(jì)算機(jī)為載體的計(jì)算機(jī)語(yǔ)言的合稱。對(duì)象是對(duì)客觀事物的抽象,類(lèi)是對(duì)對(duì)象的抽象。類(lèi)是一種抽象的數(shù)據(jù)類(lèi)型
    2022-03-03
  • SpringBoot整合Milvus的實(shí)現(xiàn)

    SpringBoot整合Milvus的實(shí)現(xiàn)

    本文主要介紹了SpringBoot整合Milvus的實(shí)現(xiàn),文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2023-07-07
  • Java爬蟲(chóng)實(shí)戰(zhàn)抓取一個(gè)網(wǎng)站上的全部鏈接

    Java爬蟲(chóng)實(shí)戰(zhàn)抓取一個(gè)網(wǎng)站上的全部鏈接

    這篇文章主要介紹了JAVA使用爬蟲(chóng)抓取網(wǎng)站網(wǎng)頁(yè)內(nèi)容的方法,現(xiàn)在就分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧。
    2016-10-10
  • 淺析java 循序與二元搜索算法

    淺析java 循序與二元搜索算法

    這篇文章主要簡(jiǎn)單介紹了java 循序與二元搜索算法,需要的朋友可以參考下
    2015-02-02

最新評(píng)論