概述

大型業(yè)務系統(tǒng)有著用戶多、并發(fā)高的特點，而在這方面，集中式數(shù)據(jù)庫(單機數(shù)據(jù)庫)的性能很難支持，因此主流的互聯(lián)網(wǎng)公司往往采用分布式(架構)數(shù)據(jù)庫，物理上利用更多的低端設備，邏輯上對大表水平拆分支撐業(yè)務的需要。

雖然分布式數(shù)據(jù)庫能解決性能難題，但事務一致性(Consistency)的問題，卻很難在分布式數(shù)據(jù)庫上得到解決。

數(shù)據(jù)一致性?

一致性問題，“萬惡之源”是數(shù)據(jù)冗余和分布并通過網(wǎng)絡交互+網(wǎng)絡異常是常態(tài)。

1、數(shù)據(jù)一致性的情形

主庫、從庫和緩存數(shù)據(jù)一致性，相同數(shù)據(jù)冗余，關系數(shù)據(jù)庫，為保證關據(jù)庫的高可用和高性能，一般會采用主從(備)架構并引入緩存。其中數(shù)據(jù)不一致性存在于數(shù)據(jù)冗余的時間窗口內。常用的解決方案見數(shù)據(jù)庫之互聯(lián)網(wǎng)常用架構方案。

多副本數(shù)據(jù)之間的數(shù)據(jù)一致性，相同數(shù)據(jù)副本，大數(shù)據(jù)領域，一份數(shù)據(jù)會有多個副本并存儲到不同的節(jié)點上?？蛻舳丝梢栽L問任何一個節(jié)點進行讀寫操作。常用的解決方案是基于Paxos、ZAB、Raft、Quorum、Gossip等的開源實現(xiàn)。

分布式服務之間的數(shù)據(jù)一致性，相關數(shù)據(jù)分布，分布式服務，不同的服務操作不同的庫(表)，而且?guī)?表)間要保持一致。常用的解決方案是分布式事務一致性解決方案。

2、數(shù)據(jù)一致性的概念

強一致性

弱一致性

最終一致性

3、數(shù)據(jù)一致性的原理

ACID

CAP

BASE

4、數(shù)據(jù)一致性的協(xié)議

• 兩階段提交協(xié)議
• 三階段提交協(xié)議
• TCC協(xié)議
• Paxos協(xié)議
• ZAB協(xié)議
• Raft協(xié)議
• Quorum協(xié)議
• Gossip協(xié)議

分布式事務XA實現(xiàn)數(shù)據(jù)一致性

所謂分布式服務，就是把之前通過本地接口交互的模塊，拆分成單獨的應用獨立部署，并通過RPC和MQ交互。拿物流中的訂單和庫存舉例(新增一條訂單記錄，庫存就要-1)，集中式架構中，要想保證訂單表和庫存表的一致性，只要一個本地事務(ACID)就能保證兩者的強一致性;而分布式架構中，訂單表由訂單服務操作，庫存表由庫存服務操作。要想保證訂單表和庫存表的一致性，那么就必須保證訂單服務對訂單表的操作和庫存服務對庫存表的操作同時成功。之前的一個本地事務就變成了一個分布式事務。由于服務之間通過網(wǎng)絡交互+網(wǎng)絡異常是常態(tài)，就會產(chǎn)生服務間數(shù)據(jù)不一致的情況。這就涉及一個分布式事務一致性的問題。

如何來保證分布式事務的ACID，業(yè)界也有比較成熟的方案，一般是2段提交2PC協(xié)議或者改進版也就是3段提交3PC協(xié)議，下面來分別簡單介紹下。

2PC協(xié)議也成為2段提交，1prepare階段，2commit階段。

所謂的兩個階段是指：第一階段：準備階段(投票階段)和第二階段：提交階段(執(zhí)行階段)。

準備階段

事務協(xié)調者(事務管理器)給每個參與者(資源管理器)發(fā)送Prepare消息，每個參與者要么直接返回失敗(如權限驗證失敗)，要么在本地執(zhí)行事務，寫本地的redo和undo日志，但不提交，到達一種“萬事俱備，只欠東風”的狀態(tài)。

可以進一步將準備階段分為以下三個步驟：

