[發明專利]基于消息隊列的消息消費方法、裝置及設備

有效

• 申請號: 201911417643.5
• 申請日: 2019-12-31
• 公開（公告）號: CN111552575B
• 公開（公告）日: 2023-09-12
• 發明（設計）人: 張陽;崔昌棟;錢佳林;柴猛;崔永超;尹濤;陳慧敏;姜凱洋;朱樹強;張朝旭;劉文杰;王仁斌;張宏振
• 申請（專利權）人: 遠景智能國際私人投資有限公司;上海遠景科創智能科技有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 北京三高永信知識產權代理有限責任公司 11138
• 代理人: 寧立存

本申請公開了一種基于消息隊列的消息消費方法、裝置及設備，屬于計算機數據通訊領域。該方法包括：將消息寫入消息文件中對應的本次寫入位置，消息是生產者程序生成的，本次寫入位置是按照循環寫入順序在n個消息文件中確定出的寫入位置，n為正整數；獲取消費者程序在消息文件中對應的本次讀取位置，本次讀取位置是按照循環讀取順序在n個消息文件中確定出的讀取位置；響應于本次寫入位置與本次讀取位置重合，將本次讀取位置更新為目標讀取位置，目標讀取位置是沿循環寫入順序的寫入方向上位于本次讀取位置之后的讀取位置；將目標讀取位置讀取到的所述消息文件中的消息，發送至消費者程序。

技術領域

本申請涉及計算機數據通訊領域，特別涉及一種基于消息隊列的消息消費方法、裝置及設備。

背景技術

消息隊列(Message?Queue，MQ)是一種應用程序間的通信方式，應用程序在將消息發送至消息隊列后可以立即返回，由消息系統來確保消息的可靠傳遞。消息的生產者(消息發布者)將消息發布到消息隊列中，消息的消費者(消息主動獲取者)從消息隊列中獲取消息，生產者和消費者之間互不干擾。

發明內容

本申請實施例提供了一種基于消息隊列的消息消費方法、裝置及設備，使得消費速度較低的消費者在讀取消息時對消息傳輸系統中的生產者或其他消費者的影響降到最低。所述技術方案如下：

根據本申請的一個方面，一種基于消息隊列的消息消費方法，所述方法包括：

將消息寫入消息文件中對應的本次寫入位置，所述消息是生產者程序生成的，所述本次寫入位置是按照循環寫入順序在n個消息文件中確定出的寫入位置，n為正整數；

獲取消費者程序在所述消息文件中對應的本次讀取位置，所述本次讀取位置是按照循環讀取順序在所述n個消息文件中確定出的讀取位置；

響應于所述本次寫入位置與所述本次讀取位置重合，將所述本次讀取位置更新為目標讀取位置，所述目標讀取位置是沿所述循環寫入順序的寫入方向上位于所述本次讀取位置之后的讀取位置；

將所述目標讀取位置讀取到的所述消息文件中的消息，發送至所述消費者程序。

根據本申請的另一方面，提供了一種基于消息隊列的消息消費裝置，所述裝置包括：

寫入模塊，用于將消息寫入消息文件中對應的本次寫入位置，所述消息是生產者程序生成的，所述本次寫入位置是按照循環寫入順序在n個消息文件中確定出的寫入位置，n為正整數；

獲取模塊，用于獲取消費者程序在所述消息文件中對應的本次讀取位置，所述本次讀取位置是按照循環讀取順序在所述n個消息文件中確定出的讀取位置；

處理模塊，用于響應于所述本次寫入位置與所述本次讀取位置重合，將所述本次讀取位置更新為目標讀取位置，所述目標讀取位置是沿所述循環寫入順序的寫入方向上位于所述本次讀取位置之后的讀取位置；

讀取模塊，用于將所述目標讀取位置讀取到的所述消息文件中的消息，發送至所述消費者程序。

根據本申請的另一方面，提供了一種計算機設備，所述計算機設備設置有傳感器，所述計算機設備包括處理器和存儲器，所述存儲器中存儲有至少一條指令、至少一段程序、代碼集或指令集，所述至少一條指令、所述至少一段程序、所述代碼集或指令集由所述處理器加載并執行以實現如上方面所述的基于消息隊列的消息消費方法。

本申請實施例提供的技術方案帶來的有益效果至少包括：

在本次寫入位置與本次讀取位置重合時，通過將本次讀取位置更新為目標讀取位置，即將本次讀取位置沿循環寫入順序的寫入方向進行更新，使得消費者程序的讀取位置與寫入位置重新保持一段距離，對于偶爾消費速度較低的消費者程序，只會丟失小部分消息。

附圖說明