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

在審

• 申請號: 202010485956.0
• 申請日: 2020-06-01
• 公開（公告）號: CN111897825A
• 公開（公告）日: 2020-11-06
• 發明（設計）人: 楊猛;張娜;歐創新;孟慶峰;于灝;劉震;潘曦;馬南;劉皓
• 申請（專利權）人: 中國人民財產保險股份有限公司
• 主分類號: G06F16/23
• 分類號: G06F16/23;G06F16/27;G06Q40/08
• 代理公司: 北京國昊天誠知識產權代理有限公司 11315
• 代理人: 李瀟

本說明書實施例公開了一種分布式事務處理方法、裝置、電子設備以及計算機可讀存儲介質。該方法包括：第一用戶將生產的消息推送至消息隊列中，并將消息推送狀態記錄至預先建立的消息推送狀態表中；根據消息推送狀態表中消息推送狀態，將消息推送狀態為推送失敗狀態的消息推送至消息隊列；通過消息隊列，將推送至消息隊列的消息投遞至第二用戶，并將消息投遞信息記錄至預先建立的消息接收狀態表中，以使第二用戶根據所述消息接收狀態表消費消息。

技術領域

本說明書實施例涉及計算機技術領域，尤其涉及分布式事務處理方法、裝置、電子設備和計算機可讀存儲介質。

背景技術

目前云計算、大數據、互聯網領域的很多業務系統都采用了分布式架構。在一致性要求較高的分布式架構中，分布式事務成為關鍵點。目前主流的分布式事務解決方案主要包括：兩階段XA方案、補償方案(例如，Try-Confirm-Cancel，TCC方案)以及基于異步確保的消息隊列方案等。其中，消息隊列方案，由于開發成本相對較低、應用場景較廣被廣泛采用，但采用消息隊列方案，要求確保消息冪等性和消息一致性。

研究人員發現，有些消息隊列技術采用確認機制來保證消息的發送和接收，這種機制在網絡異常、生產者和/或消費者異常等情況下，可能會出現生產者發送消息失敗、生成者重復生產消息、消費者重復消費消息等特殊情況。也有些消息隊列技術提供事務消息機制，即可實現消息事務與本地事務的同時提交或回滾，但事務消息機制無法解決因本地事務失敗或消息事務失敗等特殊情況而造成的分布式事務中消息不一致的問題。

如何在這些特殊情況下，確保消息冪等性和消息一致性是本領域技術人員需要解決的。

發明內容

本說明書實施例提供一種分布式事務處理方法、裝置、電子設備以及計算機可讀存儲介質，以解決在一些特殊情況下如何確保分布式事務中消息冪等性和消息一致性的問題。

本說明書實施例采用下述技術方案：

一種分布式事務處理方法，包括：

第一用戶將生產的消息推送至消息隊列中，并將消息推送狀態記錄至預先建立的消息推送狀態表中；

根據所述消息推送狀態表中消息推送狀態，將消息推送狀態為推送失敗狀態的消息推送至所述消息隊列；

通過所述消息隊列，將推送至所述消息隊列的消息投遞至第二用戶，并將消息投遞信息記錄至預先建立的消息接收狀態表中，以使所述第二用戶根據所述消息接收狀態表消費消息。

一種分布式事務處理裝置，包括：

推送記錄模塊，用于第一用戶將生產的消息推送至消息隊列中，并將消息推送狀態記錄至預先建立的消息推送狀態表中；

推送模塊，用于根據所述消息推送狀態表中消息推送狀態，將消息推送狀態為推送失敗狀態的消息推送至所述消息隊列；

投遞記錄模塊，用于通過所述消息隊列，將推送至所述消息隊列的消息投遞至第二用戶，并將消息投遞信息記錄至預先建立的消息接收狀態表中，以使所述第二用戶根據所述消息接收狀態表消費消息。

一種電子設備，包括：存儲器、處理器及存儲在所在存儲器上并可在所述處理器上運行的計算機程序，所述計算機程序被所述處理器執行時實現任一項所述的分布式事務處理方法的步驟。

一種計算機可讀存儲介質，其特征在于，所述計算機可讀存儲介質上存儲有計算機程序，所述計算機程序被處理器執行時實現任一項所述的分布式事務處理方法的步驟。

本說明書實施例采用的上述至少一個技術方案能夠達到以下有益效果：