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

有效

• 申請號: 202010115853.5
• 申請日: 2020-02-25
• 公開（公告）號: CN111538600B
• 公開（公告）日: 2023-09-12
• 發明（設計）人: 柴猛;崔昌棟;張陽;錢佳林;崔永超
• 申請（專利權）人: 遠景智能國際私人投資有限公司;上海遠景科創智能科技有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F16/16
• 代理公司: 北京三高永信知識產權代理有限責任公司 11138
• 代理人: 邢少真

1.一種消息處理方法，其特征在于，所述方法包括：

接收消息生產者發送的第一消息；

將所述第一消息存儲至目標消息隊列對應的消息文件中，所述消息文件持久化存儲在存儲介質中；

獲取所述目標消息隊列對應的刪除策略，所述刪除策略是可動態配置的用于控制所述目標消息隊列對應的消息文件進行刪除的條件；

根據所述刪除策略，獲取所述目標消息隊列對應的消息文件的編號，所述編號是指所述消息文件的標識符號，同一消息隊列中的消息文件具有不同的編號，且所述消息文件的編號的大小與所述消息文件的創建時間呈正比；

根據所述目標消息隊列中的具有不同編號的消息文件的數量，確定所述目標消息隊列對應的消息文件的數量；

響應于所述目標消息隊列對應的消息文件的數量大于閾值，根據所述目標消息隊列對應的消息文件的數量與所述閾值的差值，確定待刪除文件數量，所述待刪除文件數量是指所述目標消息隊列中需要刪除的消息文件的數量；

根據所述待刪除文件數量，按所述編號從小到大的順序刪除所述目標消息隊列對應的消息文件；

若確定刪除所述目標消息隊列對應的第一消息文件，且所述第一消息文件正在被消息消費者使用，則向所述消息消費者發送轉移請求；其中，所述轉移請求用于指示所述消息消費者停止使用所述第一消息文件，并開始使用所述目標消息隊列對應的第二消息文件，所述第二消息文件是所述目標消息隊列中的非待刪除文件；

若確定刪除所述目標消息隊列對應的第一消息文件，且所述第一消息文件沒有正在被消息消費者使用，則刪除所述第一消息文件。

2.根據權利要求1所述的方法，其特征在于，所述將所述第一消息存儲至目標消息隊列對應的消息文件中，包括：

響應于所述目標消息隊列已創建的消息文件未達到存儲上限值，將所述第一消息存儲至所述已創建的消息文件中；

或者，

響應于所述目標消息隊列已創建的消息文件已達到存儲上限值，創建所述目標消息隊列對應的新的消息文件，并將所述第一消息存儲至所述新的消息文件中。

3.根據權利要求1所述的方法，其特征在于，所述接收消息生產者發送的第一消息，包括：

接收所述消息生產者發送的消息存儲請求，所述消息存儲請求中包括所述第一消息、所述目標消息隊列的指示信息和所述第一消息對應的延時信息；

其中，所述第一消息對應的延時信息用于指示對所述第一消息進行持久化存儲的延遲時間。

4.根據權利要求1至3任一項所述的方法，其特征在于，所述將所述第一消息存儲至目標消息隊列對應的消息文件中之后，還包括：

向所述目標消息隊列對應的消息消費者發送第一信息，所述第一信息用于提醒所述消息消費者使用所述第一消息；

向所述消息生產者發送第二信息，所述第二信息用于提醒所述消息生產者所述第一消息已完成持久化存儲。

5.根據權利要求1至3任一項所述的方法，其特征在于，所述方法還包括；

接收消息消費者發送的消息獲取請求，所述消息獲取請求中包括消息消費規則；

若所述消息消費規則中包括向前跳躍消費的指示信息，則根據所述向前跳躍消費的指示信息，向所述消息消費者發送所述消息文件中的消息，所述消息的接收時間早于所述第一消息；

若所述消息消費規則中包括向后跳躍消費的指示信息，則根據所述向后跳躍消費的指示信息，等待接收新的消息，并向所述消息消費者發送所述新的消息。