如果說「共識」解決的是「水平」問題，那麼「事務」解決的就是「垂直」問題，是如何讓一條繩上的螞蚱共同起舞。

事務只是一個計算機術語，其實事務的體現形式在我們生活中也無處不在。任何我們認為應該是這樣的事情，去確保它達到預期的過程就是「事務」。往小了說，我們平時在走路的時候，向前擺動左手的同時擡右腿，如果不是這樣的話就是不一致，別人會說你走路不協調。所以我們小時候父母會通過各種方式教會我們這個，這些各式各樣的方式就好比我們在軟體開發中去實施「事務」一樣，一題是多解的。

二、事務的來源

提到事務不得不提到「XA規範」[1]，這是分散式還沒大行其道的時期，被大多數的資料庫作為其內部分散式事務實現的介面標準。

注：文中[1-8]標註皆可於文末找到對應參考資料

▲圖片來源於論文中，版權歸原作者所有

「XA規範」就是上圖中「RM」和「TM」的互動規範和介面定義。僅僅是定義了xa_和ax_系列的函式原型以及功能描述、約束和實施規範等，並不包括建議的實現方式。後面會提到的兩階段提交（2PC）是「TM」協調「RM」們完成事務的方法。

所以其實可以說，事務起源於資料庫，輝煌於分散式系統。在摩爾定律還適用的時候，軟體系統為了承載更大的流量或者說使用者數，開始運用「分治」的思想來設計。然後隨著網際網路的蓬勃發展，B/S應用大行其道的背景下，分散式系統越來越常見。並且隨著一個個巨無霸網際網路公司的出現，越來越被鼓吹和傳頌。

一輪明月的背後是一個陰暗面，從來不讓人看見。

能被吹捧的永遠是有益的一面，再加上耀眼的資料：多少TPS、多少QPS，更抓人眼球。但是這背後為了讓「分治」後的系統能夠儘可能的像單個個體一樣運作，各類專家學者們通過多年研究，才有瞭如今的各種著名理論和解決方案。

三、分散式系統中的事務問題

正如前面所說，事務問題其實一直存在，只是在分散式系統中被放大了。並且隨著系統拆分的粒度越細，問題的複雜度成指數上升。

分散式系統的事務，不得不提到被廣為流傳的兩個理論：「CAP」、「BASE」。

1、CAP理論

「CAP」理論由Eric Brewer在2000年PODC會議上提出[2]，所以還被稱為Brewer定理。是Eric Brewer在Inktomi期間研發搜尋引擎、分散式web快取時得出的一個猜想：

It is impossible for a web service to provide the three following guarantees : Consistency, Availability and Partition-tolerance.

後來Seth Gilbert和Nancy Lynch對其進行了證明[3]，成為我們熟知的「CAP」定理。

對，就是下面這張經典的圖：

▲圖片來源於網路，版權歸原作者所有

• 一致性(consistency)：這裡的一致性指是「線性一致性」。（關於線性一致性的解釋，可回顧上篇文章《這或許是最通俗易懂的資料一致性問題解讀》）

• 可用性(availability)：每個請求都在一定時限內得到響應。

• 分割槽容忍性(partition-tolerance)：這應該是這三點中最晦澀的。允許丟失以一個節點發給另一個節點的任意多的訊息。只要是分散式系統，這項是無法逃避的。因為網路、硬體說不準啥時候就出問題了。

舉個不是特別嚴謹的例子，這就好比要實現一個系統不能產生BUG（C），並且10天內完成上線（A），以及需要多人團隊一起協作進行（P）。我們做開發的也很清楚這三者是無法兼得的。況且只要是一個組織，團隊協作是無法避免的，正如這裡的分割槽容忍性一樣，比如得考慮人員請假的問題。

剩下的2項，如果說可以達到沒有BUG的話，那就是時間無限延長，但也只是無限趨近於0，並不能達到真正的0，因為沒有人可以保證發現了所有的BUG。

2、BASE理論

「BASE」理論是由時任ebay架構師的Dan Pritchett提出的[4]，本質上就是對「線性一致性」的弱化。弱化的方式正如上一篇文章的「順序一致性」和「最終一致性」。（關於這兩種一致性的解釋，點《上篇》可閱讀）

「BASE」理論解釋如下：

• 基本可用(Basically Available)。分散式系統在出現故障時，允許損失部分可用功能，保證核心功能可用。

• 軟狀態(Soft State)。狀態可以有一段時間不同步，且這個狀態不影響系統可用性。

