[發明專利]一種數據一致性方法、分布式協調器及中央協調器

在審

• 申請號: 201911415793.2
• 申請日: 2019-12-31
• 公開（公告）號: CN111143041A
• 公開（公告）日: 2020-05-12
• 發明（設計）人: 戴翔;高芳;吳嘉杰;謝立治
• 申請（專利權）人: 中國銀行股份有限公司
• 主分類號: G06F9/46
• 分類號: G06F9/46;G06F9/54;H04L29/08
• 代理公司: 北京三友知識產權代理有限公司 11127
• 代理人: 許曼;薛平

本發明提供了一種數據一致性方法、分布式協調器及中央協調器，其中，數據一致性方法包括：通過交易程序中的交易開始注解識別交易開始，當交易開始時，創立全局ID并將其發送至中央協調器，由中央協調器建立全局ID隊列；通過事務開始注解識別事務開始，事務開始時，創立事務信息并將其發送至中央協調器，其中，事務信息包括：事務ID、全局ID及事務調用狀態，由中央協調器于事務調用狀態為結束時記錄事務ID至相應全局ID隊列中，若事務調用狀態為失敗時，根據相應全局ID隊列中所有已完成事務ID隊列生成回退指令；接收回退指令，發起回退操作。本發明能夠實現分布式服務器數據的一致性。

技術領域

本發明涉及分布式服務器領域，尤其涉及一種分布式服務器數據一致性方法、分布式協調器及中央協調器。

背景技術

現有技術中分布式服務器數據的統一主要通過如下兩種方式實現：1)兩階段提交(2PC)，其使用的原理為XA協議原理(是X/Open組織為分布式事務處理制定的標準協議)。2)補償事務(TCC)，TCC即采用補償機制，針對每個操作，都要注冊一個與其對應的確認和補償(撤銷)操作，共分為三個階段：Try階段主要是對業務系統做檢測及資源預留；Confirm階段主要是對業務系統做確認提交，Try階段執行成功并開始執行Confirm階段時，默認Confirm階段是不會出錯的。即：只要Try成功，Confirm一定成功；Cancel階段主要是在業務執行錯誤，需要回滾的狀態下執行的業務取消，預留資源釋放。

對于上述2PC而言，存在如下缺陷：1)阻塞。對于任何一次指令必須收到明確的響應，才會繼續做下一步，否則處于阻塞狀態，占用的資源被一直鎖定，不會被釋放。2)單點故障。如果協調者宕機，參與者沒有協調者指揮，會一直阻塞，盡管可以通過選舉新的協調者替代原有協調者，但是如果之前協調者在發送一個提交指令后宕機，而提交指令僅僅被一個參與者接收，并且參與者接收后也宕機，新上任的協調者無法處理這種情況。3)腦裂。協調者發送提交指令，有的參與者接收到執行了事務，有的參與者沒有接收到事務，就沒有執行事務，多個參與者之間是不一致的。4)跨系統調用：沒有良好的解決方案。

對于上述TCC而言，存在如下缺陷：1)需要修改原來的業務邏輯。2)通信次數較多。

發明內容

為了解決現有技術中的分布式服務器數據一致性方法存在信息閉塞、單點故障、需要修改業務邏輯及通信次數較多的缺陷，本發明的第一方面提供一種分布式服務器數據一致性的方法，適用于分布式協調器，預先在交易程序中建立交易開始注解及事務開始注解，其中，交易程序中包括多個事務，所述方法包括：

通過交易程序中的交易開始注解識別交易開始，當交易開始時，創立全局ID并將其發送至中央協調器，由中央協調器建立全局ID隊列；

通過事務開始注解識別事務開始，事務開始時，創立事務信息并將其發送至中央協調器，其中，事務信息包括：事務ID、全局ID及事務調用狀態，由中央協調器于事務調用狀態為結束時記錄事務ID至相應全局ID隊列中，若事務調用狀態為失敗時，根據相應全局ID隊列中所有已完成事務ID隊列生成回退指令；

接收回退指令，發起回退操作。

進一步實施例中，通過交易程序中的交易開始注解識別交易開始，包括：

通過SpringAop對交易程序中的交易開始注解進行攔截；

攔截到交易開始注解時，確定交易開始。

進一步實施例中，通過事務開始注解識別單個事務開始，包括：

通過SpringAop對事務開始注解進行攔截；

攔截到事務開始注解時，確定事務開始。

進一步實施例中，接收回退指令，發起回退操作，包括：