[發明專利]集群消息的處理方法、裝置、電子設備和介質

有效

• 申請號: 202110831096.6
• 申請日: 2021-07-22
• 公開（公告）號: CN113596746B
• 公開（公告）日: 2022-11-04
• 發明（設計）人: 王賀
• 申請（專利權）人: 北京金山云網絡技術有限公司
• 主分類號: H04W4/10
• 分類號: H04W4/10;H04W4/06;H04L67/10;H04L67/51
• 代理公司: 北京開陽星知識產權代理有限公司 11710
• 代理人: 唐博

本公開涉及一種集群消息的處理方法、裝置、電子設備和介質；其中，該方法包括：獲取數據結構服務器的集群中的服務節點分別對應的屬性信息；根據屬性信息對集群中的服務節點進行劃分，得到至少兩個節點集合；確定至少兩個節點集合分別對應的通訊節點，其中，每個節點集合對應的通訊節點為節點集合中的一個服務節點；若監測到集群中產生節點服務消息，則將節點服務消息廣播給通訊節點，使通訊節點將節點服務消息廣播給通訊節點所在的節點集合中的其他服務節點，節點服務消息用于指示服務節點出現節點增加、節點刪除和通訊節點變更中的至少一種。本實施例能夠提高集群消息的傳遞效率。

技術領域

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

背景技術

遠程字典服務器(REmote DIctionary Server，redis)是一個使用內存存儲的數據結構服務器，其可用作數據庫、高速緩存和消息隊列代理。redis中能夠支持字符串、哈希表、列表、集合、有序集合以及位圖等數據存儲類型的數據的有效存儲。

但是，現有的redis構建的redis集群中，可包括多個服務節點，用來獲取并存儲集群消息(如新增節點或者刪除節點)，redis集群中各服務節點采用點對點的方式進行消息傳遞。如redis集群中增加一個新的服務節點，則需要將增加新的服務節點的消息分別傳遞給redis集群中的所有服務節點。

從而，當redis集群中服務節點的數量龐大時，點對點的消息傳遞方式會極大減弱集群消息的傳遞效率。

發明內容

為了解決上述技術問題或者至少部分地解決上述技術問題，本公開提供了一種集群消息的處理方法、裝置、電子設備和介質。

第一方面，本實施例提供了一種集群消息的處理方法，包括：

獲取數據結構服務器的集群中的服務節點分別對應的屬性信息；

根據所述屬性信息對所述集群中的服務節點進行劃分，得到至少兩個節點集合；

確定所述至少兩個節點集合分別對應的通訊節點，其中，每個節點集合對應的通訊節點為所述節點集合中的一個服務節點；

若監測到所述集群中產生節點服務消息，則將所述節點服務消息廣播給所述通訊節點，使所述通訊節點將所述節點服務消息廣播給所述通訊節點所在的節點集合中的其他服務節點，所述節點服務消息用于指示服務節點出現節點增加、節點刪除和通訊節點變更中的至少一種。

可選的，所述確定所述至少兩個節點集合分別對應的通訊節點，包括：

獲取每一節點集合中服務節點分別對應的數據存儲量；

將最小數據存儲量對應的服務節點作為所述節點集合的通訊節點。

可選的，所述確定所述至少兩個節點集合分別對應的通訊節點，包括：

獲取每一節點集合中服務節點分別對應的性能參數值；

根據所述性能參數值選取通訊節點。

可選的，所述節點服務消息是在所述集群中第一節點集合的任務處理量大于預設的第一處理量閾值時產生的；

所述將所述節點服務消息廣播給所述通訊節點之前，還包括：

將第一預設數量個服務節點增加進所述第一節點集合；

所述將所述節點服務消息廣播給所述通訊節點，包括：

將增加的服務節點的標識和所述第一節點集合的所屬信息廣播給所述集群中的其他節點集合。

可選的，所述節點服務消息是在所述集群中第二節點集合的任務處理量小于或等于預設的第二處理量閾值時產生的；