1)協(xié)調者節(jié)點向所有參與者節(jié)點詢問是否可以執(zhí)行提交操作(vote)，并開始等待各參與者節(jié)點的響應。

2)參與者節(jié)點執(zhí)行詢問發(fā)起為止的所有事務操作，并將Undo信息和Redo信息寫入日志。(注意：若成功這里其實每個參與者已經(jīng)執(zhí)行了事務操作)

3)各參與者節(jié)點響應協(xié)調者節(jié)點發(fā)起的詢問。如果參與者節(jié)點的事務操作實際執(zhí)行成功，則它返回一個”同意”消息;如果參與者節(jié)點的事務操作實際執(zhí)行失敗，則它返回一個"中止"消息。

提交階段

如果協(xié)調者收到了參與者的失敗消息或者超時，直接給每個參與者發(fā)送回滾(Rollback)消息;否則，發(fā)送提交(Commit)消息;參與者根據(jù)協(xié)調者的指令執(zhí)行提交或者回滾操作，釋放所有事務處理過程中使用的鎖資源。(注意:必須在最后階段釋放鎖資源)

接下來分兩種情況分別討論提交階段的過程。

當協(xié)調者節(jié)點從所有參與者節(jié)點獲得的相應消息都為”同意”時:

1)協(xié)調者節(jié)點向所有參與者節(jié)點發(fā)出”正式提交(commit)”的請求。

2)參與者節(jié)點正式完成操作，并釋放在整個事務期間內占用的資源。

3)參與者節(jié)點向協(xié)調者節(jié)點發(fā)送”完成”消息。

4)協(xié)調者節(jié)點受到所有參與者節(jié)點反饋的”完成”消息后，完成事務。

如果任一參與者節(jié)點在第一階段返回的響應消息為”中止”，或者 協(xié)調者節(jié)點在第一階段的詢問超時之前無法獲取所有參與者節(jié)點的響應消息時：

1)協(xié)調者節(jié)點向所有參與者節(jié)點發(fā)出”回滾操作(rollback)”的請求。

2)參與者節(jié)點利用之前寫入的Undo信息執(zhí)行回滾，并釋放在整個事務期間內占用的資源。

3)參與者節(jié)點向協(xié)調者節(jié)點發(fā)送”回滾完成”消息。

4)協(xié)調者節(jié)點受到所有參與者節(jié)點反饋的”回滾完成”消息后，取消事務。

不管最后結果如何，第二階段都會結束當前事務。

二階段提交看起來確實能夠提供原子性的操作，但是不幸的事，二階段提交還是有幾個缺點的：

1、同步阻塞問題。執(zhí)行過程中，所有參與節(jié)點都是事務阻塞型的。當參與者占有公共資源時，其他第三方節(jié)點訪問公共資源不得不處于阻塞狀態(tài)。

2、單點故障。由于協(xié)調者的重要性，一旦協(xié)調者發(fā)生故障。參與者會一直阻塞下去。尤其在第二階段，協(xié)調者發(fā)生故障，那么所有的參與者還都處于鎖定事務資源的狀態(tài)中，而無法繼續(xù)完成事務操作。(如果是協(xié)調者掛掉，可以重新選舉一個協(xié)調者，但是無法解決因為協(xié)調者宕機導致的參與者處于阻塞狀態(tài)的問題)

3、數(shù)據(jù)不一致。在二階段提交的階段二中，當協(xié)調者向參與者發(fā)送commit請求之后，發(fā)生了局部網(wǎng)絡異?；蛘咴诎l(fā)送commit請求過程中協(xié)調者發(fā)生了故障，這回導致只有一部分參與者接受到了commit請求。而在這部分參與者接到commit請求之后就會執(zhí)行commit操作。但是其他部分未接到commit請求的機器則無法執(zhí)行事務提交。于是整個分布式系統(tǒng)便出現(xiàn)了數(shù)據(jù)部一致性的現(xiàn)象。

4、二階段無法解決的問題：協(xié)調者再發(fā)出commit消息之后宕機，而唯一接收到這條消息的參與者同時也宕機了。那么即使協(xié)調者通過選舉協(xié)議產(chǎn)生了新的協(xié)調者，這條事務的狀態(tài)也是不確定的，沒人知道事務是否被已經(jīng)提交。

