那些用 Go 實現的分布式事務框架
本文轉載自微信公眾號「RememberGo」，作者吳親庫里 。轉載本文請聯系RememberGo公眾號。
開篇
不知不覺竟然一個月沒更新了，人一旦懶下來只會越來越懶。
最近對分布式事務產生了一些興趣，查閱了一些文章以及論文。這篇文章主要介紹我看的兩個項目，不涉及一些理論知識。
- 阿里開源版本的Seata，主要看了Go實現的seata-golang(落后java版)
- 以及前段時間很多公眾號都發的dtm。
Seata簡介
Seata是由阿里開源的分布式事務服務，目前為用戶提供了AT、TCC、SAGA、XA的事務模式，整體采用的是兩階段提交協議。Go版的seata-golang 目前好像只實現了mysql的AT、TCC模式，作者現在不咋更新了。
Seata 有幾個核心角色：
- TC(Transaction Coordinator) -事務協調者。(維護全局和分支事務的狀態，驅動全局事務提交或回滾)
- TM(Transaction Manager)-事務管理器。(定義全局事務的范圍：開始全局事務、提交或回滾全局事務。)
- RM(Resource Manager)-資源管理器。(管理分支事務處理的資源，與TC交談以注冊分支事務和報告分支事務的狀態，并驅動分支事務提交或回滾)
當然這樣看，可能還不是很理解，我拿一張官網的圖加以解釋。
從上圖中可以看出，這三個角色所負責的工作如下，
TC
- 維護全局和分支事務狀態，需要進行存儲。
- 當一個分布式事務處理結束，需要通知到每個RM是commit還是rollback。
TM
- 向TC請求開啟一個分布式事務，得到一個全局唯一的分布式id。
- 根據每個參與分布式事務的RM一階段的反饋，決定二階段向TC請求此次分布式事務是commit還是rollback(絕大部分場景下，一階段任一RM失敗，本次分布式事務失敗)
RM
說的白一點就是管理參與分布式事務的各個服務(比如經典下單場景中涉及到的:訂單服務、庫存服務、營銷服務等)
ps:個人感覺，這里的RM有點類似微服務中的中間處理層(專業術語他們管這叫bff->backend for fronted)。
- 一階段 prepare 行為(主動)：每個RM調用 自定義 的 prepare 邏輯。
- 二階段 commit 行為(被動觸發)：如果本次分布式事務第一階段全部RM成功，TC處理完自身狀態變更后，調用各個RM自定義 的 commit 邏輯。(一階段RM全部成功)
- 二階段 rollback 行為(被動觸發)：如果本次分布式事務第一階段任一RM失敗，TC處理完自身狀態變更后，調用各個RM自定義 的 rollback 邏輯。(一階段任意RM失敗)
好了。下面可以看看seata-golang 實現的一些細節了，seata-golang 底層采用gRPC進行通信。
seata-golang
我們先看RM部分結構。
至于managers，保存支持的各大事務模式實現(TCC、XA等)，每個模式只需要實現此接口即可。
再看TC部分結構(去除部分字段)。
TC對數據的存儲目前支持mysql和pgsql，即只要實現SessionManager接口，然后注入到SessionHolder的manager。
介紹完這兩個基本結構，還記得我們上面說過他們之間的關系嗎?
二階段TC會根據當前事務狀態去通知RM是commit還是rollback。
在初始化ResourceManager 的時候，
我們看到最終會調用TC一個 grpc 接口branchCommunicate。
對應到服務端。
我們知道gRPC有四種基礎的通信模式。
- 一元模式(Unary RPC)
- 服務器端流RPC(Server Sreaming RPC)
- 客戶端流RPC(Client Streaming RPC)
- 雙向流RPC(Bidirectional Streaming RPC)
想要流的形式也很簡單，只需要在proto方法定義中將對應的請求|響應 參數前加上stream標記，那么這個接口就是流式傳送了。至于是哪種流，取決于你把stream加在哪邊，如果請求和響應都加，那么就是雙向流了。
客戶端和服務端都可以通過stream.Send 發送請求，通過stream.Recv 接收數據。
當RM調用BranchCommunicate時，
最終處理分支事務調用manager.BranchCommit，
相應的，當TC被RM調用BranchCommunicate 后，
上面要發送給RM 通知commit 或者 rollback 數據是咋么來的呢?
當TC要通知RM進行分支commit 的時候，
最后一個就是TM，沒啥理解難度。
其實seat-golang還有別的可以提一提的。
比如說，它里面通過go反射實現的動態代理功能(雖然我覺得完全沒必要?)，我懶得寫了。
這篇文章再寫就更長了，不繼續寫dtm了，感興趣的留個言，我看看要不要寫一篇dtm。
參考
https://seata.io/zh-cn/docs/overview/what-is-seata.html
https://github.com/opentrx/seata-golang
