透過協調多個服務間的一連串本地交易,維持分散式系統的資料一致性。 每個服務執行其操作並透過事件或訊息觸發下一步。 若步驟失敗,一連串補償交易會撤銷完成步驟所做的變更。
內容和問題
交易 代表可包含多個作業的工作單位。 在交易中,事件 是指影響實體的狀態變更。 命令 封裝執行動作或觸發後續事件所需的所有資訊。
交易必須遵循原子性、一致性、隔離性和持久性(ACID)原則。
- 原子性: 所有操作要麼全部成功,要麼全部不成功。
- 一致性: 數據會從一個有效狀態轉換成另一個有效狀態。
- 隔離: 並行交易會產生與循序交易相同的結果。
- 持久性:即使發生失敗, 變更在認可之後仍會保存。
在單一服務中,交易會遵循 ACID 原則,因為它們會在單一資料庫內運作。 不過,在多個服務之間達成 ACID 合規性可能更為複雜。
微服務架構中的挑戰
微服務架構通常會將 專用資料庫指派給每個微服務。 此方法提供數個優點:
- 每個服務都會封裝自己的數據。
- 每個服務都可以針對其特定需求使用最適合的資料庫技術和架構。
- 每個服務的資料庫都可以獨立調整。
- 一個服務中的失敗會與其他服務隔離。
儘管有這些優點,但此架構會使跨服務數據一致性複雜化。 傳統資料庫保證,例如 ACID 無法直接適用於多個獨立管理的數據存放區。 由於這些限制,依賴進程間通訊的架構,或傳統交易模型,例如兩階段認可通訊協定,通常更適合Saga模式。
解決方案
Saga 模式會藉由將交易拆分為一系列 本機交易 來管理交易。
每筆本機交易:
- 在單一服務內以原子方式完成其工作。
- 更新服務的資料庫。
- 透過事件或訊息起始下一個交易。
如果本地交易失敗,Saga 會執行一系列的 補償交易,以撤銷先前本地交易所做的變更。
Saga 模式中的重要概念
可補償交易可以透過其他具有相反效果的交易加以撤銷或補償。 如果傳奇中的步驟失敗,補償交易會復原可補償交易所做的變更。
樞紐交易在整個歷程中是無法回頭的轉折點。 樞紐交易成功之後,可補償的交易就不再相關。 系統必須完成所有後續的動作,才能達到一致的最終狀態。 根據傳奇的流程,樞紐交易可以承擔不同的角色:
不可逆或無法補償的交易無法還原或重試。
可逆和認可的 之間的界限表示樞紐交易可以是最後一個可復原或可補償的交易。 或者,它也可以是 Saga 中第一個可重試的操作。
可重試交易位於樞紐交易之後。 可重試的交易具冪等性,並有助於確保 Saga 即使發生暫時性失敗,仍能到達最終狀態。 它們有助於讓 Saga 最終達到一致狀態。
Saga 實作方法
兩種典型的 Saga 實作方式是 編舞 和 協調。 每個方法都有自己的一組挑戰和技術來協調工作流程。
編舞
在編舞方法中,服務會在沒有集中式控制器的情況下交換事件。 在編舞模式中,每個本地交易都會發佈網域事件,進而觸發其他服務中的本地交易。
| 編舞的優點 | 編舞的缺點 |
|---|---|
| 適用於少數服務且不需要協調邏輯的簡單工作流程。 | 當您新增步驟時,工作流程可能會造成混淆。 很難追蹤每個 Saga 參與者各自會回應哪些命令。 |
| 協調不需要其他服務。 | Saga 參與者之間存在循環相依的風險,因為它們必須處理彼此的命令。 |
| 不會造成單點故障,因為職責分散在 Saga 的參與者之間。 | 整合測試很困難,因為所有服務都必須執行以模擬交易。 |
協調
在協調流程中,集中式控制器或 協調器,會處理所有交易,並告知參與者根據事件執行哪些作業。 協調器會執行 Saga 請求、儲存並解讀每項任務的狀態,並透過補償交易來處理失敗復原。
| 流程協調的優勢 | 編排的缺點 |
|---|---|
| 更適合複雜的工作流程,或當您新增服務時。 | 其他設計複雜度需要協調邏輯的實作。 |
| 避免迴圈相依性,因為協調器會管理流程。 | 因為協調器負責管理整個工作流程,所以會引入單點故障。 |
| 清楚區分責任可簡化服務邏輯。 |
問題和考慮
當您決定如何實作此模式時,請考慮下列幾點:
設計思維轉變: 採用傳奇模式需要不同的心態。 它需要您專注於跨多個微服務的交易協調和數據一致性。
Saga 偵錯的複雜性: 偵錯 Saga 可能相當複雜,尤其是隨著參與的服務數量增加。
不可逆的本地資料庫變更:資料無法回復,因為 Saga 參與者會將變更提交到各自的資料庫。
處理暫時性失敗和等冪: 當重複相同的作業不會改變結果時,系統必須有效處理暫時性失敗並確保等冪性。 欲了解更多資訊,請參閱 冪能消費者模式。
需要監控和追蹤 Saga: 監控和追蹤 Saga 的工作流程,是維持營運可視性的重要工作。
補償交易的限制: 補償交易可能不一定成功,這可能會使系統處於不一致的狀態。
傳奇中潛在的數據異常
資料異常是指當 Saga 跨多個服務執行時可能發生的不一致情況。 因為每個服務都會管理自己的數據,稱為 參與者數據,因此不會跨服務進行內建隔離。 此設定可能會導致數據不一致或持久性問題,例如部分套用的更新或服務之間的衝突。 一般問題包括:
遺失的更新: 當某個傳奇修改數據而不考慮另一個傳奇所做的變更時,會導致覆寫或遺失更新。
髒讀: 當某個 Saga 或事務讀取了另一個 Saga 已修改、但該修改尚未完成的資料。
模糊讀或不可重複讀: 當 Saga 中的不同步驟讀取到不一致的資料時,這是因為兩次讀取之間發生了更新。
解決數據異常的策略
若要減少或防止這些異常狀況,請考慮下列對策:
語義鎖定: 當 Saga 的可補償交易使用信號量來表示更新正在進行時,請使用應用程式層級鎖。
可交換更新: 將更新設計為可依任意順序套用,且仍得到相同結果。 這種方法有助於減少傳奇之間的衝突。
悲觀觀點: 重新安排 Saga 的順序,讓資料更新在可重試的交易中進行,以消除髒讀。 否則,一個傳奇可以讀取髒數據,或 未認可的變更,而另一個傳奇同時執行可補償的交易來回復其更新。
重新讀取值: 確認數據在您進行更新之前會維持不變。 如果資料有變動,請停止目前步驟,並視需要重新啟動 Saga。
版本檔案: 維護記錄上執行之所有作業的記錄檔,並確保它們是以正確的順序執行,以防止衝突。
根據價值採用風險導向的並行控制: 根據潛在的業務風險,動態選擇適當的並行控制機制。 例如,針對低風險更新使用sagas,以及針對高風險更新使用分散式交易。
使用此模式的時機
當下列情況時,請使用此模式:
- 您必須確保分散式系統中的數據一致性,而不需要緊密結合。
- 如果序列中的某個作業失敗,您需要回復或補償。
當下列情況時,此模式可能不適合:
- 交易緊密耦合。
- 補償交易會發生在較早的參與者身上。
- 有迴圈相依性。
下一步
相關資源
當您實作此模式時,下列模式可能相關:
編舞模式 讓系統的每個元件都參與商務交易工作流程的決策程式,而不是依賴控制中心點。
補償交易模式 會撤銷一系列步驟已執行的工作,並在一個或多個步驟失敗時,最終讓整體作業達到一致狀態。 實作複雜商務程式和工作流程的雲端裝載應用程式通常會遵循此 最終一致性模型。
重試模式 可讓應用程式在嘗試連線至服務或網路資源時,藉由以透明方式重試失敗的作業來處理暫時性故障。 此模式可以改善應用程式的穩定性。
斷路器模式可用來處理當您連線到遠端服務或資源時,復原所需時間長短不一的故障。 此模式可以改善應用程式的穩定性和復原能力。
健康情況端點監視模式會在應用程式中實作功能檢查機制,讓外部工具能夠定期透過公開端點存取這些檢查。 此模式可協助您驗證應用程式和服務是否正常執行。