• 最終一致(Eventually Consistent)。確保最終資料能夠一致，而不是時時保持強一致。

「BASE」理論的提出並不是取代「CAP」理論，不是讓我們在實際的工作中完全撇開「線性一致性」，而是引導我們可以區分核心和非核心，然後分別對待，核心部分還是需要用CAP理論來保證「線性一致性」。

為什麼要區別對待？根本上還是無法容忍「線性一致性」帶來的巨大效能損耗，因為它是反可伸縮性的。但只要是涉及到Money之類的高敏感資料的操作部分，還是必須保證「線性一致性」。

便於理解，還是用上面的例子：我們側重於降低核心功能的BUG，不花過多精力在非核心功能上（BA）。我們允許產生不影響核心功能的BUG（S），但是必須最終要修復（E）。

四、分散式事務的解決方案

如果說「CAP」理論和「BASE」理論是「道」，那麼圍繞這兩個理論演化的解決方案就是「術」。對我們來說，最重要的事是在實際的運用中根據所處的場景找到最合適的。

以「CAP」為基礎的強一致性解決方案都會引入一個類似“協調器”的東西來作為全域性事務的掌控者，可以來看一下：

1、兩階段提交（2PC）[5]

▲圖片來源於網路，版權歸原作者所有

印象中左耳朵耗子（陳皓）之前拿西方結婚時的儀式做過一個形象的比喻。大致好像是牧師分別詢問男女雙方“你願意嗎？”相當於這裡的「請求提交」，得到的“yes”相當於「是」這個答覆。然後再要求給對方帶上戒指，這個要求就相當於這裡的「提交」，戴完戒指之後的反饋就是「ACK」。

另外值得注意的是，參與者在答覆「是」之前會將自己的內部資源變為阻塞狀態。因此如果在產生阻塞後協調者出問題，那麼這些被阻塞的資源有可能就一直不被釋放了，需要額外的介入。

2PC相對來說是最簡單的事務模型，但缺點也更多。其它缺點諸如：在某些場景下的資料不一致（參與者與協調者共同與「提交」環節掛了）、阻塞範圍過大等問題。

2、三階段提交（3PC）[6]

▲圖片來源於網路，版權歸原作者所有

3PC的出現就是通過增加複雜度（效能也因此降低）來解決或優化2PC中的一部分問題。本質的變化就是在2PC的「請求提交」之後增加了一個「準備提交」環節，以增加每個參與者需要等待其它參與者確認後方可進行具體的操作。

「阻塞」這個動作延後到「準備提交」環節再做，使得阻塞範圍縮小為2PC的2/3（圖中背景黃色和綠色部分）。正如上面的例子，在交換戒指之前增加了把戒指交給牧師的動作。

同時還解決了協調者的單點問題。故障恢復或者新接替的協調者，可以利用「準備提交」產生的狀態結果，來作為參與者和協調者在「提交」出現故障恢復後的界定依據。

還是前面的例子，誇張點，交換戒指的時候我失憶了，意識恢復後我只要看到牧師手掌上託著戒指或者我的手上已經被戴好了戒指，就知道我的妻子已經答應了，我只要繼續給她做戴戒指這個事就好了。

新引入了timeout機制，在發生超時執行預設約定，避免了永久阻塞，也因此對多個參與者下的100%資料一致性作出了妥協。比如，協調者在向參與者A傳送「doCommit」時timeout了，會引發廣播「abort」，但是這個「abort」又未能投遞到參與者B，導致參與者B執行了「ACK」後的timeout預設約定「commit」。

3、TCC

在國內，由於阿里的光環加持下TCC好像更火，風頭蓋過了2PC和3PC。其本質上是另闢蹊徑達到了和3PC類似的效果。

▲圖片來源於網路，版權歸原作者所有

作用：

• 通過運用本地事務代替了全域性事務，使得可以不需要協調者的存在，避免了協調者的單點問題。

• 3PC中協調者的另一個作用：故障恢復後的資料一致性。在TTC裡通過事務日誌來確保。

這個概念最初是由Pat Helland於2007年提出的[7]，那時還叫「Tentative-Confirmation-Cancellation」，在2008年的軟體開發2.0技術大會上支付寶CTO（程立）將其在國內推廣開來。

以上這三種就是主流的DTS（Distributed Transaction Service）框架。

