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

有效

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

1.一種基于消息隊列的消息消費方法，其特征在于，所述方法包括：

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

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

獲取所述消費者程序的歷史讀取位置和所述生產者程序的歷史寫入位置在上一次重合時的第一時間戳；

獲取所述本次讀取位置與所述本次寫入位置重合時的第二時間戳；

根據所述第一時間戳和所述第二時間戳的差值，將所述本次讀取位置更新為目標讀取位置，所述目標讀取位置是沿所述循環寫入順序的寫入方向上位于所述本次讀取位置之后的讀取位置；

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

2.根據權利要求1所述的方法，其特征在于，所述根據所述第一時間戳和所述第二時間戳的差值，將所述本次讀取位置更新為所述目標讀取位置，包括：

響應于所述第一時間戳和所述第二時間戳的差值不大于時間閾值，將所述本次讀取位置更新為第二目標讀取位置；

所述歷史讀取位置與歷史目標讀取位置之間的長度是第一長度，所述本次讀取位置與第二目標讀取位置之間的長度是第二長度，其中，所述第一長度小于所述第二長度。

3.根據權利要求1所述的方法，其特征在于，所述根據所述第一時間戳和所述第二時間戳的差值，將所述本次讀取位置更新為所述目標讀取位置，包括：

響應于所述第一時間戳和所述第二時間戳的差值大于時間閾值，將所述本次讀取位置更新為第一目標讀取位置；

所述本次讀取位置與第一目標讀取位置之間的長度是第二長度，其中，所述第二長度是預設值。

4.根據權利要求3所述的方法，其特征在于，所述方法還包括：

響應于所述第二長度達到預設長度，將所述本次讀取位置更新為第三目標讀取位置，所述本次讀取位置與所述第三目標讀取位置之間的長度為所述預設長度。

5.一種基于消息隊列的消息消費裝置，其特征在于，所述裝置包括：

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

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

處理模塊，用于獲取所述消費者程序的歷史讀取位置和所述生產者程序的歷史寫入位置在上一次重合時的第一時間戳；獲取所述本次讀取位置與所述本次寫入位置重合時的第二時間戳；根據所述第一時間戳和所述第二時間戳的差值，將所述本次讀取位置更新為目標讀取位置，所述目標讀取位置是沿所述循環寫入順序的寫入方向上位于所述本次讀取位置之后的讀取位置；

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

6.根據權利要求5所述的裝置，其特征在于，

所述獲取模塊，用于獲取所述消費者程序的歷史讀取位置和所述生產者程序的歷史寫入位置在上一次重合時的第一時間戳；

所述獲取模塊，用于獲取所述本次讀取位置與所述本次寫入位置重合時的第二時間戳；

所述處理模塊，用于根據所述第一時間戳和所述第二時間戳的差值，將所述本次讀取位置更新為所述目標讀取位置。

7.根據權利要求6所述的裝置，其特征在于，

所述處理模塊，用于響應于所述第一時間戳和所述第二時間戳的差值大于時間閾值，將所述本次讀取位置更新為第一目標讀取位置；

所述歷史讀取位置與歷史目標讀取位置之間的長度是第一長度，所述本次讀取位置與第一目標讀取位置之間的長度是第二長度，其中，所述第一長度與所述第二長度相等。