[發明專利]數據分發方法、裝置及存儲介質

有效

• 申請號: 201910985286.6
• 申請日: 2019-10-16
• 公開（公告）號: CN110839061B
• 公開（公告）日: 2020-11-06
• 發明（設計）人: 胡偉松
• 申請（專利權）人: 北京達佳互聯信息技術有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京潤澤恒知識產權代理有限公司 11319
• 代理人: 李娜

本公開關于一種數據分發方法、裝置及存儲介質，數據分發方法包括：獲取訂閱服務器集合中每個訂閱服務器的訂閱時間信息，根據每個訂閱服務器的訂閱時間信息，從訂閱服務器集合中確定第一訂閱服務器，并確定第一訂閱服務器的目標訂閱服務器，通知第一訂閱服務器從目標訂閱服務器中訂閱消息。通過使訂閱服務器從其他訂閱服務器中訂閱消息隊列中的消息，降低了同一時刻訪問存儲服務器的訂閱服務器數量，進一步的降低了同一時刻訪問分布式消息隊列系統的訂閱服務器的數量，有效分散了多個訂閱服務器對分布式消息隊列系統的訂閱壓力，大大降低了分布式消息隊列系統的網絡通信負載，并降低了對機器資源的消耗。

技術領域

本公開涉及數據分發技術領域，尤其涉及一種數據分發方法、裝置及存儲介質。

背景技術

目前的生產環境中，需要分發的數據量規模不斷增長，大規模數據的實時分發通常是通過分布式消息隊列系統實現的。分布式消息隊列系統由多個服務器組成，多個服務器分布存儲多個消息隊列中的消息，由多個服務器對多個消息隊列中的消息進行分布存儲和實時分發。

相關技術中，發布消息的服務器(下稱生產服務器)發布的大規模的消息數據統一存儲到分布式消息隊列系統中，多個請求訂閱消息的服務器(下稱訂閱服務器)需要從分布式消息隊列系統中的消息隊列訂閱消息，當多個訂閱服務器從分布式消息隊列系統中同時訂閱消息隊列中的消息時，導致分布式消息隊列系統需要和多個訂閱服務器同時進行網絡通信，造成較高的網絡通信負載，消耗很多機器資源。

發明內容

本公開提供一種數據分發方法、裝置及存儲介質，以至少解決相關技術中分布式消息隊列系統中通信負載高和機器資源消耗多的問題。本公開的技術方案如下：

根據本公開實施例的第一方面，提供一種數據分發方法，應用于數據分發系統，所述數據分發系統包括存儲服務器和訂閱服務器集合，所述方法執行于存儲服務器，包括：

獲取所述訂閱服務器集合中每個訂閱服務器的訂閱時間信息，所述訂閱時間信息標志所述訂閱服務器的訂閱進度；

根據每個所述訂閱服務器的訂閱時間信息，從所述訂閱服務器集合中確定第一訂閱服務器，并確定所述第一訂閱服務器的目標訂閱服務器；

通知所述第一訂閱服務器從所述目標訂閱服務器中訂閱消息。

根據本公開實施例的第二方面，提供另一種數據分發方法，應用于數據分發系統，所述數據分發系統包括存儲服務器和訂閱服務器集合，所述方法執行于訂閱服務器，包括：

接收所述存儲服務器發送的通知，所述通知用于通知所述訂閱服務器從所述訂閱服務器的目標訂閱服務器中訂閱消息；其中，所述目標訂閱服務器為所述存儲服務器根據每個所述訂閱服務器的訂閱時間信息，從所述訂閱服務器集合中確定所述訂閱服務器后，為所述訂閱服務器確定的所述目標訂閱服務器；

根據所述通知，從所述目標訂閱服務器中訂閱消息。

根據本公開實施例的第三方面，提供一種數據分發裝置，應用于數據分發系統，所述數據分發系統包括存儲服務器和訂閱服務器集合，所述裝置設置于存儲服務器，包括：

獲取模塊，被配置為獲取所述訂閱服務器集合中每個訂閱服務器的訂閱時間信息，所述訂閱時間信息標志所述訂閱服務器的訂閱進度；

確定模塊，被配置為根據每個所述訂閱服務器的訂閱時間信息，從所述訂閱服務器集合中確定第一訂閱服務器，并確定所述第一訂閱服務器的目標訂閱服務器；

通知模塊，被配置為通知所述第一訂閱服務器從所述目標訂閱服務器中訂閱消息。

根據本公開實施例的第四方面，提供一種數據分發裝置，應用于數據分發系統，所述數據分發系統包括存儲服務器和訂閱服務器集合，所述裝置設置于訂閱服務器，包括：