由于二階段提交存在著諸如同步阻塞、單點問題、腦裂等缺陷，所以后來在二階段提交的基礎上做了改進，提出了三階段提交。

PC

三階段提交(Three-phase commit)，也叫三階段提交協(xié)議(Three-phase commit protocol)，是二階段提交(2PC)的改進版本。

與兩階段提交不同的是，三階段提交有兩個改動點。

1、引入超時機制。同時在協(xié)調者和參與者中都引入超時機制。

2、在第一階段和第二階段中插入一個準備階段。保證了在最后提交階段之前各參與節(jié)點的狀態(tài)是一致的。

也就是說，除了引入超時機制之外，3PC把2PC的準備階段再次一分為二，這樣三階段提交就有CanCommit、PreCommit、DoCommit三個階段。

CanCommit階段

3PC的CanCommit階段其實和2PC的準備階段很像。協(xié)調者向參與者發(fā)送commit請求，參與者如果可以提交就返回Yes響應，否則返回No響應。

1.事務詢問 協(xié)調者向參與者發(fā)送CanCommit請求。詢問是否可以執(zhí)行事務提交操作。然后開始等待參與者的響應。

2.響應反饋 參與者接到CanCommit請求之后，正常情況下，如果其自身認為可以順利執(zhí)行事務，則返回Yes響應，并進入預備狀態(tài)。否則反饋No

PreCommit階段

協(xié)調者根據(jù)參與者的反應情況來決定是否可以記性事務的PreCommit操作。根據(jù)響應情況，有以下兩種可能。

假如協(xié)調者從所有的參與者獲得的反饋都是Yes響應，那么就會執(zhí)行事務的預執(zhí)行。

1.發(fā)送預提交請求 協(xié)調者向參與者發(fā)送PreCommit請求，并進入Prepared階段。

2.事務預提交 參與者接收到PreCommit請求后，會執(zhí)行事務操作，并將undo和redo信息記錄到事務日志中。

3.響應反饋 如果參與者成功的執(zhí)行了事務操作，則返回ACK響應，同時開始等待最終指令。

假如有任何一個參與者向協(xié)調者發(fā)送了No響應，或者等待超時之后，協(xié)調者都沒有接到參與者的響應，那么就執(zhí)行事務的中斷。

1.發(fā)送中斷請求 協(xié)調者向所有參與者發(fā)送abort請求。

2.中斷事務 參與者收到來自協(xié)調者的abort請求之后(或超時之后，仍未收到協(xié)調者的請求)，執(zhí)行事務的中斷。

doCommit階段

該階段進行真正的事務提交，也可以分為以下兩種情況。

執(zhí)行提交

1.發(fā)送提交請求 協(xié)調接收到參與者發(fā)送的ACK響應，那么他將從預提交狀態(tài)進入到提交狀態(tài)。并向所有參與者發(fā)送doCommit請求。

2.事務提交 參與者接收到doCommit請求之后，執(zhí)行正式的事務提交。并在完成事務提交之后釋放所有事務資源。

3.響應反饋 事務提交完之后，向協(xié)調者發(fā)送Ack響應。

4.完成事務 協(xié)調者接收到所有參與者的ack響應之后，完成事務。

中斷事務 協(xié)調者沒有接收到參與者發(fā)送的ACK響應(可能是接受者發(fā)送的不是ACK響應，也可能響應超時)，那么就會執(zhí)行中斷事務。

在doCommit階段，如果參與者無法及時接收到來自協(xié)調者的doCommit或者rebort請求時，會在等待超時之后，會繼續(xù)進行事務的提交。(其實這個應該是基于概率來決定的，當進入第三階段時，說明參與者在第二階段已經(jīng)收到了PreCommit請求，那么協(xié)調者產(chǎn)生PreCommit請求的前提條件是他在第二階段開始之前，收到所有參與者的CanCommit響應都是Yes。(一旦參與者收到了PreCommit，意味他知道大家其實都同意修改了)所以，一句話概括就是，當進入第三階段時，由于網(wǎng)絡超時等原因，雖然參與者沒有收到commit或者abort響應，但是他有理由相信：成功提交的幾率很大。 )