[發明專利]消息隊列系統以及基于消息隊列系統的消息處理方法

在審

• 申請號: 202010583137.X
• 申請日: 2020-06-23
• 公開（公告）號: CN111949497A
• 公開（公告）日: 2020-11-17
• 發明（設計）人: 陳光明
• 申請（專利權）人: 貝殼技術有限公司
• 主分類號: G06F11/34
• 分類號: G06F11/34
• 代理公司: 北京路浩知識產權代理有限公司 11002
• 代理人: 楊云云

1.一種基于消息隊列系統的消息處理方法，其特征在于，所述消息隊列系統包括生產端、消費端以及監聽端；所述消息處理方法包括：

在生產端和消費端中注冊與事件對應的鉤子函數；

當所述生產端或所述消費端對消息的操作符合預設的事件時，觸發執行對應的鉤子函數，所述鉤子函數記錄并發送狀態信息至所述監聽端；所述狀態信息為所述消息在事件后的更新狀態以及更新時刻；

所述監聽端創建與所述消息對應的影子消息，并將接收到的所述狀態信息記錄在所述影子消息中，根據所述影子消息對所述消息的處理過程進行統計。

2.根據權利要求1所述的基于消息隊列系統的消息處理方法，其特征在于，所述在生產端和消費端中注冊與事件對應的鉤子函數，包括：

在所述生產端中注冊第一鉤子函數，所述第一鉤子函數在消息寫入事件后觸發，用于將所述消息的內容、消息入隊時間以及已入隊狀態發送至所述監聽端；

相應地，當所述生產端或所述消費端對消息的操作符合預設的事件時，觸發執行對應的鉤子函數，包括：

當所述生產端將生成的消息寫入消息隊列時構成消息寫入事件，觸發執行所述第一鉤子函數；

相應地，所述將接收到的所述狀態信息記錄在影子消息中，包括：

所述監聽端在所述影子消息中記錄接收到的所述消息的內容和消息入隊時間，并將所述影子消息的狀態更新為已入隊。

3.根據權利要求1所述的基于消息隊列系統的消息處理方法，其特征在于，所述在生產端和消費端中注冊與事件對應的鉤子函數，還包括：

在所述消費端中注冊第二鉤子函數，所述第二鉤子函數在消息開始執行事件后觸發，用于將所述消息的消息出隊時間以及消費中狀態發送至所述監聽端；

相應地，當所述生產端或所述消費端對消息的操作符合預設的事件時，觸發執行對應的鉤子函數，包括：

當所述消費端將消息從消息隊列中取出時構成消息開始執行事件，觸發執行所述第二鉤子函數；

相應地，將接收到的所述狀態信息記錄在影子消息中，包括：

所述監聽端在所述影子消息中記錄接收到的所述消息的消息出隊時間，并將所述影子消息的狀態更新為消費中。

4.根據權利要求1所述的基于消息隊列系統的消息處理方法，其特征在于，所述在生產端和消費端中注冊與事件對應的鉤子函數，還包括：

在所述消費端中注冊第三鉤子函數，所述第三鉤子函數在消息完成事件后觸發，用于將所述消息的消息完成時間以及已完成狀態發送至所述監聽端；

相應地，當生產端或消費端對消息的操作符合預設的事件時，觸發執行對應的鉤子函數，包括：

當所述消費端將消息成功處理時構成消息完成事件，觸發執行對應的第三鉤子函數；

相應地，將接收到的所述狀態信息在影子消息中，包括：

所述監聽端在所述影子消息中記錄接收到的所述消息的消息完成時間，并將所述影子消息的狀態更新為已完成。

5.根據權利要求1所述的基于消息隊列系統的消息處理方法，其特征在于，所述在生產端和消費端中注冊與事件對應的鉤子函數，還包括：

在所述消費端中注冊第四鉤子函數，所述第四鉤子函數在消息失敗事件后觸發，用于將所述消息的消息失敗時間、異常信息以及已失敗狀態發送至所述監聽端；

相應地，當生產端或消費端對消息的操作符合預設的事件時，觸發執行對應的鉤子函數，包括：

當消費端處理消息失敗時構成消息失敗事件，觸發執行對應的第四鉤子函數；

相應地，將接收到的所述狀態信息記錄在影子消息中，包括：

所述監聽端在所述影子消息中記錄接收到所述消息的消息失敗時間和異常信息，并將所述影子消息的狀態更新為已失敗，所述異常信息中包括消息失敗的原因和調用棧信息。