值得一提的是，不管是3PC還是TCC，只要涉及到故障恢復或者重試機制，那麼「冪等性」問題必須要提上來了。比如3PC中「提交」階段某個參與者和協調者同時掛了，但是這個參與者在掛之前已經做了commit操作。那麼故障恢復後其實沒人知道它是否執行過了commit，協調者只會為了能100%確保commit指令被送達，又會發起一次commit通知，這時候如果沒有做好「冪等性」就會發生重複commit的問題。

 下面聊聊以「BASE」理論為基礎的解決方案。

1、 非同步訊息——本地訊息表

這種實現方式的思路，源於ebay，與提出BASE理論在同一篇論文中[4]。設計思想是將遠端分散式事務拆分成一系列的本地事務，藉助關係型資料庫中的表即可實現。

2、非同步訊息——不支援事務的MQ

其實大部分的MQ都是不支援事務的，所以我們需要自己想辦法解決可能出現的MQ訊息未能成功投遞出去的問題。有個便宜可以撿的是，如果需投遞的MQ訊息條數僅有1的話，可以將本地事務的commit放於訊息投遞之後即可避免此問題。虛擬碼如下：

try{

    beginTrans();

    modifyLocalData1();

    modifyLocalData2();

    deliverMessageToMQ();

    commitTrans();

}

catch(Exception ex){

    rollbackTrans();

}

3、非同步訊息——支援事務的MQ

據我所知，目前唯一支援事務的MQ框架是RockerMQ，並且於近期才開源了事務部分實現。這樣的確能省很多事，直接放一張阿里方面給出的圖感受一下實現細節：

▲圖片來源於網路，版權歸原作者所有

不過其實有一個疑點我沒有去驗證，有知道的小夥伴們可以留言下，就是RocketMQ是否有防止consumer（上圖中的訂閱方）在消費完成後傳送的ACK丟失的機制。如果能達到這點，對於consumer內部的方法冪等性需求就低了很多。

4、Saga

Saga是1987年就提出的概念[8]，核心是：

• 將一個分散式事務拆分為多個本地事務，並且擊鼓傳花給下一個，不用阻塞本地事務等待響應。且允許巢狀至多一層子事務。

• 除了最後一個參與者之外，都需要定義一個「回滾」介面，便於在遇到無法進行下去的情況下撤銷之前上游系統的修改。當然這裡的撤銷除了Update還可以是衝抵類的操作。

Saga原則上是個鏈式的「長活事務」，整個處理耗時可能會很長。所以可以通過增加save point（儲存點，類似於遊戲裡的存檔），便於故障恢復和提速，如向前恢復（重試）和向後恢復（回滾）。不過，也可以並行多個子事務，但一般在運用中心節點的Saga模式中，如圖：

只是在我們打破了鏈式規則後必須要額外確保執行了「回滾」之後再接收到「正向請求」，等於“請求無效”的效果。中心節點模式還有一個比較大的好處是能夠更好的避免事務之間的迴圈依賴關係。

5、Gossip協議

額外提一下，這個其實是一個具體的、運用BASE理論實現的協議，藉由Cassandra的熱火而讓更多人知道了。這協議一般會用於資料複製、P2P拓撲構造、故障探測等。

看這些案例我們可以發現，基於「CAP」的解決方案都是線上的，而「Base」是允許離線的。好比前者是，累倒了必須得馬上爬起來繼續幹活，要不然就是失敗。而後者是，慢慢來，只要最終能幹完。

不管怎樣，如果每個解決方案中增加「重試」和「回滾」，會大大提升程式的自我修正能力，以降低需要人為介入的比例。識別是否需要人為介入的方式就是類似於「對賬」的機制，這個機制就是兜底的。最後還需要做一道選擇題來防止混亂：確保參與者的介面符合「冪等性」，或者在中介軟體裡做到「正好一次(Exactly-once)」。

這些基於「BASE」的解決方案都是可以作為「CAP」解決方案出現問題時的PlanB來用的，起到補充作用。當然，如非必要，可以優先考慮基於「BASE」的方案，畢竟這才是天然易伸縮的，自然也能帶來更好的效能。

五、結語

解決方案如此多，所以不管我們是架構師、還是在成為架構師的路上，甚至在日常生活中，都需要養成Balance的習慣，找到那個最適合的方案。

最後還有一招終極大法——減少冗餘。

是亦彼也，彼亦是也，彼亦一是非，此亦一是非。——莊子

「事物都具有兩面性」，所以，在選擇走向分散式之前，慎重考慮下是否有必要，以免給自己徒增麻煩。

作者：張帆

來源：跨界架構師訂閱號（ID：Zachary_ZF）

dbaplus社群歡迎廣大技術人員投稿，投稿郵箱：[email protected]