【Spring】事務實現原理

来源:https://www.cnblogs.com/shanml/archive/2023/11/09/17762215.html
-Advertisement-
Play Games

在使用事務的時候需要添加@EnableTransactionManagement註解來開啟事務,Spring事務底層是通過AOP來實現的,所以啟用事務後,同樣會向容器中註入一個代理對象創建器,AOP使用的是AnnotationAwareAspectJAutoProxyCreator,事務使用的是In ...


在使用事務的時候需要添加@EnableTransactionManagement註解來開啟事務,Spring事務底層是通過AOP來實現的,所以啟用事務後,同樣會向容器中註入一個代理對象創建器,AOP使用的是AnnotationAwareAspectJAutoProxyCreator,事務使用的是InfrastructureAdvisorAutoProxyCreator。

  • Advice通知:定義在切點上需要執行什麼樣的操作;

  • PointCut切點:定義在哪些方法上使用通知;

  • Advisor:Advice和Pointcut加起來組成了Advisor,可以看做是對切麵的封裝;

在使用AOP時,一般會創建一個切麵,裡面包含了切點和通知,事務既然基於AOP實現,所以也會有對應的通知和切點。

事務Advisor

開啟事務時,還會向Spring容器中註冊一個BeanFactoryTransactionAttributeSourceAdvisor,從名字上可以看出它是一個Advisor,它重點有以下幾個類型的成員變數:

  • Advice(通知):傳入的實際類型為TransactionInterceptor,它是事務攔截器,實現了Advice介面,這個攔截器就相當於AOP中的通知,在執行目標方法前會進行攔截,進行事務處理;

  • TransactionAttributeSourcePointcut(切點):它實現了Pointcut和MethodMatcher介面,是一個切點,目標方法是否需要被事務代理就是通過它判斷的;

  • TransactionAttributeSource:傳入的實際類型為AnnotationTransactionAttributeSource,用於解析事務屬性相關配置信息;

Advisor由Advice和Pointcut組成,現在Advice和Pointcut都已經知道了,接下來就去看看是如何判斷當前Bean是否需要進行事務代理的。

事務底層是通過AOP實現的,所以它的處理邏輯與AOP類似,啟動時會註冊一個後置處理器,在postProcessAfterInitialization方法中判斷是否需要進行代理,邏輯與AOP一致,會獲取所有的Advisor,判斷是否有匹配當前Bean的Advisor,Spring會自動為事務註冊Advisor(BeanFactoryTransactionAttributeSourceAdvisor),匹配的處理邏輯在TransactionAttributeSourcePointcut切點中實現,是否匹配的判斷條件如下:

  1. 判斷當前Bean的Class是否匹配,具體是通過ClassFilter(TransactionAttributeSourceClassFilter)的matches方法實現的,註意這裡並不是判斷當前Bean所在類上面是否有事務註解,這個條件主要是為了排除一些Spring認為不需要進行事務代理的類,比如某個Bean的類路徑以java.開頭,而我們編寫的類一般不會是以java開頭的,所以這個Bean就會跳過代理,對於我們編寫的Bean,一般不會被這個條件過濾掉,會進行下一個條件判斷;

TransactionAttributeSourceClassFilter是TransactionAttributeSourcePointcut的內部類,裡面有matches方法的實現。

  1. 判斷當前Bean中的方法是否與事務切點匹配,具體是通過MethodMatcher(TransactionAttributeSourcePointcut)的matches方法實現,這裡會獲取當前Bean的所有方法,一個個與事務切點進行匹配,匹配規則如下:

(1)從方法中獲取事務註解相關的設置;
(2)從方法所在類中獲取事務註解相關設置;
(2)如果方法所在的類實現了介面,還會從介面上面解析是否有事務註解相關的配置;

如果我們使用了@Transactional註解對方法或者類進行了配置,就會在這一步解析到相關內容。

如果通過以上方式中的任意一種獲取到了事務相關設置,就會認為當前Bean需要進行事務代理,為其創建代理對象,實現與AOP一致,會為其創建一個AOP代理對象,只不過在執行目標方法時,Spring會通過已經設定好的事務切麵進行攔截,也就是BeanFactoryTransactionAttributeSourceAdvisor中的TransactionInterceptor對進行方法攔截,而在AOP中一般是我們自己編寫切麵。

事務攔截

上面我們知道對於需要進行事務攔截的Bean,會為其創建代理對象,在執行目標方法的時候,會進入事務攔截器的處理邏輯,主要步驟如下:

  1. 獲取事務管理器;
  2. 創建事務;
  3. 這裡主要是向後執行攔截器鏈,待所有的攔截器都執行完畢之後,執行目標方法;
  4. 捕捉異常,如果出現異常進行回滾;
  5. 提交事務;

事務的創建

事務的創建分為兩部分:

一、 獲取事務

