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

有效

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

本申請公開了一種消息處理方法、裝置、計算機設備及存儲介質，屬于物聯網技術領域。所述方法包括：接收消息生產者發送的第一消息；將第一消息存儲至目標消息隊列對應的消息文件中；獲取目標消息隊列對應的刪除策略；根據所述刪除策略，對目標消息隊列對應的消息文件進行刪除。本申請實施例提供的技術方案中，避免了因文件堆積而造成的文件占用空間太大的問題，節省消息中間件的存儲空間，減少了消息中間件的處理開銷，有效地避免了因清除緩存而造成的文件丟失，保證了消息消費者充分使用消息；刪除策略可動態配置，提高了消息中間件進行文件刪除時的靈活性和自由度。

技術領域

本申請涉及物聯網技術領域，特別涉及一種消息處理方法、裝置、計算機設備及存儲介質。

背景技術

目前，隨著互聯網技術的飛速發展，更多設備可以實現在任何時間、任何地點的人機物相通。

相關技術中，消息可以通過中間設備，在消息生產者和消息消費者之間進行傳遞。具體地，消息生產者在生成消息之后，向中間設備發送該消息，進一步地，中間設備將該消息存儲在內存中，消息消費者可以從中間設備的內存中讀取對應的消息。

然后，上述相關技術中，隨著時間的增加，中間設備的內存中存儲的消息越來越多，且中間設備不會自動對消息進行刪除，占用的運行空間大，加大了中間設備的處理開銷。

發明內容

本申請實施例提供了一種消息處理方法、裝置、計算機設備及存儲介質，可以自動刪除中間設備中的消息，減少消息占用的運行空間。所述技術方案如下：

一方面，本申請實施例提供了一種消息處理方法，所述方法包括：

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

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

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

根據所述刪除策略，對所述目標消息隊列對應的消息文件進行刪除。

另一方面，本申請實施例提供了一種消息處理裝置，所述裝置包括：

消息接收模塊，用于接收消息生產者發送的第一消息；

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

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

文件刪除模塊，用于根據所述刪除策略，對所述目標消息隊列對應的消息文件進行刪除。

再一方面，本申請實施例提供了一種計算機設備，所述計算機設備包括處理器和存儲器，所述存儲器中存儲有計算機程序，所述計算機程序由所述處理器加載并執行以實現上述消息處理方法。

又一方面，本申請實施例提供了一種計算機可讀存儲介質，所述可讀存儲介質中存儲有計算機程序，所述計算機程序由所述處理器加載并執行以實現上述消息處理方法。

還一方面，提供了一種計算機程序產品，當所述計算機程序產品在計算機設備上運行時，使得計算機設備執行上述消息處理方法。

本申請實施例提供的技術方案可以帶來如下有益效果：

通過刪除策略對目標消息隊列中的消息文件進行刪除，避免了因文件堆積而造成的文件占用空間太大的問題，節省消息中間件的存儲空間，減少了消息中間件的處理開銷；對消息進行持久化存儲，有效地避免了因清除緩存而造成的文件丟失，保證了消息消費者充分使用消息；刪除策略可動態配置，使得消息中間件可以根據實際情況調配刪除策略，提高了消息中間件進行文件刪除中時的靈活性和自由度。