[發明專利]一種分布式系統業務數據一致性處理方法、裝置

在審

• 申請號: 202110483789.0
• 申請日: 2021-04-30
• 公開（公告）號: CN113177052A
• 公開（公告）日: 2021-07-27
• 發明（設計）人: 朱浩斌;鄒昌宏;周思來;張建亮;孫傳興
• 申請（專利權）人: 中國建設銀行股份有限公司
• 主分類號: G06F16/23
• 分類號: G06F16/23;G06F16/27;G06F9/448;G06F9/54
• 代理公司: 北京三友知識產權代理有限公司 11127
• 代理人: 賈磊;李輝

1.一種分布式系統業務數據一致性處理方法，其特征在于包括，

根據業務的需求，產生至少一個子服務調用請求發送給相應的子服務提供系統；

根據所述子服務提供系統反饋的服務執行結果進行第一一致性處理，并將所述第一一致性處理后所述子服務調用請求的狀態記錄于本地服務執行歷史表中；

對所述本地服務執行歷史表中經過所述第一一致性處理的處于第一特定狀態的子服務調用請求進行第二一致性處理，并根據所述子服務提供系統的服務執行結果更新所述本地服務執行歷史表中子服務調用請求的狀態；

對所述本地服務執行歷史表中處于第二特定狀態的子服務調用請求進行第三一致性處理；

返回所述第一一致性處理步驟，接收所述子服務提供系統根據所述第三一致性處理反饋的服務執行結果。

2.根據權利要求1所述的方法，其特征在于，產生至少一個子服務調用請求發送給相應的子服務提供系統中進一步包括，所述子服務調用請求包括唯一標識符。

3.根據權利要求1所述的方法，其特征在于，所述服務執行結果中包括，所述子服務調用請求被執行成功的成功狀態，以及所述子服務調用請求被執行失敗的失敗狀態。

4.根據權利要求3所述的方法，其特征在于，所述第一一致性處理包括，

將成功狀態的子服務調用請求記錄于所述本地服務執行歷史表中，并結束；

將失敗狀態的子服務調用請求記錄于所述本地服務執行歷史表中，并向相應的子服務提供系統重發所述子服務調用請求，接收所述子服務提供系統反饋的服務執行結果；

如果超過預定時間所述子服務提供系統未反饋服務執行結果，則將所述子服務調用請求為超時狀態記錄于所述本地服務執行歷史表中。

5.根據權利要求4所述的方法，其特征在于，在向相應的子服務提供系統重發所述子服務調用請求，接收所述子服務提供系統反饋的服務執行結果中進一步包括，

計算重發所述子服務調用請求的時間，如果超過了第一時間門限，所述子服務調用請求的狀態為失敗狀態，則報錯退出。

6.根據權利要求5所述的方法，其特征在于，在所述報錯退出之中還包括，

向與造成報錯退出的子服務調用請求相關聯的其他子服務調用請求對應的子服務提供系統發送反向子服務調用請求，使得所述對應的子服務提供系統執行反向子服務調用請求回滾已經執行成功的子服務調用請求。

7.根據權利要求1所述的方法，其特征在于，對所述本地服務執行歷史表中經過所述第一一致性處理的處于第一特定狀態的子服務調用請求進行第二一致性處理中進一步包括，

對所述本地服務執行歷史表中狀態為超時狀態的子服務調用請求生成查詢請求；

向相應的子服務提供系統發送所述查詢請求；

接收所述相應的子服務提供系統反饋的服務執行結果。

8.根據權利要求7所述的方法，其特征在于，接收所述相應的子服務提供系統反饋的服務執行結果中進一步包括，

如果在第二時間門限內未接收到所述相應的子服務提供系統反饋的服務執行結果，則所述本地服務執行歷史表中狀態為超時狀態的子服務調用請求依然為超時狀態，并向所述相應的子服務提供系統重發所述查詢請求；

當到達第三時間門限為止始終未收到所述相應的子服務提供系統反饋的服務執行結果，則報錯退出。

9.根據權利要求1所述的方法，其特征在于，對所述本地服務執行歷史表中處于第二特定狀態的子服務調用請求進行第三一致性處理中進一步包括，

讀取所述本地服務執行歷史表中狀態為超時狀態或失敗狀態的子服務調用請求；

將讀取出來的子服務調用請求發送到消息隊列；

所述子服務提供系統獲取所述消息隊列中的子服務調用請求；

所述子服務提供系統執行所述子服務調用請求；

接收所述子服務提供系統的服務執行結果。