[發明專利]一種基于ZK服務器的消息訂閱方法及裝置

在審

• 申請號: 202210368942.X
• 申請日: 2022-04-08
• 公開（公告）號: CN114840353A
• 公開（公告）日: 2022-08-02
• 發明（設計）人: 劉科浩;熊超
• 申請（專利權）人: 云控智行科技有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;H04L12/18;H04L67/54
• 代理公司: 北京晉德允升知識產權代理有限公司 11623
• 代理人: 王戈

本說明書實施例公開了一種基于ZK服務器的消息訂閱方法及裝置，消息發布端和消息訂閱端分別在ZK服務器注冊消息發布節點和消息訂閱節點，對ZK服務器中各消息發布節點和各消息訂閱節點的動態進行監聽，獲取實時的消息發布端列表和消息訂閱端列表；獲取消息發布端列表實時對應的消息發布主題列表；根據消息發布主題列表和消息訂閱端列表生成消息訂閱策略；將消息訂閱策略廣播給各消息訂閱端，使得各消息訂閱端根據消息訂閱策略訂閱消息主題列表中包含的待訂閱消息主題。本說明書實施例提供的基于ZK服務器的消息訂閱方法及裝置，能夠動態訂閱消息主題，各消息訂閱端也不會因為新增消息主題或訂閱更高層次的消息主題而造成系統或性能不穩定。

技術領域

本說明書實施例涉及通訊技術領域，尤其涉及一種基于ZK服務器的消息訂閱方法及裝置。

背景技術

MQTT(Message Queuing Telemetry Transport，消息隊列遙測傳輸協議)，是一種基于發布/訂閱(publish/subscribe)模式的“輕量級”通訊協議，消息發布端、消息訂閱端通過MQTT協議與MQTT中間件服務器連接，消息發布端往MQTT中間件服務器上的消息主題中發布消息，只有消息訂閱端訂閱MQTT中間件服務器上相應的消息主題，消息訂閱端才能訂閱到消息發布端發布的消息，以此達到消息發布端、消息訂閱端的通信。

此消息主題為消息訂閱端與消息發布端事先定義的應用程序消息的標簽，當消息發布端新增消息主題時，消息訂閱端需要重啟程序來訂閱新增的消息主題或者訂閱更高層次的消息主題，這樣大大降低了整個系統的穩定性及性能。

發明內容

有鑒于此，本說明書實施例提供了一種基于ZK服務器的消息訂閱方法及裝置，用于解決現有技術中消息訂閱端新增消息主題或訂閱更高層次的消費主題帶來的系統不穩定及性能問題。

本說明書實施例采用下述技術方案：

本說明書實施例提供一種基于ZK服務器的消息訂閱方法，各消息發布端和各消息訂閱端分別在所述ZK服務器注冊消息發布節點和消息訂閱節點，所述方法包括：

對所述ZK服務器中各所述消息發布節點和各所述消息訂閱節點的動態進行監聽，以根據監聽結果，獲取實時的消息發布端列表和消息訂閱端列表；

獲取所述消息發布端列表實時對應的消息發布主題列表；

根據所述消息發布主題列表和所述消息訂閱端列表生成消息訂閱策略；

將所述消息訂閱策略廣播給各所述消息訂閱端，使得各所述消息訂閱端根據所述消息訂閱策略從MQTT服務器中訂閱所述消息主題列表中包含的待訂閱消息主題。

進一步的，對所述ZK服務器中各所述消息發布節點和各所述消息訂閱節點的動態進行監聽，包括：

對各所述消息發布節點和各所述消息訂閱節點的上下線信息進行監聽，以獲取實時的消息發布端列表和消息訂閱端列表。

進一步的，獲取所述消息發布端列表實時對應的消息發布主題列表，包括：

當監聽到新增上線的消息發布節點時，將對應新增的消息發布主題加入到所述消息發布主題列表中；

或者，當監聽到新增下線的消息發布節點時，將對應的消息發布主題從所述消息發布主題列表中刪除。

進一步的，根據所述消息發布主題列表和所述消息訂閱端列表生成消息訂閱策略，包括：

當監聽到新增下線的消息發布節點時，從所述消息訂閱端列表中確定已訂閱所述新增下線的消息發布節點對應的消息發布主題的消息訂閱端；

根據所述確定的消息訂閱端和所述新增下線的消息發布節點對應的消息發布主題生成所述消息訂閱策略，使得所述確定的消息訂閱端取消訂閱所述新增下線的消息發布節點對應的消息發布主題，以釋放系統資源。