詳解Spring事務(wù)回滾和事務(wù)提交
事務(wù)回滾
回滾邏輯如下:
- 判斷是否存在事務(wù),只有存在事務(wù)才執(zhí)行回滾
- 根據(jù)異常類型判斷是否回滾。如果異常類型不符合,仍然會(huì)提交事務(wù)
- 回滾處理
詳細(xì)解析
- 判斷是否存在事務(wù),只有存在事務(wù)才執(zhí)行回滾,即是否有@Transactional事務(wù)注解或相關(guān)事務(wù)切面
- 根據(jù)異常類型判斷是否回滾。如果異常類型不符合,仍然會(huì)提交事務(wù)
根據(jù)@Transactional注解中rollbackFor、rollbackForClassName、noRollbackForClassName配置的值,找到最符合ex的異常類型,如果符合的異常類型不是NoRollbackRuleAttribute,則可以執(zhí)行回滾。
如果@Transactional沒有配置,則默認(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沒有配置,默認(rèn)調(diào)用父類的
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ù)庫處理.
- 當(dāng)前事務(wù)是一個(gè)新事務(wù)時(shí),那么直接回滾,使用的是DataSourceTransactionManager事務(wù)管理器,所以調(diào)用DataSourceTransactionManager#doRollback,直接調(diào)用數(shù)據(jù)庫連接的回滾方法。
- 當(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è)捕獲沒有拋出,就會(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ù),直接回滾,不過我沒找到在哪設(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)文章!
相關(guān)文章
Applet小應(yīng)用程序開發(fā)簡(jiǎn)介
Applet小應(yīng)用程序開發(fā)簡(jiǎn)介 ,用java開發(fā)的小程序,需要的朋友可以參考下2012-09-09
freemarker簡(jiǎn)介_動(dòng)力節(jié)點(diǎn)Java學(xué)院整理
FreeMarker是一個(gè)模板引擎,一個(gè)基于模板生成文本輸出的通用工具,使用純Java編寫,有興趣的可以了解一下2017-08-08
MyBatis Plus 將查詢結(jié)果封裝到指定實(shí)體的方法步驟
這篇文章主要介紹了MyBatis Plus 將查詢結(jié)果封裝到指定實(shí)體的方法步驟,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-09-09
三分鐘帶你了解SpringBoot真正的啟動(dòng)引導(dǎo)類
這篇文章主要介紹了三分鐘帶你了解SpringBoot真正的啟動(dòng)引導(dǎo)類,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-11-11
基于jni調(diào)用時(shí),jvm報(bào)錯(cuò)問題的深入分析
本篇文章是對(duì)jni調(diào)用時(shí),jvm的報(bào)錯(cuò)問題進(jìn)行了詳細(xì)的分析介紹,需要的朋友參考下2013-05-05

