Seata 1.5.2 源碼學習(事務執行)

来源:https://www.cnblogs.com/cjsblog/archive/2022/11/22/16912937.html
-Advertisement-
Play Games

關於全局事務的執行,雖然之前的文章中也有所涉及,但不夠細緻,今天再深入的看一下事務的整個執行過程是怎樣的。 1. TransactionManager io.seata.core.model.TransactionManager是事務管理器,它定義了一個全局事務的相關操作 DefaultTransa ...


關於全局事務的執行,雖然之前的文章中也有所涉及,但不夠細緻,今天再深入的看一下事務的整個執行過程是怎樣的。

1. TransactionManager

io.seata.core.model.TransactionManager是事務管理器,它定義了一個全局事務的相關操作

DefaultTransactionManager是TransactionManager的一個實現類

可以看到,所有操作(開啟、提交、回滾、查詢狀態、上報)都是調用TmNettyRemotingClient#sendSyncRequest()方法向TC發請求

2. GlobalTransaction

DefaultGlobalTransaction實現了GlobalTransaction,它代表一個全局事務

有兩件事情需要留意,一是transactionManager是什麼? 二是GlobalTransactionRole又是什麼?

採用靜態內部類的形式來構造單例,還記得DefaultRMHandler和DefaultResourceManager也都是通過靜態內部類的形式構造單例

3. TransactionalTemplate

TransactionalTemplate是全局事務執行模板,所有業務邏輯都在其定義的模板方法中執行

io.seata.tm.api.TransactionalTemplate#execute()

現在整個過程清楚了,首先根據事務傳播特性來創建一個事務對象,然後開啟事務,執行業務邏輯處理,最後提交事務,如果業務執行過程中拋異常,則回滾事務。

現在有一個問題,什麼情況下會進入TransactionalTemplate#execute(),或者說什麼時候調用該方法?

要回答這個問題,又得從io.seata.spring.annotation.GlobalTransactionScanner說起,這個前面已經說過了,想瞭解的可以再看看之前那篇 https://www.cnblogs.com/cjsblog/p/16866796.html

從GlobalTransactionScanner說起就太長了,直接快進到GlobalTransactionalInterceptor攔截器吧

當被調用的方法上有@GlobalTransactional註解時,就會被攔截,從而進入GlobalTransactionalInterceptor#invoke(),在invoke()里會調用GlobalTransactionalInterceptor#handleGlobalTransaction(),於是順利進入TransactionalTemplate#execute()

也就是說,當進入第一個@GlobalTransactional方法時,此時全局事務為空,於是創建一個角色為“GlobalTransactionRole.Launcher”的DefaultGlobalTransaction。當方法內部又調用了另一個@GlobalTransactional方法,於是再創建一個角色為“GlobalTransactionRole.Participant”的DefaultGlobalTransaction。以此類推,後面的都是事務“參與者”。

好了,現在事務已經創建,接下來就可以開啟事務並執行業務邏輯處理了

可以看到,只有角色為“GlobalTransactionRole.Launcher”的線程才可以執行事務的開啟提交回滾操作,而且這些操作的底層都是調用TransactionManager中的方法,最終是調用TmNettyRemotingClient#sendSyncRequest()方法向TC發送同步請求

最後,看一下什麼時候回滾

catch捕獲到異常就回滾

以上這些說的都是TM,因為是TM在控制整個全局事務的執行,至於RM本地事務的執行要看io.seata.rm.datasource.ConnectionProxy,這個在之前都講過了

4. GlobalLockTemplate

GlobalLockTemplate是全局鎖模板,是需要全局鎖的本地事務的一個執行器模板

那麼,在哪裡用這個"TX_LOCK"線程變數呢?在BaseTransactionalExecutor#execute()

預設ConnectionContext中isGlobalLockRequire為false

現在就很清晰了,當方法上加了@GlobalLock註解後,進入GlobalLockTemplate#execute(),在當前線程上綁定局部變數TX_LOCK=true。當本地事務提交的時候,上下文(ConnectionContext)中isGlobalLockRequire為true,於是給TC發請求查詢鎖,如果這些數據沒有被任何事務加鎖,或者被當前事務加鎖,則都算獲取到鎖了,如果被別的事務加鎖了,則算獲取鎖失敗。

總結一下鎖互斥,分這麼幾種情況:

  1. 兩個@GlobalTransactional方法之間,會在註冊分支事務的時候檢查全局鎖,註冊成功(獲取鎖成功)才能提交
  2. 兩個@GlobalLock方法之間,會在事務提交前檢查全局鎖,獲取到鎖才能提交
  3. @GlobalTransactional方法與@GlobalLock方法之間,都是在提交前,一個是分支註冊檢查鎖,一個是直接檢查鎖

