[發明專利]一種分布式事務處理的方法、裝置、系統和存儲介質

在審

• 申請號: 202011251444.4
• 申請日: 2020-11-10
• 公開（公告）號: CN113760566A
• 公開（公告）日: 2021-12-07
• 發明（設計）人: 李鵬程
• 申請（專利權）人: 北京沃東天駿信息技術有限公司;北京京東世紀貿易有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F16/2455;G06F16/27;G06F16/28
• 代理公司: 北京德琦知識產權代理有限公司 11018
• 代理人: 鄭紅娟;宋志強

1.一種分布式事務處理的方法，其特征在于，該方法包括：

在接收到用戶的業務請求時，第一業務系統將產生的業務數據進行保存，并將所述業務數據的狀態設置為未完成的狀態，所述業務數據為針對所述用戶的業務請求所產生的數據；

所述第一業務系統發送由消息隊列(MQ)消息體組成的業務消息，所述業務消息為針對所述用戶的業務請求所產生的需要由第二業務系統執行的消息；

所述第一業務系統接收由MQ消息體組成的業務回執時，將所述業務數據的狀態設置為已完成的狀態，所述業務回執為所述第二業務系統執行完所述業務消息后反饋的消息，所述第一業務系統和所述第二業務系統構成分布式系統。

2.根據權利要求1所述的方法，其特征在于，

所述第一業務系統發送由MQ消息體組成的業務消息的步驟包括：所述第一業務系統將由所述MQ消息體組成的業務消息發送給中間件隊列服務器，所述中間件隊列服務器將所述MQ業務放置于消息隊列中，由所述第二業務系統從所述消息隊列中獲取所述業務消息；

所述第一業務系統接收由MQ消息體組成的業務回執的步驟包括：所述第一業務系統從所述中間件隊列服務器的消息隊列中獲取所述業務回執，所述業務回執為所述第二業務系統執行完所述業務消息后發送給所述中間件隊列服務器的。

3.根據權利要求2所述的方法，其特征在于，所述第一業務系統將產生的業務數據進行保存的步驟包括：

所述第一業務系統先將產生的業務數據保存在業務數據庫中；

所述第一業務系統再將所述業務數據保存在中間件緩存服務器；

所述將業務數據的狀態設置為已完成的狀態的步驟之后，該方法進一步包括：所述第一業務系統刪除所述中間件緩存服務器中的所述業務數據。

4.根據權利要求3所述的方法，其特征在于，所述第一業務系統再將所述業務數據保存在中間件緩存服務器之后，該方法進一步包括：

根據設置的時間間隔查詢所述中間件緩存服務器中的業務數據，并判斷所述業務數據為未完成的狀態的時長是否超出預設的延遲時間閾值；

如果超出預設的延遲時間閾值，則所述第一業務系統利用遠程過程調用(RPC)接口調用所述第二業務系統，獲取所述業務消息執行結果；所述業務消息執行結果為成功時，將所述業務數據庫中的業務數據設置為已完成的狀態，且刪除所述中間件緩存服務器中的所述業務數據；所述業務消息執行結果為失敗時，將所述業務消息重新發送給所述中間件隊列服務器。

5.一種分布式事務處理的裝置，其特征在于，該裝置包括：收發模塊、存儲操作模塊和狀態設置模塊，其中：

所述收發模塊，用于接收用戶的業務請求；發送由消息隊列(MQ)消息體組成的業務消息，所述業務消息為針對所述用戶的業務請求所產生的需要由第二業務系統執行的消息；接收由MQ消息體組成的業務回執，所述業務回執為所述第二業務系統執行完所述業務消息后反饋的消息；

所述存儲操作模塊，用于將產生的業務數據進行保存，所述業務數據為針對所述用戶的業務請求所產生的數據；

所述狀態設置模塊，用于將產生的業務數據進行保存時將所述業務數據的狀態設置為未完成的狀態；在接收由MQ消息體組成的業務回執時將所述業務數據的狀態設置為已完成的狀態。

6.根據權利要求5所述的裝置，其特征在于，

所述收發模塊發送由MQ消息體組成的業務消息時用于：將由所述MQ消息體組成的業務消息發送給中間件隊列服務器，所述中間件隊列服務器將所述MQ業務放置于消息隊列中，由所述第二業務系統從所述消息隊列中獲取所述業務消息；

所述收發模塊接收由MQ消息體組成的業務回執時用于：從所述中間件隊列服務器的消息隊列中獲取所述業務回執，所述業務回執為所述第二業務系統執行完所述業務消息后發送給所述中間件隊列服務器的。

7.根據權利要求6所述的裝置，其特征在于，

所述存儲操作模塊將產生的業務數據進行保存時用于：先將產生的業務數據保存在業務數據庫中，再將所述業務數據保存在中間件緩存服務器；

所述存儲操作模塊進一步用于：將業務數據的狀態設置為已完成的狀態之后，刪除所述中間件緩存服務器中的所述業務數據。