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

在審

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

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

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

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

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

2.如權利要求1所述的方法，其特征在于，根據所述消息推送狀態表中消息推送狀態，將所述消息推送狀態為推送失敗狀態的消息推送至所述消息隊列，包括：

按照預設定時周期，定時遍歷所述消息推送狀態表中的消息推送狀態；

在遍歷到所述消息推送狀態為推送失敗狀態的消息時，將所述消息推送狀態為推送失敗狀態的消息推送至所述消息隊列。

3.如權利要求1所述的方法，其特征在于，所述消息包括消息內容和消息標識，所述方法還包括：將所述消息內容和所述消息標識記錄至所述預先構建的消息推送狀態表中。

4.如權利要求3所述的方法，其特征在于，所述將消息投遞信息記錄至預先建立的消息接收狀態表中，包括：

將所述消息的消息標識和消息內容記錄至所述預先建立的消息接收狀態表中。

5.如權利要求4所述的方法，其特征在于，所述第二用戶根據所述消息接收狀態表消費消息，包括：

根據所述消息接收狀態表中的消息標識，判斷所述消息隊列投遞的消息是否為重復投遞消息；

若為重復投遞消息，則在消費所述重復投遞消息中的一條消息后，將所述重復投遞消息從所述消息隊列中刪除。

6.一種分布式事務處理裝置，其特征在于，包括：

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

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

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

7.如權利要求6所述的裝置，其特征在于，所述推送模塊，包括：

遍歷單元，用于按照預設定時周期，定時遍歷所述消息推送狀態表中的消息推送狀態；

推送單元，用于在遍歷到所述消息推送狀態為推送失敗狀態的消息時，將所述消息推送狀態為推送失敗狀態的消息推送至所述消息隊列。

8.如權利要求6所述的裝置，其特征在于，所述消息包括消息內容和消息標識，所述裝置還包括：記錄模塊，用于將所述消息內容和所述消息標識記錄至所述預先構建的消息推送狀態表中。

9.一種電子設備，其特征在于，包括：存儲器、處理器及存儲在所在存儲器上并可在所述處理器上運行的計算機程序，所述計算機程序被所述處理器執行時實現如權利要求1至5中任一項所述的分布式事務處理方法的步驟。

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