還有一個問題,哪些數據會被加鎖呢?這就要從io.seata.rm.datasource.exec.ExecuteTemplate#execute()說起了

長話短說,什麼樣的數據加鎖取決於資料庫,以及SQL語句,自行理解一下吧

5. 總結

1、Seata到底是如何實現分散式事務的?

  • 首先,每個業務系統都要引入seata的jar包,因此每個業務系統都是一個seata client,於是數據源被seata代理,同時所有方法添加攔截器,對加了@GlobalTransactional的方法進行攔截處理;
  • 其次,進入事務方法後,按照模板方法定義,在try...catch...finally中先創建事務並開啟,接著執行業務處理,如果拋異常則回滾,如果順利執行完成,則提交;
  • 再次,被調用的遠程服務在其本地開啟事務並執行,將業務處理和undo_log放在同一個事務中,然後向TC註冊分支事務,成功後提交本地事務並向TC報告分支狀態
  • 最後,業務順利執行完或拋異常後TM向TC發請求可以提交或回滾全局事務了,TC向所有已註冊的分支事務發送提交或回滾請求

總之,數據源代理和全局事務掃描是seata實現分散式事務的基礎,而TM做的事情就是控制事務的執行,RM做的事就是處理好本地事務的執行,TC是協調器

2、Seata實現的全局事務,它的事務隔離級別是怎樣的?會不會出現臟讀、幻讀、不可重覆讀?

先看臟讀,在全局事務提交之前,分支事務早已提交,因此,預設情況下,其它的事務是可以讀取到當前未提交的全局事務的數據的,故而,預設情況下會發生臟讀。

舉個例子,假設現在有一個全局事務A還沒提交,但是其中的分支事務A1已經提交,A2還在沒提交,這個時候另一個全局事務B是可以讀取到A1已經提交的數據的,也就是在全局事務B中讀到了還未提交的全局事務A的數據,這就是臟讀。

那麼,如何避免臟讀呢?

思路是這樣的:首先要讓Seata意識到這個SQL語句執行時鎖,光知道需要鎖還不行,還得讓它在執行的時候檢查是否獲取到鎖了。一個SELECT語句需要鎖就是將其改寫成SELECT ... FOR UPDATE的形式,檢查鎖的話@GlobalTransactional或@GlobalLock都可以辦到。於是,解決版本就有兩個:

  • SELECT ... FOR UPDATE  +  @GlobalTransactional
  • SELECT ... FOR UPDATE  +  @GlobalLock

綜上所述,分支事務在提交前先進行分支註冊獲取全局鎖,在全局事務提交成功後釋放全局鎖。此時,其它全局事務可以讀取到已提交的分支事務的數據,但這是當前全局事務還未提交,於是出現臟讀。辦法也很簡單,首先select加for update,其次業務方法加@GlobalTransactional或@GlobalLock註解。

同理,預設是可能出現幻讀和不可重覆讀的,它倆屬於是臟寫,究其原因還是因為跨資料庫了,seata搞了個全局鎖,這就相當於將業務中幾個不同的資料庫看成一個資料庫,全局鎖就相當於這個大資料庫中的行級鎖,因此解決辦法還是一樣

不得不說,Seata真的是一個優秀的分散式事務框架

3、AT模式、TCC模式、Saga模式、XA模式的區別

AT模式是基於支持本地事務的關係型資料庫

TCC模式不依賴於資料庫的事務支持,另外TCC沒有全局鎖,也就沒有鎖競爭,故而效率比AT模式高

Saga模式是seata提供的長事務解決方案

XA模式以 XA 協議的機制來管理分支事務的一種事務模式

 


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

