[發明專利]分布式事務處理方法及分布式系統

有效

• 申請號: 201810204077.9
• 申請日: 2018-03-13
• 公開（公告）號: CN108491252B
• 公開（公告）日: 2022-03-22
• 發明（設計）人: 紀少聰
• 申請（專利權）人: 萬惠投資管理有限公司
• 主分類號: G06F9/46
• 分類號: G06F9/46
• 代理公司: 北京超凡志成知識產權代理事務所(普通合伙) 11371
• 代理人: 鄧超

1.一種分布式事務處理方法，其特征在于，應用于分布式系統，所述分布式系統包括相互通信的協調子系統、管理子系統及執行子系統；所述分布式事務處理方法包括：

所述協調子系統向所述管理子系統發送事務標識申請，以獲取目標事務標識，并向所述執行子系統發送帶有所述目標事務標識的執行請求；

判斷所述執行請求對應的需要操作的數據是否具有帶有唯一標識符的緩存數據；若所述執行請求對應的需要操作的數據不具有帶有所述唯一標識符的緩存數據，則執行步驟執行所述執行請求對應的事務；若所述執行請求對應的需要操作的數據具有帶有所述唯一標識符的緩存數據，判斷所述唯一標識符的緩存數據對應的事務狀態是否為結果狀態；若所述事務狀態為結果狀態，根據該事務狀態的當前值對該事務狀態對應的所述緩存數據進行提交或回滾操作；

所述執行子系統接收到所述執行請求后，執行所述執行請求對應的事務；

所述執行子系統在對所述執行請求對應的數據進行修改時，對修改的數據進行緩存得到所述緩存數據，包括：對所述修改的數據使用與所述目標事務標識對應的唯一標識符進行標記，將標記的數據進行緩存得到所述緩存數據；

所述執行子系統將執行結果返回給所述協調子系統；

所述協調子系統根據每個執行子系統執行結果向所述管理子系統發送所述目標事務標識對應的事務狀態的更改請求，以將所述事務狀態更改為所述結果狀態，所述結果狀態包括成功和失敗；

所述執行子系統從所述管理子系統中獲取所述事務狀態，根據所述事務狀態的當前值對該事務狀態對應的所述緩存數據進行提交或回滾操作。

2.如權利要求1所述的分布式事務處理方法，其特征在于，所述方法還包括：

所述執行子系統按照預設時間周期檢測管理子系統中的事務狀態為結果狀態的事務；

若所述管理子系統中存在有事務狀態為結果狀態，根據該事務狀態的當前值對該事務狀態對應的所述緩存數據進行提交或回滾操作。

3.如權利要求1所述的分布式事務處理方法，其特征在于，所述執行子系統在對所述執行請求對應的數據進行修改時，對修改的數據進行緩存得到緩存數據的步驟之前，包括：

判斷需要被緩存的數據是否被目標事務標識對應的唯一標識符標記并緩存；

當該數據不具有緩存時，再執行步驟執行子系統在判斷有修改數據動作時，對修改的數據進行緩存得到緩存數據。

4.如權利要求1所述的分布式事務處理方法，其特征在于，所述方法還包括：

所述管理子系統根據所述事務標識申請生成所述目標事務標識時，初始化該目標事務標識對應的事務狀態為執行中及保存事務創建時間；

所述管理子系統檢測所述目標事務標識對應的事務狀態為執行中的時長是否超過預設時長，若該事務狀態為執行中的時長超過預設時長，將該事務狀態修改為失敗。

5.如權利要求1所述的分布式事務處理方法，其特征在于，在所述執行子系統在對所述執行請求對應的數據進行修改時，對修改的數據進行緩存得到緩存數據之前，所述方法還包括：

對修改的數據使用鎖定碼進行鎖定。

6.如權利要求1所述的分布式事務處理方法，其特征在于，所述執行子系統從所述管理子系統中獲取所述事務狀態，根據所述事務狀態的當前值對該事務狀態對應的所述緩存數據進行提交或回滾操作的步驟之前，所述方法還包括：

對所述緩存數據進行提交或回滾操作對應的事務使用鎖定碼進行鎖定。

7.一種分布式系統，其特征在于，所述分布式系統包括相互通信的協調子系統、管理子系統及執行子系統；

所述協調子系統用于向所述管理子系統發送事務標識申請，以獲取目標事務標識，并向所述執行子系統發送帶有所述目標事務標識的執行請求；

所述執行子系統用于判斷所述執行請求對應的需要操作的數據是否具有帶有唯一標識符的緩存數據；若所述執行請求對應的需要操作的數據不具有帶有所述唯一標識符的緩存數據，則執行步驟執行所述執行請求對應的事務；若所述執行請求對應的需要操作的數據具有帶有所述唯一標識符的緩存數據，判斷所述唯一標識符的緩存數據對應的事務狀態是否為結果狀態；若所述事務狀態為結果狀態，根據該事務狀態的當前值對該事務狀態對應的所述緩存數據進行提交或回滾操作；

所述執行子系統還用于接收到所述執行請求后，執行所述執行請求對應的事務；

所述執行子系統還用于在對所述執行請求對應的數據進行修改時，對修改的數據進行緩存得到所述緩存數據，包括：對所述修改的數據使用與所述目標事務標識對應的唯一標識符進行標記，將標記的數據進行緩存得到所述緩存數據；

所述執行子系統還用于將執行結果返回給所述協調子系統；

所述協調子系統還用于根據每個執行子系統執行結果向所述管理子系統發送所述目標事務標識對應的事務狀態的更改請求，以將所述事務狀態更改為所述結果狀態，所述結果狀態包括成功和失敗；以及

所述執行子系統用于從所述管理子系統中獲取所述事務狀態，根據所述事務狀態的當前值對該事務狀態對應的所述緩存數據進行提交或回滾操作。