[發明專利]一種基于消息落庫的MQ消息可靠性投遞解決方法

在審

• 申請號: 202011623035.2
• 申請日: 2020-12-30
• 公開（公告）號: CN112698969A
• 公開（公告）日: 2021-04-23
• 發明（設計）人: 胡樂成;曾繁陽
• 申請（專利權）人: 佰年頤堂醫療科技股份有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F9/46
• 代理公司: 北京八月瓜知識產權代理有限公司 11543
• 代理人: 李斌

1.一種基于消息落庫的MQ消息可靠性投遞解決方法，其特征在于，包括業務系統和消息服務器，通過消息信息落庫，對消息信息狀態進行打標，具體步驟如下：

步驟1：業務系統在事務內，進行業務數據入庫和消息數據入庫，此時消息數據入庫的狀態為：未成功；

步驟2：在步驟1中業務數據入庫成功的前提下，消息發送者向消息服務器發送消息并完成消息持久化；

步驟3：消息服務器收到消息后，發送確認收到消息通知；

步驟4：生產者收到消息服務器發送的確認收到消息通知后，修改消息數據庫中消息數據入庫狀態為：成功；

步驟5：布置分布式定時任務，查詢數據庫中消息數據入庫狀態為未成功且允許進行重試的數據；

步驟6：重新發送上一步中檢索出來的隊列消息給消息發送者；

步驟7：通過分布式定時任務，查詢當前重試次數大于N的數據，修改該消息數據入庫的狀態為：發送失敗。

2.根據權利要求1所述的一種基于消息落庫的MQ消息可靠性投遞解決方法，其特征在于：還包括消息補償表，消息補償表包括流水號、消息主題、消息標簽、業務key值、異常信息、消息投遞狀態0∶未成功；1∶成功；2∶失敗、重試次數、允許進行重試的開始時間、創建時間和更新時間，步驟5中，通過消息補償表中的允許進行重試的開始時間的記錄值來判斷是否允許進行重試。

3.根據權利要求2所述的一種基于消息落庫的MQ消息可靠性投遞解決方法，其特征在于：步驟7中，通過消息補償表的重試次數的記錄值來查找當前重試次數大于N的數據。

4.根據權利要求3所述的一種基于消息落庫的MQ消息可靠性投遞解決方法，其特征在于：步驟2中，消息發送者向消息服務器發送消息后，消息服務器將消息發送給消息消費者，消息消費者執行業務處理，然后將信息反饋給消息服務器。