[發明專利]消息消費方法、裝置、計算機設備和存儲介質

在審

• 申請號: 202010221369.0
• 申請日: 2020-03-26
• 公開（公告）號: CN111427708A
• 公開（公告）日: 2020-07-17
• 發明（設計）人: 任超超
• 申請（專利權）人: 中國平安財產保險股份有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F8/71;G06F16/172
• 代理公司: 廣州華進聯合專利商標代理有限公司 44224
• 代理人: 唐彩琴

本申請涉及一種消息消費方法、裝置、計算機設備和存儲介質。所述方法包括：根據數據源的名稱從預存消費規則配置文件中獲取相應消息消費規則；所述消息消費規則包括需要消費的消息的起止時間，所述起止時間根據消息到達消息中間件的預估時間設定；根據所述消息消費規則，從消息中間件中查找在所述起止時間內到達所述消息中間件的消息，并對其進行消費；將已消費的所述消息存儲到目標文件，并設置所述起止時間為所述目標文件的名稱。采用本方法能夠提供漏接消息的排查效率。

技術領域

本申請涉及通信技術領域，特別是涉及一種消息消費方法、裝置、計算機設備和存儲介質。

背景技術

消息中間件包括消息生產端和消息消費端，消息生產端的作用是提供消息，消息消費端的作用是與消息生產端連接、輸出消息，其中，消息是一些數字、字母和符號的文本數據。消息中間件利用高效可靠的消息傳遞機制進行平臺無關的數據交流，針對每種平臺都有相應的消息消費端。消息中間件基于數據通信來進行分布式系統的集成，通過提供消息傳遞和消息排隊模型，它可以在分布式環境下擴展進程間的通信。

然而，當出現消息漏接時，IT運維人員要排查歷史消息(即排查是因為發送端未發送消息，還是因為消息接收端未接收到消息，導致消息漏接)時通常要從消息中間件的第一條消息開始消費直到消費完最后一條消息，并把消費到的消息存儲到文本文件中，IT運維人員再從文本文件中查找漏接消息。由于消息消費端不能中途中斷，消息中間件中的消息數量龐大，導致用于存儲消息的文本文件容量龐大，可以達到幾十G字節到幾百G字節，從這個大文件中查找到特定要排查的消息無異于大海撈針，而且在大文件中查找消息時對計算機的硬件性能要求很高，故現有排查漏接效率很低。

發明內容

基于此，有必要針對上述技術問題，提供一種能夠提高消息排除效率的消息消費方法、裝置、計算機設備和存儲介質。

一種消息消費方法，所述方法包括：

根據數據源的名稱從預存消費規則配置文件中獲取相應消息消費規則；所述消息消費規則包括需要消費的消息的起止時間，所述起止時間根據消息到達消息中間件的預估時間設定；

根據所述消息消費規則，從消息中間件中查找在所述起止時間內到達所述消息中間件的消息，并對其進行消費；

將已消費的所述消息存儲到目標文件，并設置所述起止時間為所述目標文件的名稱。

在其中一個實施例中，所述根據數據源的名稱從預存消費規則配置文件中獲取相應消息消費規則步驟包括：根據數據源的名稱從預存消費規則配置文件中獲取消息進入的應用程序接口、消息輸出的應用程序接口、對消息的輸入輸出進行處理的可執行文件；其中，所述消息進入的應用程序接口、消息輸出的應用程序接口、對消息的輸入輸出進行處理的可執行文件配置了相應消息消費規則；其中，所述消息輸出的應用程序接口配置了需要消費的消息的起止時間。

在其中一個實施例中，所述消息輸出的應用程序接口配置了保存所述消息的文件的命名方式、保存所述消息的單個文件大小和保存所述消息的文件的目錄；所述將已消費的所述消息存儲到目標文件，并設置所述起止時間為所述目標文件的名稱步驟包括：將所述消費的消息按照所述保存所述消息的文件的命名方式、保存所述消息的單個文件大小和保存所述消息的文件的目錄存儲到目標文件，所述保存所述消息的文件的命名方式包括設置所述起止時間為所述目標文件的名稱。

在其中一個實施例中，所述消息進入的應用程序接口配置了需要消費的消息的通信協議；所述根據所述消息消費規則，從消息中間件中查找在所述起止時間內到達所述消息中間件的消息，并對其進行消費步驟包括：根據所述需要消費的消息的通信協議與對應的消息中間件進行通信；根據所述消息消費規則，從所述消息中間件中查找在所述起止時間內到達所述消息中間件的消息，并對其進行消費。