[發明專利]延遲消息發送方法、裝置及存儲介質

有效

• 申請號: 202011205008.3
• 申請日: 2020-11-02
• 公開（公告）號: CN112395103B
• 公開（公告）日: 2022-09-13
• 發明（設計）人: 黃智偉
• 申請（專利權）人: 天津五八到家貨運服務有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 北京太合九思知識產權代理有限公司 11610
• 代理人: 張愛;劉戈

本申請實施例提供一種延遲消息發送方法、裝置及存儲介質。在本申請實施例中，在監控到期望發送時間與當前時間匹配的目標主題時，對目標主題的單次發送的延遲消息的數量進行管控。這樣，在目標主題為多個時，多個目標主題都有概率將期望發送時間到期的延遲消息發送出去。即使多個目標主題中有消息堆積的目標主題，也不會影響其他目標主題的延遲消息的正常發送，盡可能地避免消息堆積的主題對其他主題的消息吞吐量的影響。與此同時，存在消息堆積的目標主題也會持續地發送延遲消息，只是單次發送的延遲消息的數量受到約束。由此，能夠很好地解決現有技術中消息堆積的主題會影響其他主題的消息吞吐量的技術問題。

技術領域

本申請涉及計算機技術領域，尤其涉及一種延遲消息發送方法、裝置及存儲介質。

背景技術

基于消息中間件技術，生產者所生成的消息可以被消費者消費。以消息中間件實現為消息隊列為例，消息隊列的消息傳遞模式一般包括點對點(point to point，PTP)模式和發布/訂閱(Publish/Subscribe，Pub/Sub)模式。PTP模式的特點是一個生成者與一個消費者對應。Pub/Sub模式的特點是一個生產者產生消息并進行發送后，可以由多個消費者進行接收。

生產者把消息發送到消息隊列中以后，并不期望被立即消費，而是等待指定時間后才可以被消費者消費，這類消息通常被稱為延遲消息。每條消息都有一個主題(Topic)，一個Topic可以有1個或多個生產者所發送的消息。目前，按照延遲消息的期望發送時間進行發送各條延遲消息。然而，若某個主題的延遲消息比較多，甚至出現堆積現象時，按照上述延遲消息的發送方式，很可能出現其他主題的延遲消息無法如期發送出去，影響其他主題的消息吞吐量。

發明內容

本申請的多個方面提供一種延遲消息發送方法、裝置及存儲介質，用以盡可能地避免消息堆積的主題對其他主題的消息吞吐量的影響。

本申請實施例提供一種延遲消息發送方法，包括：

監控多個主題中延遲消息的期望發送時間；

若監控到期望發送時間與當前時間匹配的目標主題，則從所述目標主題中的候選延遲消息中，分別選擇不大于預設消息數量的目標延遲消息；

根據所述目標主題之間的先后順序，依次發送所述目標主題中的目標延遲消息；其中，候選延遲消息是期望發送時間與當前時間匹配的延遲消息。

本申請實施例還提供一種延遲消息發送裝置，包括：存儲器和處理器；

所述存儲器，用于存儲計算機程序；

所述處理器，與所述存儲器耦合，用于執行所述計算機程序，以用于：

監控多個主題中延遲消息的期望發送時間；

若監控到期望發送時間與當前時間匹配的目標主題，則從所述目標主題中的候選延遲消息中，分別選擇不大于預設消息數量的目標延遲消息；

根據所述目標主題之間的先后順序，依次發送所述目標主題中的目標延遲消息；其中，候選延遲消息是期望發送時間與當前時間匹配的延遲消息。

本申請實施例還提供一種存儲有計算機程序的計算機可讀存儲介質，當所述計算機程序被處理器執行時，致使所述處理器實現上述延遲消息發送方法中的步驟。