[發明專利]事務消息處理方法、裝置、設備及系統

有效

• 申請號: 201610709666.3
• 申請日: 2016-08-23
• 公開（公告）號: CN107766080B
• 公開（公告）日: 2021-11-09
• 發明（設計）人: 姜宇
• 申請（專利權）人: 阿里巴巴集團控股有限公司
• 主分類號: G06F9/38
• 分類號: G06F9/38
• 代理公司: 北京同立鈞成知識產權代理有限公司 11205
• 代理人: 宋揚;劉芳

本申請提供一種事務消息處理方法、裝置、設備及系統。本申請的事務消息處理系統包括客戶端設備和事務協調器所在節點設備；客戶端設備確定業務消息對應的事務消息，判斷事務消息否包括回滾指示信息；若事務消息包括回滾指示信息，記錄回滾指示信息；事務協調器所在節點設備接收客戶端設備發送的事務消息對應的事務的處理結果；根據處理結果確定事務消息對應的事務是否處理成功；若事務消息對應的事務存在未處理成功的事務，則向客戶端設備發送事務回滾請求消息；客戶端設備還根據記錄的回滾指示信息對事務消息對應的事務進行回滾。本申請可提高分布式事務系統的吞吐量，提高事務處理效率。

技術領域

本申請涉及互聯網技術，尤其涉及一種事務消息處理方法、裝置、設備及系統。

背景技術

隨著網絡技術的發展，網絡中業務系統間的數據操作越來越頻繁，處于業務系統間的不同數據庫中數據的一致性。不同數據庫中數據的一致性則需使得對不同數據庫的數據操作具有原子性、一致性、隔離性以及持久性(Atomicity Consistency IsolationDurability，簡稱ACID)，即要求進行分布式事務處理，且，事務處理需在多個事務資源間實現。事務作為數據庫的最小操作單元，所有的操作要么都成功，要么都失敗。

在分布式事務系統中，為解決不同事務并發處理同一數據而發生沖突的問題，可在針對一個事務對數據進行處理的過程中，對該數據進行鎖定，以不允許其他事務對該數據進行處理，而在該一個事務處理完成后對該一個數據放鎖，繼而針對另一事務對該數據進行處理。

然而，鎖定數據進行事務處理，可使得分布式事務系統的吞吐量受到限制，從而使得事務處理效率受到限制。

發明內容

本申請提供一種事務消息處理方法、裝置、設備及系統，以提高事務處理效率。

第一方面，本申請提供一種事務消息處理系統，包括：客戶端設備和事務協調器所在節點設備；客戶端設備與事務協調器所在節點設備連接；

客戶端設備，用于確定業務消息對應的事務消息；判斷事務消息否包括回滾指示信息；若事務消息包括回滾指示信息，記錄回滾指示信息；回滾指示信息用以對事務消息對應的事務進行回滾；

事務協調器所在節點設備，用于接收客戶端設備發送的事務消息對應的事務的處理結果；根據處理結果確定事務消息對應的事務是否處理成功；若事務消息對應的事務存在未處理成功的事務，則向客戶端設備發送事務回滾請求消息；

客戶端設備，還用于根據記錄的回滾指示信息對事務消息對應的事務進行回滾。

該事務消息處理系統中客戶端設備在接收到事務協調器所在節點設備發送的事務回滾請求消息后，可根據記錄的回滾指示信息進行回滾，無需等待其他事務消息處理完成，也無需進行數據鎖定，可使得針對同一數據的事務處理可并行進行，提高分布式事務系統的吞吐量，提高事務處理效率。

第二方面，本申請提供一種事務消息處理方法，包括：

確定業務消息對應的事務消息；

判斷事務消息否包括回滾指示信息；

若事務消息包括回滾指示信息，記錄回滾指示信息；回滾指示信息用以對事務消息對應的事務進行回滾。

該方法中，可記錄事務消息包括的用以進行回滾的回滾指示信息，因而對事務消息對應的事務進行處理時，無需等待其他事務消息處理完成，也無需進行數據鎖定，可使得針對同一數據的事務處理可并行進行，提高分布式事務系統的吞吐量，提高事務處理效率。

同時，該方法可針對同一數據的事務處理并行進行，突破針對熱點數據的事務處理的性能瓶頸，提高針對熱點數據的處理效率。并且，該方法無需記錄事務處理前的數據以及處理后的數據，僅需記錄該回滾指示信息便可，因而，還可節省記錄數據的開銷。