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

在審

• 申請號: 201710521704.7
• 申請日: 2017-06-30
• 公開（公告）號: CN107332906A
• 公開（公告）日: 2017-11-07
• 發明（設計）人: 郭濤
• 申請（專利權）人: 鄭州云海信息技術有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;G06F17/30
• 代理公司: 北京集佳知識產權代理有限公司11227
• 代理人: 羅滿

1.一種分布式系統事務管理方法，其特征在于，包括：

在接收到主動方節點發送的消息時，對消息進行存儲并將消息狀態標記為待確認，并向所述主動方節點發送所述消息的存儲結果；

在接收到所述主動方節點發送的已開始執行業務操作的指示消息時，將消息狀態更新為待發送，所述主動方節點在接收到所述存儲結果并且所述存儲結果為存儲成功時開始執行業務操作；

在所述主動方節點執行完業務操作后，當接收到所述主動方節點返回的業務操作結果時，若所述業務操作結果為業務處理成功，則將所述消息發送給被動方節點，并將消息狀態更新為已發送；

在所述被動方節點接收到所述消息，執行完業務操作后，當所述被動方節點返回的業務操作結果為業務處理失敗時，則將該業務操作結果發送給所述主動方節點，以指示所述主動方節點進行回滾操作。

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

對所述主動方節點與所述被動方節點之間進行調用的調用信息保存，并將所述調用信息展示給用戶；

將存儲的所述消息、接收到的所述指示消息、接收到的主動方節點的業務操作結果以及被動方節點的業務操作結果展示給用戶，并可由用戶根據展示信息進行人為管理各類消息以及干預調用事務。

3.根據權利要求1所述的分布式系統事務管理方法，其特征在于，還包括：查詢消息狀態為待發送的消息的存儲時長，若存儲時長超過第一閾值，則將存儲的所述消息刪除。

4.根據權利要求3所述的分布式系統事務管理方法，其特征在于，還包括：查詢消息狀態為已發送的消息的存儲時長，若存儲時長已超過第二閾值，但未收到所述被動方節點返回的業務操作結果，則將所述消息重新發送給所述被動方節點。

5.根據權利要求1-4任一項所述的分布式系統事務管理方法，其特征在于，還包括：當監測到出現未預知的問題阻斷事務進行時，以預設方式恢復事務。

6.一種分布式系統事務管理裝置，其特征在于，包括：

消息存儲模塊，用于在接收到主動方節點發送的消息時，對消息進行存儲；

消息狀態標記模塊，用于在接收到主動方節點發送的所述消息時，將消息狀態標記為待確認，并在接收到所述主動方節點發送的已開始執行業務操作的指示消息時，將消息狀態更新為待發送，所述主動方節點在接收到存儲結果并且所述存儲結果為存儲成功時開始執行業務操作；還用于在所述主動方節點執行完業務操作后，當接收到所述主動方節點返回的業務操作結果時，若所述業務操作結果為業務處理成功，則將所述消息發送給被動方節點，并將消息狀態更新為已發送；

消息處理模塊，用于在對所述消息存儲后，向所述主動方節點發送所述消息的存儲結果，并在所述主動方節點執行完業務操作后，當接收到所述主動方節點返回的業務操作結果時，若所述業務操作結果為業務處理成功，則將所述消息發送給被動方節點；還用于在所述被動方節點接收到所述消息，執行完業務操作后，當所述被動方節點返回的業務操作結果為業務處理失敗時，則將該業務操作結果發送給所述主動方節點，以指示所述主動方節點進行回滾操作。

7.根據權利要求6所述的分布式系統事務管理裝置，其特征在于，還包括：

數據庫，用于對所述主動方節點與所述被動方節點之間進行調用的調用信息保存；

控制臺，用于對所述主動方節點與所述被動方節點之間進行調用的調用信息展示給用戶，還用于將存儲的所述消息、接收到的所述指示消息、接收到的主動方節點的業務操作結果以及被動方節點的業務操作結果展示給用戶，并可由用戶根據展示信息進行人為管理各類消息以及干預調用事務。

8.根據權利要求6所述的分布式系統事務管理裝置，其特征在于，還包括：

消息查詢模塊，用于查詢消息狀態為待發送的消息的存儲時長，若存儲時長超過第一閾值，則將存儲的所述消息刪除。

9.根據權利要求8所述的分布式系統事務管理裝置，其特征在于，所述消息查詢模塊還用于查詢消息狀態為已發送的消息的存儲時長，若存儲時長已超過第二閾值，但未收到所述被動方節點返回的業務操作結果，則將所述消息重新發送給所述被動方節點。

10.根據權利要求6-9任一項所述的分布式系統事務管理裝置，其特征在于，還包括：

事務恢復模塊，用于當監測到出現未預知的問題阻斷事務進行時，以預設方式恢復事務。