詳解Spring事務(wù)回滾和事務(wù)提交
事務(wù)回滾
回滾邏輯如下:
- 判斷是否存在事務(wù),只有存在事務(wù)才執(zhí)行回滾
- 根據(jù)異常類(lèi)型判斷是否回滾。如果異常類(lèi)型不符合,仍然會(huì)提交事務(wù)
- 回滾處理
詳細(xì)解析
- 判斷是否存在事務(wù),只有存在事務(wù)才執(zhí)行回滾,即是否有@Transactional事務(wù)注解或相關(guān)事務(wù)切面
- 根據(jù)異常類(lèi)型判斷是否回滾。如果異常類(lèi)型不符合,仍然會(huì)提交事務(wù)
根據(jù)@Transactional注解中rollbackFor、rollbackForClassName、noRollbackForClassName配置的值,找到最符合ex的異常類(lèi)型,如果符合的異常類(lèi)型不是NoRollbackRuleAttribute,則可以執(zhí)行回滾。
如果@Transactional沒(méi)有配置,則默認(rèn)使用RuntimeException和Error異常。
代碼如下:
@Override public boolean rollbackOn(Throwable ex) { if (logger.isTraceEnabled()) { logger.trace("Applying rules to determine whether transaction should rollback on " + ex); } RollbackRuleAttribute winner = null; int deepest = Integer.MAX_VALUE; //rollbackRules保存@Transactional注解中rollbackFor、rollbackForClassName、noRollbackForClassName配置的值 if (this.rollbackRules != null) { for (RollbackRuleAttribute rule : this.rollbackRules) { int depth = rule.getDepth(ex); if (depth >= 0 && depth < deepest) { deepest = depth; winner = rule; } } } if (logger.isTraceEnabled()) { logger.trace("Winning rollback rule is: " + winner); } // User superclass behavior (rollback on unchecked) if no rule matches. //若@Transactional沒(méi)有配置,默認(rèn)調(diào)用父類(lèi)的 if (winner == null) { logger.trace("No relevant rollback rule found: applying default rules"); return super.rollbackOn(ex); } return !(winner instanceof NoRollbackRuleAttribute); } //super @Override public boolean rollbackOn(Throwable ex) { return (ex instanceof RuntimeException || ex instanceof Error); }
回滾處理
- 如果存在安全點(diǎn),則回滾事務(wù)至安全點(diǎn),這個(gè)主要是處理嵌套事務(wù),回滾安全點(diǎn)的操作還是交給了數(shù)據(jù)庫(kù)處理.
- 當(dāng)前事務(wù)是一個(gè)新事務(wù)時(shí),那么直接回滾,使用的是DataSourceTransactionManager事務(wù)管理器,所以調(diào)用DataSourceTransactionManager#doRollback,直接調(diào)用數(shù)據(jù)庫(kù)連接的回滾方法。
- 當(dāng)前存在事務(wù),但又不是一個(gè)新的事務(wù),只把事務(wù)的狀態(tài)標(biāo)記為read-only,等到事務(wù)鏈執(zhí)行完畢后,統(tǒng)一回滾,調(diào)用DataSourceTransactionManager#doSetRollbackOnly
- 清空記錄的資源并將掛起的資源恢復(fù)
代碼如下:
private void processRollback(DefaultTransactionStatus status) { try { try { triggerBeforeCompletion(status); //如果有安全點(diǎn),回滾至安全點(diǎn) if (status.hasSavepoint()) { if (status.isDebug()) { logger.debug("Rolling back transaction to savepoint"); } status.rollbackToHeldSavepoint(); } //如果是新事務(wù),回滾事務(wù) else if (status.isNewTransaction()) { if (status.isDebug()) { logger.debug("Initiating transaction rollback"); } doRollback(status); } //如果有事務(wù)但不是新事務(wù),則把標(biāo)記事務(wù)狀態(tài),等事務(wù)鏈執(zhí)行完畢后統(tǒng)一回滾 else if (status.hasTransaction()) { if (status.isLocalRollbackOnly() || isGlobalRollbackOnParticipationFailure()) { if (status.isDebug()) { logger.debug("Participating transaction failed - marking existing transaction as rollback-only"); } doSetRollbackOnly(status); } else { if (status.isDebug()) { logger.debug("Participating transaction failed - letting transaction originator decide on rollback"); } } } else { logger.debug("Should roll back transaction but cannot - no transaction available"); } } catch (RuntimeException ex) { triggerAfterCompletion(status, TransactionSynchronization.STATUS_UNKNOWN); throw ex; } catch (Error err) { triggerAfterCompletion(status, TransactionSynchronization.STATUS_UNKNOWN); throw err; } triggerAfterCompletion(status, TransactionSynchronization.STATUS_ROLLED_BACK); } finally { //清空記錄的資源并將掛起的資源恢復(fù) cleanupAfterCompletion(status); } }
事務(wù)提交
事務(wù)提交邏輯如下:
- 判斷事務(wù)是否已經(jīng)完成,如果完成拋出異常
- 判斷事務(wù)是否已經(jīng)被標(biāo)記成回滾,則執(zhí)行回滾操作
- 嵌入事務(wù)標(biāo)記回滾,如果嵌入事務(wù)拋出了異常執(zhí)行了回滾,但是在調(diào)用方把嵌入事務(wù)的異常個(gè)捕獲沒(méi)有拋出,就會(huì)執(zhí)行這一步。
- 提交事務(wù)
代碼如下:
@Override public final void commit(TransactionStatus status) throws TransactionException { //1. 判斷事務(wù)是不是已經(jīng)完成 if (status.isCompleted()) { throw new IllegalTransactionStateException( "Transaction is already completed - do not call commit or rollback more than once per transaction"); } DefaultTransactionStatus defStatus = (DefaultTransactionStatus) status; //2. 如果在事務(wù)鏈中已經(jīng)被標(biāo)記回滾,那么不會(huì)嘗試提交事務(wù),直接回滾,不過(guò)我沒(méi)找到在哪設(shè)置這個(gè)值 if (defStatus.isLocalRollbackOnly()) { if (defStatus.isDebug()) { logger.debug("Transactional code has requested rollback"); } processRollback(defStatus); return; } //3. shouldCommitOnGlobalRollbackOnly()默認(rèn)返回false,isGlobalRollbackOnly是在嵌入事務(wù)回滾的時(shí)候賦值的 if (!shouldCommitOnGlobalRollbackOnly() && defStatus.isGlobalRollbackOnly()) { if (defStatus.isDebug()) { logger.debug("Global transaction is marked as rollback-only but transactional code requested commit"); } processRollback(defStatus); // Throw UnexpectedRollbackException only at outermost transaction boundary // or if explicitly asked to. if (status.isNewTransaction() || isFailEarlyOnGlobalRollbackOnly()) { throw new UnexpectedRollbackException( "Transaction rolled back because it has been marked as rollback-only"); } return; } //4. 提交事務(wù) processCommit(defStatus); }
以上就是詳解Spring事務(wù)回滾和事務(wù)提交的詳細(xì)內(nèi)容,更多關(guān)于Spring事務(wù)回滾和事務(wù)提交的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章!
- Spring事務(wù)執(zhí)行流程及如何創(chuàng)建事務(wù)
- Spring事務(wù)的開(kāi)啟原理詳解
- SpringBoot2整合JTA組件實(shí)現(xiàn)多數(shù)據(jù)源事務(wù)管理
- 深入理解spring事務(wù)
- 五分鐘教你手寫(xiě) SpringBoot 本地事務(wù)管理實(shí)現(xiàn)
- springBoot service層事務(wù)控制的操作
- spring事務(wù)隔離級(jí)別、傳播機(jī)制以及簡(jiǎn)單配置方式
- Spring Boot事務(wù)配置詳解
- Springcloud seata分布式事務(wù)實(shí)現(xiàn)代碼解析
- Spring事務(wù)失效場(chǎng)景原理及解決方案
相關(guān)文章
JVM內(nèi)存結(jié)構(gòu)劃分實(shí)例解析
這篇文章主要介紹了JVM內(nèi)存結(jié)構(gòu)劃分實(shí)例解析,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-12-12SpringBoot實(shí)現(xiàn)發(fā)送郵件功能過(guò)程圖解
這篇文章主要介紹了SpringBoot實(shí)現(xiàn)發(fā)送郵件功能過(guò)程圖解,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-03-03Java編程實(shí)現(xiàn)獲取mp3時(shí)長(zhǎng)及播放mp3文件的方法
這篇文章主要介紹了Java編程實(shí)現(xiàn)獲取mp3時(shí)長(zhǎng)及播放mp3文件的方法,涉及java基于jaudiotagger與jl包對(duì)MP3音頻文件屬性操作及音頻播放相關(guān)操作技巧,并提供了相關(guān)jar包的本站下載,需要的朋友可以參考下2018-02-02詳解Java中List接口底層實(shí)現(xiàn)原理
Java是一種廣泛應(yīng)用的編程語(yǔ)言,被廣泛應(yīng)用于各種平臺(tái)和應(yīng)用領(lǐng)域,List接口是Java中最重要的數(shù)據(jù)結(jié)構(gòu)之一,它為我們提供了一種靈活、高效、可擴(kuò)展的數(shù)據(jù)結(jié)構(gòu),本篇文章將首先介紹Java中List接口的基本特性和使用方法,然后深入研究List接口的底層實(shí)現(xiàn)原理2023-11-11IntelliJ IDEA 創(chuàng)建spring boot 的Hello World 項(xiàng)目(圖解)
這篇文章主要介紹了IntelliJ IDEA 創(chuàng)建spring boot 的Hello World 項(xiàng)目的步驟詳解,需要的朋友可以參考下2018-01-01Java線程使用同步鎖交替執(zhí)行打印奇數(shù)偶數(shù)的方法
這篇文章主要介紹了Java線程使用同步鎖交替執(zhí)行打印奇數(shù)偶數(shù)的方法。小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2019-01-01詳解使用IntelliJ IDEA新建Java Web后端resfulAPI模板
這篇文章主要介紹了詳解使用IntelliJ IDEA新建Java Web后端resfulAPI模板,小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2018-08-08springboot集成ftp實(shí)現(xiàn)文件上傳
這篇文章主要為大家詳細(xì)介紹了springboot集成ftp實(shí)現(xiàn)文件上傳,文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2021-05-05