[發(fā)明專利]一種IOT集群通訊的方法、系統(tǒng)、設(shè)備及存儲介質(zhì)

在審

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

本申請實施例提供了一種IOT集群通訊的方法、系統(tǒng)、設(shè)備及存儲介質(zhì)，其包括：服務(wù)器端接收到客戶端發(fā)送的包含位置信息的連接請求時，根據(jù)所述連接請求中的位置信息選取第一IOT服務(wù)器，使所述第一IOT服務(wù)器與所述客戶端進行連接；在所述第一IOT服務(wù)器與所述客戶端進行連接后，根據(jù)所述客戶端發(fā)送的消息，獲取與所述消息相關(guān)的訂閱者列表，并確定所述訂閱者列表中每個訂閱者客戶端所在的第二IOT服務(wù)器；所述第一IOT服務(wù)器根據(jù)所述訂閱者列表，并經(jīng)由所述每個訂閱者客戶端所在的第二IOT服務(wù)器將所述消息分別發(fā)送到所述每個訂閱者客戶端。

技術(shù)領(lǐng)域

本申請涉及物聯(lián)網(wǎng)通訊技術(shù)領(lǐng)域，具體地，涉及一種IOT集群通訊的方法、系統(tǒng)、設(shè)備及存儲介質(zhì)。

背景技術(shù)

目前屬于移動物聯(lián)網(wǎng)的時代，海量物聯(lián)網(wǎng)設(shè)備接入IOT來實現(xiàn)通信，IOT服務(wù)端大多采用MQTT協(xié)議來實現(xiàn)。由于海量設(shè)備的接入,MQTT Broker的集群化是必不可少的。物聯(lián)網(wǎng)設(shè)備的連接是有狀態(tài)的，且海量物聯(lián)網(wǎng)設(shè)備需要分布在多地的服務(wù)器集群去支撐，因此MQTT Broker集群的難點在于降低消息傳播的延時、消息的高效分發(fā)，多服務(wù)集群內(nèi)部如何通訊的問題。

現(xiàn)有方案提供了一種基于路由模式、MQTT協(xié)議的IOT集群通訊方法。接入層主要通過Nginx最小連接算法來確定物聯(lián)網(wǎng)設(shè)備將要連接的第一IOT服務(wù)器；設(shè)備端的設(shè)備信息，所連接第一IOT服務(wù)器的信息存儲于Redis中；在設(shè)備端向第一IOT服務(wù)器發(fā)送消息時，第一IOT服務(wù)器將所述消息持久化存儲，隨后基于消息主題從存儲在Zookeeper的訂閱樹中查詢訂閱者列表；IOT服務(wù)器從Redis中根據(jù)訂閱者列表查詢訂閱者所連接的IOT服務(wù)器IP，將所屬消息通過內(nèi)部消息路由到第二IOT服務(wù)器；所述第二IOT服務(wù)器將所述消息持久化保存在本地，并查找連接到該IOT服務(wù)器的訂閱者，將所述消息通過MQTT發(fā)送給在線的訂閱者。

但是，現(xiàn)有技術(shù)有以下缺點：

接入層只采用Nginx最小連接算法，在多地域的環(huán)境下，會導(dǎo)致設(shè)備與服務(wù)器間的延遲、設(shè)備與設(shè)備之間傳遞消息的延時變大。

依賴Redis、Zookeeper兩個組件，需要維護兩種組件集群。

設(shè)備信息與所連接第一IOT服務(wù)器的信息存儲與Redis中，會導(dǎo)致每次發(fā)送消息均需要訪問遠端的Redis服務(wù)、及遠端的Zookeeper服務(wù)，在海量設(shè)備的情況下造成延遲增加，甚至服務(wù)不可用的情況。

發(fā)明內(nèi)容

本申請實施例提供了一種IOT集群通訊的方法、系統(tǒng)、設(shè)備及存儲介質(zhì)，以解決現(xiàn)有設(shè)備與MQTT集群通訊、設(shè)備與設(shè)備消息延時不可控，路由查找復(fù)雜、延時較大、擴展性能弱的技術(shù)問題。

根據(jù)本申請實施例的第一個方面，提供了一種IOT集群通訊的方法，包括：

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

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

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

根據(jù)本申請實施例的第二個方面，提供了一種IOT集群通訊的系統(tǒng)，包括：

發(fā)送客戶端，用于向服務(wù)器端發(fā)送包含位置信息的連接請求；