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

在審

• 申請號: 202110891382.1
• 申請日: 2021-08-04
• 公開（公告）號: CN113709214A
• 公開（公告）日: 2021-11-26
• 發明（設計）人: 強貝貝
• 申請（專利權）人: 北京快樂茄信息技術有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京善任知識產權代理有限公司 11650
• 代理人: 李梅香

本公開是關于一種消息處理方法及裝置、電子設備及存儲介質。應用于服務端中的消息處理方法包括：接收客戶端發送的待處理的延時消息；所述延時消息的頭部信息中攜帶有存儲所述延時消息的目標隊列以及延時后時間；將所述延時消息存儲至預設延時隊列；響應于當前時間與所述延時后時間一致，從所述預設延時隊列中讀取所述延時消息發送給所述目標隊列，以使所述客戶端從所述目標隊列中讀取延時消息進行處理。通過該方法，能支持任意時間的消息延時。

技術領域

本公開涉及信息技術領域，尤其涉及一種消息處理方法及裝置、電子設備及存儲介質。

背景技術

隨著互聯網通信的發展，互聯網系統規模越來越大，不同應用之間對消息的傳遞需求也越來越大，對此，消息中間件應運而生。消息中間件基于隊列與消息傳遞技術，在網絡環境中為應用系統提供同步或異步、可靠的消息傳輸。

消息中間件中消息隊列的通信模式包括點對點模式和發布訂閱模式。點對點模式通常是基于拉取或者輪詢的消息傳送模型，這個模型的特點是發送隊列的消息被一個且只有一個消費者進行處理。不同的是，發布訂閱模式中，一個消息可能被多個消費者處理。

發明內容

本公開提供一種消息處理方法及裝置、電子設備及存儲介質。

根據本公開實施例的第一方面，提供一種消息處理方法，應用于服務端，包括：

接收客戶端發送的待處理的延時消息；所述延時消息的頭部信息中攜帶有存儲所述延時消息的目標隊列以及延時后時間；

將所述延時消息存儲至預設延時隊列；

響應于當前時間與所述延時后時間一致，從所述預設延時隊列中讀取所述延時消息發送給所述目標隊列，以使所述客戶端從所述目標隊列中讀取延時消息進行處理。

在一些實施例中，所述延時消息存儲于所述預設延時隊列中所述延時后時間對應的第一日志文件，所述預設延時隊列中包括根據時間劃分的不同第一日志文件；

所述響應于當前時間與所述延時后時間一致，從所述預設延時隊列中讀取所述延時消息發送給所述目標隊列，包括：

響應于當前時間與所述延時后時間一致，從所述延時后時間對應的第一日志文件中讀取所述延時消息發送給所述目標隊列。

在一些實施例中，所述將所述延時消息存儲至預設延時隊列，包括：

將所述延時消息存儲至所述預設延時隊列的第二日志文件中；

將所述第二日志文件中的所述延時消息復制后，按所述延時后時間存儲至所述預設延時隊列中所述延時后時間對應的所述第一日志文件。

在一些實施例中，所述方法還包括：

若當前時間未到達所述延時后時間，按照所述延時后時間與所述當前時間之間的時間差，將所述延時消息的索引信息存儲至所述時間差對應的目標時間分區中；所述目標時間分區為時間輪中的一個分區，用于表征所述延時消息的到期剩余時間；

所述響應于當前時間與所述延時后時間一致，從所述延時后時間對應的第一日志文件中讀取所述延時消息發送給所述目標隊列，包括：

響應于計時時間與所述時間輪的目標時間分區指示的時間差相一致，通過所述目標時間分區中存儲的索引信息從所述延時后時間對應的第一日志文件中讀取所述延時消息，并發送給所述目標隊列；其中，所述計時時間從將所述延時消息的索引信息存儲至所述目標時間分區中的時間起算。

在一些實施例中，所述若當前時間未到達所述延時后時間，按照所述延時后時間與所述當前時間之間的時間差，將所述延時消息的索引信息存儲至所述時間差對應的目標時間分區中，包括：