[發明專利]一種IOT集群通訊的方法、系統、設備及存儲介質

在審

• 申請號: 202211278500.2
• 申請日: 2022-10-19
• 公開（公告）號: CN115766735A
• 公開（公告）日: 2023-03-07
• 發明（設計）人: 王浩強;李麗;史曉丹;李平;王成宇;孫巖
• 申請（專利權）人: 中車信息技術有限公司
• 主分類號: H04L67/1021
• 分類號: H04L67/1021;H04L67/01;H04L67/02
• 代理公司: 北京科慧致遠知識產權代理有限公司 11739
• 代理人: 李瑞

1.一種IOT集群通訊的方法，其特征在于，包括：

服務器端接收到客戶端發送的包含位置信息的連接請求時，根據所述連接請求中的位置信息選取第一IOT服務器，使所述第一IOT服務器與所述客戶端進行連接；

在所述第一IOT服務器與所述客戶端進行連接后，根據所述客戶端發送的消息，獲取與所述消息相關的訂閱者列表，并確定所述訂閱者列表中每個訂閱者客戶端所在的第二IOT服務器；

所述第一IOT服務器根據所述訂閱者列表，并經由所述每個訂閱者客戶端所在的第二IOT服務器將所述消息分別發送到所述每個訂閱者客戶端。

2.根據權利要求1所述的方法，其特征在于，還包括：

從具有N個IOT服務器的IOT集群中選取M個IOT服務器，并將所述M個IOT服務器分別設置為種子節點，同時將(N-M)個IOT服務器分別設置為普通節點，并在每個普通節點啟動后周期性與所述種子節點進行信息同步處理；

其中，所述N和M均為正整數，且N大于M。

3.根據權利要求2所述的方法，其特征在于，所述在每個普通節點啟動后周期性與所述種子節點進行信息同步處理包括：

所述每個普通節點啟動后，周期性讀取包含關鍵數據、IOT服務集群列表以及當前與客戶端的連接情況的信息，并將所述信息發送給所述種子節點進行信息同步處理，同時將所述關鍵數據在本地進行持久化存儲；

其中，所述關鍵數據包括：設備端服務映射信息，訂閱樹信息，IOT服務器的連接信息，地理位置信息以及歸屬IDC機房信息。

4.根據權利要求3所述的方法，其特征在于，所述服務器端根據所述連接請求中的位置信息選取第一IOT服務器，使所述第一IOT服務器與所述客戶端進行連接包括：

所述服務器端根據所述連接請求中的位置信息，獲取與所述位置信息距離最近的IDC機房；

所述服務器端根據所述IDC機房內每個IOT服務器的當前連接數量，選取當前連接數量最少的IOT服務器作為第一IOT服務器，并將第一IOT服務器信息發送給所述客戶端，使所述客戶端根據所述第一IOT服務器信息與所述第一IOT服務器進行連接。

5.根據權利要求4所述的方法，其特征在于，在所述第一IOT服務器與所述客戶端進行連接后，還包括：

所述第一IOT服務器將所述客戶端的設備信息和其IP信息在所述服務器端進行持久化存儲，并將所述客戶端的設備信息和其IP信息同步至所述IOT集群中其他所有IOT服務器。

6.根據權利要求5所述的方法，其特征在于，所述第一IOT服務器根據所述客戶端發送的消息，獲取與所述消息相關的訂閱者列表，并確定所述訂閱者列表中每個訂閱者客戶端所在的第二IOT服務器包括:

所述第一IOT服務器通過對所述客戶端發送的消息進行解析，獲取消息主題，并根據從本地持久化存儲的訂閱樹信息中獲取與所述消息主題相對應的訂閱者列表；

所述第一IOT服務器根據所述訂閱者列表，確定所述訂閱者列表中每個訂閱者客戶端所在的第二IOT服務器。

7.根據權利要求6所述的方法，其特征在于，所述第一IOT服務器根據所述訂閱者列表，并經由所述每個訂閱者客戶端所在的第二IOT服務器將所述消息分別發送到所述每個訂閱者客戶端包括：

所述第一IOT服務器根據所述訂閱者列表，分別將所述消息通過內部消息路由到所述每個訂閱者客戶端所在的第二IOT服務器，使收到所述消息的每個第二IOT服務器將所述消息轉發到其對應的訂閱者客戶端。