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

在審

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

1.一種分布式服務器數據一致性方法，其特征在于，預先在交易程序中建立交易開始注解及事務開始注解，其中，交易程序中包括多個事務，所述方法包括：

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

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

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

2.如權利要求1所述的方法，其特征在于，通過交易程序中的交易開始注解識別交易開始，包括：

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

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

3.如權利要求1所述的方法，其特征在于，通過事務開始注解識別單個事務開始，包括：

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

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

4.如權利要求1所述的方法，其特征在于，接收回退指令，發起回退操作，包括：

根據回退指令中的事務ID，確定事務開始注解，從事務開始注解中獲取回退操作的方法名稱；

根據回退操作的方法名稱，確定回退操作方法的地址；

根據回退操作方法的方法及地址，發起回退操作。

5.如權利要求1所述的方法，其特征在于，通過事務開始注解識別事務開始的同時，還從事務開始注解中獲取回退操作的方法名稱，根據回退操作的方法名稱，確定回退操作方法的地址，將回退操作的名稱及地址存儲于數據庫中；

接收回退指令，發起回退操作，包括：根據回退指令中的事務ID，從數據庫中獲取回退操作的名稱及地址；根據獲取的回退操作名稱及地址，發起回退操作。

6.一種分布式服務器數據一致性的方法，其特征在于，包括：

接收全局ID，并建立全局ID的隊列；

接收事務信息，事務信息包括事務ID、全局ID及事務調用狀態；

于事務調用狀態為結束時記錄事務ID至相應全局ID隊列中，若事務調用狀態為失敗時，根據全局ID隊列中所有已完成事務ID隊列，生成回退指令。

7.一種分布式協調器，其特征在于，預先在交易程序中建立交易開始注解及事務開始注解，其中，交易程序中包括多個事務，包括：

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

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

回退模塊，用于接收回退指令，發起回退操作。

8.如權利要求7所述的協調器，其特征在于，第一識別模塊通過交易程序中的交易開始注解識別交易開始，包括：

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

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

9.如權利要求7所述的協調器，其特征在于，第二識別模塊通過事務開始注解識別單個事務開始，包括：

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

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