(1)首先獲取事務對象,它是一個抽象方法,數據源的不同具體的實現類也不同;

以DataSourceTransactionManager為例,它主要是創建了一個數據源事務對象(DataSourceTransactionObject),然後根據數據源信息源獲取當前線程綁定的ConnectionHolder對象(如果有的話會獲取到否則獲取為空),ConnectionHolder中存有資料庫連接及事務的活躍狀態,之後會將這個ConnectionHolder設置到數據源事務對象中,將數據源事務對象返回;

(2)根據上一步獲取到的事務對象,判斷當前線程是否存在事務,如果存在事務需要根據事務傳播行為進行不同的處理;

是否存在事務的判斷方式是通過當前線程是否持有資料庫連接(數據源事務對象中的ConnectionHolder不為空)並且事務處於活躍狀態。

  • 如果事務傳播行為設是PROPAGATION_NEVER,表示不能存在事務,當前存在事務會拋出異常;
  • 如果事務的傳播行為是PROPAGATION_NOT_SUPPORTED,表示以不使用事務的方式執行,如果當前存在事務,則掛起當前的事務,執行完當前邏輯後(不使用事務)再恢復掛起的事務;
  • 如果事務的傳播行為是PROPAGATION_REQUIRES_NEW,表示每次執行都新建事務,如果當前存在事務需要掛起當前事務,創建一個自己的事務執行之後再恢復掛起的事務;
  • 如果事務的傳播行為是PROPAGATION_NESTED,表示嵌套事務,判斷是否使用保存點,如果是則使用嵌套事務,否則開啟一個新事務;
  • 其他情況使用當前的事務;

(3)如果當前線程不存在事務:

  • 如果事務的傳播行為是PROPAGATION_MANDATORY,它要求必須存在事務,當前不存在事務,會拋出異常;

  • 如果傳播行為是PROPAGATION_REQUIRED、PROPAGATION_REQUIRES_NEW或者PROPAGATION_NESTED,新建事務;

  • 其他情況創建一個空事務;

新建事務說明之前不存在事務,ConnectionHolder為空,此時會從資料庫連接池中獲取一個連接,設置到ConnectionHolder中,並將當前線程對應這個ConnectionHolder與數據源綁定(底層ThreadLocal實現),上面第(1)步中可以看到會通過數據源獲取當前線程的ConnectionHolder,數據就是在這裡添加的,之後就可以通過這個判斷當前線程是否已經存在事務。

二、 預處理事務

主要是進行事務相關信息的封裝以及事務和線程的綁定。

事務回滾

當執行過程中出現異常時,會進行事務回滾,回滾的處理邏輯如下:

  1. 判斷事務是否設置了保存點,如果設置了將事務回滾到保存點;
  2. 如果是一個獨立的新事務,直接回滾即可;
  3. 如果既沒有設置保存點,也不是一個新事務,說明可能處於嵌套事務中,此時只設置回滾狀態rollbackOnly為true,當它的外圍事務進行提交時,如果發現回滾狀態為true,外圍事務則不提交;

資源清理

在事務提交/回滾之後,需要根據情況清理相關的資源以及恢復被掛起的事務,主要有以下操作:

  1. 清除當前線程綁定的事務相關信息;
  2. 清除當前線程對應的ConnectionHolder與數據源的綁定關係及ConnectionHolder自身的清理;
  3. 如果掛起的事務不為空,恢復掛起的事務;

您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • """sth imported""" import time import os '''2 flags''' flag = 0 tmp = 0 '''7 ending''' def end1(): os.system("cls") print('面對暴怒的院長,你在心裡十分唾棄自己,卻還是緘口不言。 ...
  • 作者最近在開發公司項目時使用到 Redis 緩存,併在翻看前人代碼時,看到了一種關於 @Cacheable 註解的自定義緩存有效期的解決方案,感覺比較實用,因此作者自己拓展完善了一番後分享給各位。 Spring 緩存常規配置 Spring Cache 框架給我們提供了 @Cacheable 註解用於 ...
  • 徹底玩轉單例模式 單例中最重要的思想 >構造器私有! 惡漢式、懶漢式(DCL懶漢式!) 惡漢式 package single; //餓漢式單例(問題:因為一上來就把對象載入了,所以可能會導致浪費記憶體) public class Hungry { /* * 如果其中有大量的需要開闢的空間,如new b ...
  • 二、認識C++ 1、項目創建 1)創建項目 ①控制台應用 ②創建項目及解決方法 ③項目創建成功頁面 2、內容輸出 #include <iostream> int main() { std::cout << "認識C++\n"; //可以理解為把雙引號中的字元串,通過<<流入到了屏幕上 } "\n"表 ...
  • 今天記一個支付寶報錯“無效的AppID參數”的問題排查解決過程,希望可以幫到大家。 報錯產生 今天在測試支付寶用戶信息授權 換取授權訪問令牌 的時候,遇到了一個報錯:“無效的AppID參數”,本來以為是個簡單的問題,結果還是花了一點時間去找原因,找到最後發現是自己腦子瓦特了=。= 報錯截圖如下: 在 ...
  • Python中的 *號是一個特殊的符號,在其他編程語言中,它最廣為人知的用途就是作為乘法運算的符號。而在Python中,它的用途遠不止如此。 本文總結了Python中*號的所有用途,以供參考。 1. 算術運算 號用來做算術運算幾乎是所有編程語言採用的方法,在Python中,號可作為乘法運算和指數運算 ...
  • 分散式的思想在大量的數據處理操作方案中涌現了很多的解決方式。Java 是 90 年代出現的語言,在嵌入式移動領域和 web 系統 PC 端占據著較大的市場。移動安卓以及現在的企業H5 小程式,在企業的數字化轉型中起著十分重要的作用。 分散式微服務實現的框架是在 2017 年 springboot 開 ...
  • 常用的包 import torch import torchvision from torch import nn from torch.utils.data import DataLoader from torch.nn import Conv2d, MaxPool2d, Flatten, Lin ...
