[發明專利]分布式消息廣播通知實現方法

有效

• 申請號: 201911152452.0
• 申請日: 2019-11-22
• 公開（公告）號: CN110932874B
• 公開（公告）日: 2022-08-16
• 發明（設計）人: 楊帆;張東冬;師銘
• 申請（專利權）人: 南京甄視智能科技有限公司
• 主分類號: H04L12/18
• 分類號: H04L12/18;H04L67/1042;H04L1/18
• 代理公司: 南京行高知識產權代理有限公司 32404
• 代理人: 王培松

1.一種分布式消息廣播通知實現方法，其特征在于，包括：

步驟1、加入集群中的節點請求消息中心訂閱公共主題；

步驟2、節點再次請求消息中心訂閱屬于每個節點的私有主題；

步驟3、消息發送者在發送消息前請求消息中心，獲取當前訂閱公共主題的客戶端數量，記為client_count，其中，所述消息發送者通過主題從消息中心獲取到訂閱該主題的客戶端的數量；如果訂閱公共主題的客戶端數量小于或等于1，則取消發送消息；如果訂閱公共主題的客戶端數量大于1，則由消息發送者組裝消息體，包含消息內容和發送者標識，請求數據中心發送到公共主題；

步驟4、消息發送者將消息體發送后，等待來自私有主題上的消息，其中等待到至少M條消息，其中M=client_count-1，如果在指定時間內未等到預期數量的消息，判定為執行超時；

步驟5、集群內的節點接收到來自公共主題的消息后，根據消息中的標識信息以發出響應或者不做響應，其中

接收到來自公共主體的消息的節點首先根據消息體中發送者標識判斷消息是否來自于自身，如果是，則不做處理，如果發送消息來自于其他節點，對消息處理后，根據發送者標識，向對應的發送者私有主題發送響應消息。

2.根據權利要求1 所述的分布式消息廣播通知實現方法，其特征在于，在所述步驟4中，如果執行超時，則重發消息或者結束消息發送流程。

3.根據權利要求1所述的分布式消息廣播通知實現方法，其特征在于，在步驟1和/或步驟2中，消息中心對訂閱相應主題的客戶端進行計數。

4.根據權利要求1所述的分布式消息廣播通知實現方法，其特征在于，在步驟2的訂閱過程中，每個節點訂閱的主題不相同。

5.根據權利要求1所述的分布式消息廣播通知實現方法，其特征在于，前述方法更加包括：

橫向擴展消息中心節點。