[發明專利]一種分布式事務處理方法及裝置

有效

• 申請號: 201711486720.3
• 申請日: 2017-12-29
• 公開（公告）號: CN108279986B
• 公開（公告）日: 2023-10-03
• 發明（設計）人: 郝長久;趙貴陽;周春楠
• 申請（專利權）人: 億陽安全技術有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;H04L67/02;H04L67/566
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 王寶筠

本發明公開了一種分布式事務處理方法及裝置，包括：消息服務器在接收到第一業務端的第一提交結果后，再將第一操作數據發送給第二業務端，第二業務端才開始執行第二本地事務，這樣，將全局事務演變為了多個本地事務，每個業務端的業務的執行無需鎖定系統資源，節省了系統資源。并且，在保障全局事務一致性的前提下，當存在多個并發業務端時，提高了事務執行的效率，提高了高并發事務的容忍度。除此之外，在消息服務器中創建監控消息隊列，監控消息服務器和各個業務端之間的所有的交互信息，并將交互信息發送給相應的業務端，這樣降低了各業務端之間的耦合性，進而保障了全局事務的一致性。

技術領域

本發明涉及分布式事務領域，尤其涉及一種分布式事務處理方法及裝置。

背景技術

事務是指作為單個邏輯工作單元執行的一系列操作，要買完全的執行要么完全不執行，即要么保證全部成功，要不全部失敗，不能出現部分成功的情況。例如：通過銀行轉賬，從A賬戶轉100塊錢到B賬戶為一個事務，該事物若是提交成功，必須保證A賬戶扣除100塊錢，同時B賬戶增加100塊錢；或者由于某些原因該事物提交事變，也就是轉賬不成功，該情況下，A賬戶不能扣掉100塊錢，B賬戶也不能增加100塊錢；這樣才可以保障事務的一致性。

分布式事務是指事務的參與者、支持事務的服務器、資源服務器以及事務管理服務器分別位于不同的分布式系統的不同節點上，簡單的說，指一個事務可能涉及多個數據庫操作，分布式事務處理的關鍵是必須保證多個數據庫的操作要么都成功，要么都失敗。

針對于分布式事務，現有技術中通常采用XA協議。其中，XA協議是指由X/Open組織提出的作為資源管理器與事務管理器之間進行通信的接口標準的分布式交易處理規范。XA協議一般包括兩個階段：

第一階段：交易中間件請求所有相關數據庫準備提交(即預提交)各自的事務分支，以確認是否所有相關數據庫都可以提交各自的事務分支。當某一數據庫收到預提交后，查看是否能夠執行該提交操作，并將預提交結果記錄下來，并將預提交結果反饋給交易中間件；

第二階段：當交易中間件接收到所有的數據庫反饋的預提交結果后，若是全部都可以提交，則通知所有的數據庫執行提交，若是其中任何一個數據庫反饋的預提交結果為提交失敗時，通知其它的數據庫執行回滾的操作。

但是，所有的異構數據庫必須支持XA協議，但是不是有的數據庫都支持XA協議；并且，所有的數據庫在執行預提交操作時，需要鎖定資源管理器的資源，這樣嚴重耗費，并且在存在多個并發事務的情況下，高并發事務的容忍度低。

發明內容

有鑒于此，本發明實施例提供了一種分布式事務處理方法及裝置，解決了現有技術中，現有的方法的通用性差，耗費系統資源以及高并發事務容忍度低的問題。

本發明公開了一種分布式事務處理方法，所述方法應用于消息服務器，包括：

接收第一業務端發送的第一操作的數據；

當接收到所述第一業務端發送的第一本地事務的第一提交結果時，在所述第一提交結果為提交成功的情況下，將所述第一操作的數據發送給第二業務端；所述第二業務端包括至少一個業務端；所述第一提交結果為所述第一業務端根據所述第一操作的數據執行第一本地事務的結果；

當接收到任何一個第二業務端發送的第二本地事務的第二提交結果后，將所述第二提交結果對應的處理消息反饋給其它的第二業務端和所述第一業務端，以使所述第一業務端和其它的業務端根據所述消息執行相應的操作；所述第二提交結果為所述第二業務端根據所述第一操作的數據執行第二本地事務的結果。

可選的，在接收到第一業務端發送的第一操作的數據后，還包括：

建立監聽消息隊列，所述監聽消息隊列用于監聽所述第一業務端和所述消息服務器的交互信息，以及所述第二業務端和所述消息服務器的交互信息，并在接收到交互信息后反饋給相應的業務端。