一周排行
    -Advertisement-
    Play Games
  • 隨著Aspire發佈preview5的發佈,Microsoft.Extensions.ServiceDiscovery隨之更新, 服務註冊發現這個屬於老掉牙的話題解決什麼問題就不贅述了,這裡主要講講Microsoft.Extensions.ServiceDiscovery(preview5)以及如何 ...
  • 概述:通過使用`SemaphoreSlim`,可以簡單而有效地限制非同步HTTP請求的併發量,確保在任何給定時間內不超過20個網頁同時下載。`ParallelOptions`不適用於非同步操作,但可考慮使用`Parallel.ForEach`,儘管在非同步場景中謹慎使用。 對於併發非同步 I/O 操作的數量 ...
  • 1.Linux上安裝Docken 伺服器系統版本以及內核版本:cat /etc/redhat-release 查看伺服器內核版本:uname -r 安裝依賴包:yum install -y yum-utils device-mapper-persistent-data lvm2 設置阿裡雲鏡像源:y ...
  • 概述:WPF界面綁定和渲染大量數據可能導致性能問題。通過啟用UI虛擬化、非同步載入和數據分頁,可以有效提高界面響應性能。以下是簡單示例演示這些優化方法。 在WPF中,當你嘗試綁定和渲染大量的數據項時,性能問題可能出現。以下是一些可能導致性能慢的原因以及優化方法: UI 虛擬化: WPF提供了虛擬化技術 ...
  • 引言 上一章節介紹了 TDD 的三大法則,今天我們講一下在單元測試中模擬對象的使用。 Fake Fake - Fake 是一個通用術語,可用於描述 stub或 mock 對象。 它是 stub 還是 mock 取決於使用它的上下文。 也就是說,Fake 可以是 stub 或 mock Mock - ...
  • 為.net6在CentOS7上面做準備,先在vmware虛擬機安裝CentOS 7.9 新建CentOS764位的系統 因為CentOS8不更新了,所以安裝7;簡單就一筆帶過了 選擇下載好的操作系統的iso文件,下載地址https://mirrors.aliyun.com/centos/7.9.20 ...
  • 經過前面幾篇的學習,我們瞭解到指令的大概分類,如:參數載入指令,該載入指令以 Ld 開頭,將參數載入到棧中,以便於後續執行操作命令。參數存儲指令,其指令以 St 開頭,將棧中的數據,存儲到指定的變數中,以方便後續使用。創建實例指令,其指令以 New 開頭,用於在運行時動態生成並初始化對象。方法調用指... ...
  • LiteDB 是一個輕量級的嵌入式 NoSQL 資料庫,其設計理念與 MongoDB 類似,但它是完全使用 C# 開發的,因此與 C# 應用程式的集成非常順暢。與 SQLite 相比,LiteDB 提供了 NoSQL(即鍵值對)的數據存儲方式,並且是一個開源且免費的項目。它適用於桌面、移動以及 We ...
  • 1 開源解析和拆分文檔 第三方的工具去對文件解析拆分,去將我們的文件內容給提取出來,並將我們的文檔內容去拆分成一個小的chunk。常見的PDF word mark down, JSON、HTML。都可以有很好的一些模塊去把這些文件去進行一個東西去提取。 優勢 支持豐富的文檔類型 每種文檔多樣化選擇 ...
  • OOM是什麼?英文全稱為 OutOfMemoryError(記憶體溢出錯誤)。當程式發生OOM時,如何去定位導致異常的代碼還是挺麻煩的。 要檢查OOM發生的原因,首先需要瞭解各種OOM情況下會報的異常信息。這樣能縮小排查範圍,再結合異常堆棧、heapDump文件、JVM分析工具和業務代碼來判斷具體是哪 ...