[發明專利]分布式事務處理方法

有效

• 申請號: 201710043404.2
• 申請日: 2017-01-21
• 公開（公告）號: CN106874076B
• 公開（公告）日: 2019-08-30
• 發明（設計）人: 張元康
• 申請（專利權）人: 浙江沛宏網絡科技有限公司
• 主分類號: G06F9/46
• 分類號: G06F9/46;G06F16/23
• 代理公司: 北京維正專利代理有限公司 11508
• 代理人: 林樂飛

1.一種分布式事務處理方法,其特征是，包括：

多個事務處理節點中的其中一個事務處理節點接收事務啟動請求，并將與所述事務啟動請求對應的事務劃分為若干子事務；

所述其中一個事務處理節點執行預定的其中一個子事務，并將其余的子事務寫入到本地數據庫；

所述其中一個事務處理節點在執行完子事務后，查詢本地數據庫中的子事務，并將本地數據庫中的子事務發布至消息隊列，并在發布后從本地數據庫中刪除相應的子事務；

所述消息隊列向其余的事務處理節點推送子事務，并在從其余的事務處理節點接收到成功標識后，從隊列中刪除相應的子事務；

所述其余的事務處理節點在接收到相應的子事務后，將子事務寫入各自的本地數據庫；

所述其余的事務處理節點從各自的本地數據庫中獲取并執行相應的子事務，并在執行完成后，從本地數據庫中刪除相應的子事務。

2.根據權利要求1所述的服務器業務處理方法，其特征是，所述消息隊列采用RabbitMQ消息隊列。

3.根據權利要求1所述的服務器業務處理方法，其特征是，所述其中一個事務處理節點在成功執行相應的子事務后，向消息隊列發送確認消息；消息隊列接收到確認消息后，消息隊列向其余的事務處理節點推送子事務；所述其中一個事務處理節點在未成功執行相應的子事務時，向消息隊列發送取消消息；消息隊列接收到取消消息后，消息隊列不向其余的事務處理節點推送子事務。

4.根據權利要求3所述的服務器業務處理方法，其特征是，還包括：消息狀態確認服務器查詢消息隊列中的子事務，若存在未確認或被取消的子事務，則查詢所述其中一個事務處理節點中對應子事務的消息狀態，若對應的消息狀態已被確認，則向消息隊列發送確認消息。

5.根據權利要求1所述的服務器業務處理方法，其特征是，還包括：

所述其余事務處理節點在處理完相應的子事務后，將該子事務寫入到各自的事務狀態表；

當所述其余事務處理節點從消息隊列接收到子事務時，查詢該事務狀態表，若已存在，則不將接收到的子事務寫入到本地數據庫；若不存在，則寫入到本地數據庫以待處理。

6.根據權利要求1所述的服務器業務處理方法，其特征是，還包括：

所述其中一個事務處理節點在對事務進行劃分時，從標識處理服務器獲取包含有若干唯一標識的唯一標識串，并將其中的唯一標識一一對應地添加至每一子事務；當相應的事務處理節點在執行完相應的子事務后，將該唯一標識發送至標識處理服務器；

該標識處理服務器在發出唯一標識串的預定時間后，查詢相應的唯一標識的接收狀態；若存在至少一個唯一標識未被接收，則查詢相應的事務處理節點，并根據查詢結果進行相應的處理。

7.根據權利要求6所述的服務器業務處理方法，其特征是，所述標識處理服務器記錄查詢結果，當在同一事務處理節點查詢到唯一標識的次數超過預設值時，則將該事務處理節點的信息發送至監視服務器；所述監視服務器在接收到相應的信息后，從備用的事務處理節點庫中調取相應的事務處理節點進行替換。