-Advertisement-
Play Games
更多相關文章
  • 前面幾篇文章對 Yarn 基本架構、程式基礎庫、應用設計方法等進行了介紹。之後幾篇將開始對 Yarn 核心組件進行剖析。 ResourceManager(RM)是 Yarn 的核心管理服務,負責集群管理、任務調度、狀態機管理等,本篇將對 RM 總體架構進行介紹。 ...
  • 哈夫曼編碼應用 問題描述 ​ 給定字元串,將每個不同的字元的哈夫曼編碼表示並輸出其哈夫曼編碼,並再將其哈夫曼編碼還原回字元串 分析一下 構建哈夫曼樹 ​ 使用靜態鏈表,先將所有的結點關係全部清零,再進行結點和相應權值的賦值,遍歷後n-1個結點 (新根),從n個結點中選兩個最小的權值了合成一棵樹,並將 ...
  • 一.小結 1.一個boolean變數可以存儲值true或false 2.關係運算符(<,<=,==,!=,>,>=)和數值及字元一起運算 3.布爾運算符&&,|| ,| 和 ^對布爾值和布爾變數進行計算 4.當對p1&&p2求值時,java先求p1的值,如果p1為true,再對p2求值;如果p1為f ...
  • 迭代器的功能: 提供一種統一的方式,來透明的遍歷容器 理解 begin()方法,end()方法, ++ , * 的用處 其中 C++11 中提供的foreach的方式,其底層還是通過迭代器來進行遍歷的. #include <iostream> using namespace std; class M ...
  • 1 概述 ArrayList實現了List介面,是 順序容器,允許放入null元素 有一個容量(capacity),表示底層數組的實際大小。如果容量不足,容器會 自動增大底層數組的大小 支持泛型,泛型擦除後,容器的元素都是 Object類型 ArrayList沒有實現同步(synchronized) ...
  • 來源:blog.csdn.net/weixin_61594803 1.SQL數據脫敏實現 MYSQL(電話號碼,身份證)數據脫敏的實現 -- CONCAT()、LEFT()和RIGHT()字元串函數組合使用,請看下麵具體實現 -- CONCAT(str1,str2,…):返回結果為連接參數產生的字元 ...
  • ###知識點 php://filter php://filter是一種元封裝器,是PHP中特有的協議流,設計用於數據流打開時的篩選過濾應用,作用是作為一個“中間流”來處理其他流。 php://filter目標使用以下的參數作為它路徑的一部分。複合過濾鏈能夠在一個路徑上指定。 |名稱|描述|備註| | ...
  • ###結果以json格式輸出,可以用json線上解析,方便查看 package com.xintone.demo; import cn.hutool.json.JSONUtil; import lombok.Data; import org.springframework.util.Collecti ...
一周排行
    -Advertisement-
    Play Games
  • 簡介 本文的初衷是希望幫助那些有其它平臺視覺演算法開發經驗的人能快速轉入Halcon平臺下,通過文中的示例開發者能快速瞭解一個Halcon項目開發的基本步驟,讓開發者能把精力完全集中到演算法的開發上面。 首先,你需要安裝Halcon,HALCON 18.11.0.1的安裝包會放在文章末尾。安裝包分開發和 ...
  • 本文是對Datawhale的動手學數據分析課程的學習總結,記錄了整體的學習過程、答案以及個人感想,代碼較為詳細。 ...
  • JZ7重建二叉樹 描述 給定節點數為 n 的二叉樹的前序遍歷和中序遍歷結果,請重建出該二叉樹並返回它的頭結點。 例如輸入前序遍歷序列{1,2,4,7,3,5,6,8}和中序遍歷序列{4,7,2,1,5,3,8,6} 提示: 1.vin.length == pre.length 2.pre 和 vin ...
  • 我們都知道在Java編程中多線程的同步使用synchronized關鍵字來標識,那麼這個關鍵字在JVM底層到底是如何實現的呢。 我們先來思考一下如果我們自己實現的一個鎖該怎麼做呢: 首先肯定要有個標記記錄對象是否已經上鎖,執行同步代碼之前判斷這個標誌,如果對象已經上鎖線程就阻塞等待鎖的釋放。 其次要 ...
  • 目錄 一.OpenGL 色階 1.Windows OpenGL ES 版本 2.Windows OpenGL 版本 二.OpenGL 色階 GLSL Shader 三.猜你喜歡 零基礎 OpenGL ES 學習路線推薦 : OpenGL ES 學習目錄 >> OpenGL ES 基礎 零基礎 Ope ...
  • 1. 查看Linux伺服器版本信息 # cat /etc/redhat-release CentOS Linux release 7.4.1708 (Core) 2. 禪道開源版安裝包下載 wget http://dl.cnezsoft.com/zentao/9.8.2/ZenTaoPMS.9.8. ...
  • Spring 框架可以為 Java 應用程式開發提供全面的基礎設施支持,它是現在非常流行的 Java 開源框架,對於一個 Java 開發人員來說,熟練掌握 Spring 是必不可少的。 ...
  • 前言 本篇是c++總結的第二篇,關於c++的對象模型,在構造、拷貝虛函數上重點分析,也包含了c++11class的新用法和特性,如有不當,還請指教! c++三大特性 訪問許可權 ​ 在c++中通過public、protected、private三個關鍵字來控製成員變數和成員函數的訪問許可權,它們分別表示 ...
  • 一.小結 1.使用二維數組來存儲表格 2.可以使用以下語法來聲明二維數組變數: 元素類型[ ] [ ]數組變數 3.可以使用以下語法來創建二維數組變數: new 元素類型 [行的個數][列的個數] 4.使用下麵的語法表示二維數組中的每個元素: 數組變數[行下標][列的個數] 5.可使用數組初始化語法 ...
  • typimg是一款為typora編輯器提供圖像自定義上傳服務的工具,該工具將在typora中輸入的網路圖片、本地圖片、剪貼板圖片/截圖上傳到博客園,支持在MacOS、Windiws、Linux三個平臺上運行。 ...