[發明專利]事務處理方法、裝置、設備及計算機可讀存儲介質

在審

• 申請號: 202010532989.6
• 申請日: 2020-06-12
• 公開（公告）號: CN111708617A
• 公開（公告）日: 2020-09-25
• 發明（設計）人: 王中慰;左明德;陳天濤;孫澤輝
• 申請（專利權）人: 京東數字科技控股有限公司
• 主分類號: G06F9/46
• 分類號: G06F9/46
• 代理公司: 北京同立鈞成知識產權代理有限公司 11205
• 代理人: 柴海平;劉芳

1.一種事務處理方法，其特征在于，包括：

在開啟本地事務后，生成所述本地事務的消息記錄，并將所述消息記錄保存到對應的業務數據庫中，所述消息記錄至少包括所述本地事務對應的業務通用唯一標識、待發送的消息和消息狀態；

注冊Spring事務事件；

響應于監聽到事務成功事件，進行事務提交，發送所述消息。

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

若所述消息發送成功，則將所述消息記錄中的消息狀態由第一狀態更新為第二狀態，所述第一狀態用于表示消息尚未發送，所述第二狀態用于表示消息發送成功；

若所述消息發送失敗，則將所述消息記錄中的消息狀態由第一狀態更新為第三狀態，所述第三狀態用于表示消息發送失敗。

3.根據權利要求2所述的方法，其特征在于，所述生成所述本地事務的消息記錄之后，還包括：

將所述消息記錄同步到狀態查詢服務對應的中心數據庫中；

將所述消息記錄中的消息狀態由第一狀態更新為第二狀態之后，還包括：

同步更新所述中心數據庫上的所述消息記錄。

4.根據權利要求3所述的方法，其特征在于，還包括：

接收所述狀態查詢服務的回調請求，所述回調請求為所述狀態查詢服務根據所述中心數據庫內消息記錄中的消息狀態發出的；

根據所述回調請求中的事務標識，查詢所述業務數據庫中的目標記錄，所述目標記錄為包含所述事務標識的消息記錄；

根據所述目標記錄中的消息狀態，進行對應的異常處理。

5.根據權利要求4所述的方法，其特征在于，根據所述目標記錄中的消息狀態，進行對應的異常處理，包括：

若所述目標記錄中的消息狀態為第一狀態或第三狀態，則重新執行所述本地事務。

6.根據權利要求4所述的方法，其特征在于，根據所述目標記錄中的消息狀態，進行對應的異常處理，包括：

若所述目標記錄中的消息狀態為第二狀態，則同將所述狀態查詢服務上所述目標記錄中的消息狀態更新為第二狀態。

7.根據權利要求1-6中任一項所述的方法，其特征在于，所述消息記錄保存在所述業務數據庫中的本地事務表中。

8.根據權利要求1-6中任一項所述的方法，其特征在于，在開啟本地事務后，生成所述本地事務的消息記錄之前，還包括：

獲取對應數據源。

9.根據權利要求1-6中任一項所述的方法，其特征在于，將所述消息記錄保存到對應業務數據庫中之后，還包括：

同步更新中心數據庫上的所述消息記錄。

10.一種事務處理方法，其特征在于，應用于分布式事務系統中一個業務系統的消息組件，所述消息組件與用于執行本地事務的業務服務運行于同一進程中，所述方法包括：

在在開啟本地事務后，生成所述本地事務的消息記錄，并將所述消息記錄保存到對應的業務數據庫中，所述消息記錄至少包括所述本地事務對應的業務通用唯一標識、待發送的消息和消息狀態；

注冊Spring事務事件；

響應于監聽到事務成功事件，進行事務提交，發送所述消息。

11.一種事務處理裝置，其特征在于，包括：

消息記錄模塊，用于在開啟本地事務后，生成所述本地事務的消息記錄，并將所述消息記錄保存到對應的業務數據庫中，所述消息記錄至少包括所述本地事務對應的業務通用唯一標識、待發送的消息和消息狀態；

事務處理模塊，用于：注冊Spring事務事件；響應于監聽到事務成功事件，進行事務提交，發送所述消息。