事務回滾
回滾邏輯如下:
- 判斷是否存在事務，只有存在事務才執行回滾
- 根據異常類型判斷是否回滾。如果異常類型不符合，仍然會提交事務
- 回滾處理
詳細解析
- 判斷是否存在事務，只有存在事務才執行回滾，即是否有@Transactional事務注解或相關事務切面
- 根據異常類型判斷是否回滾。如果異常類型不符合，仍然會提交事務
根據@Transactional注解中rollbackFor、rollbackForClassName、noRollbackForClassName配置的值，找到最符合ex的異常類型，如果符合的異常類型不是NoRollbackRuleAttribute，則可以執行回滾。
如果@Transactional沒有配置，則默認使用RuntimeException和Error異常。
代碼如下：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
|
@Overridepublic 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沒有配置，默認調用父類的 if (winner == null) { logger.trace("No relevant rollback rule found: applying default rules"); return super.rollbackOn(ex); } return !(winner instanceof NoRollbackRuleAttribute);}//super@Overridepublic boolean rollbackOn(Throwable ex) { return (ex instanceof RuntimeException || ex instanceof Error);} |
回滾處理
- 如果存在安全點，則回滾事務至安全點，這個主要是處理嵌套事務，回滾安全點的操作還是交給了數據庫處理.
- 當前事務是一個新事務時，那么直接回滾，使用的是DataSourceTransactionManager事務管理器，所以調用DataSourceTransactionManager#doRollback,直接調用數據庫連接的回滾方法。
- 當前存在事務，但又不是一個新的事務，只把事務的狀態標記為read-only，等到事務鏈執行完畢后，統一回滾,調用DataSourceTransactionManager#doSetRollbackOnly
- 清空記錄的資源并將掛起的資源恢復
代碼如下：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
|
private void processRollback(DefaultTransactionStatus status) { try { try { triggerBeforeCompletion(status); //如果有安全點，回滾至安全點 if (status.hasSavepoint()) { if (status.isDebug()) { logger.debug("Rolling back transaction to savepoint"); } status.rollbackToHeldSavepoint(); } //如果是新事務，回滾事務 else if (status.isNewTransaction()) { if (status.isDebug()) { logger.debug("Initiating transaction rollback"); } doRollback(status); } //如果有事務但不是新事務，則把標記事務狀態，等事務鏈執行完畢后統一回滾 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 { //清空記錄的資源并將掛起的資源恢復 cleanupAfterCompletion(status); }} |
事務提交
事務提交邏輯如下：
- 判斷事務是否已經完成，如果完成拋出異常
- 判斷事務是否已經被標記成回滾，則執行回滾操作
- 嵌入事務標記回滾，如果嵌入事務拋出了異常執行了回滾，但是在調用方把嵌入事務的異常個捕獲沒有拋出，就會執行這一步。
- 提交事務
代碼如下：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
|
@Overridepublic final void commit(TransactionStatus status) throws TransactionException { //1. 判斷事務是不是已經完成 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. 如果在事務鏈中已經被標記回滾，那么不會嘗試提交事務，直接回滾，不過我沒找到在哪設置這個值 if (defStatus.isLocalRollbackOnly()) { if (defStatus.isDebug()) { logger.debug("Transactional code has requested rollback"); } processRollback(defStatus); return; } //3. shouldCommitOnGlobalRollbackOnly()默認返回false，isGlobalRollbackOnly是在嵌入事務回滾的時候賦值的 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. 提交事務 processCommit(defStatus);} |
以上就是詳解Spring事務回滾和事務提交的詳細內容，更多關于Spring事務回滾和事務提交的資料請關注服務器之家其它相關文章！
原文鏈接：https://segmentfault.com/a/1190000039355614
