[發(fā)明專(zhuān)利]一種設(shè)備連接消息中間件的方法、物聯(lián)網(wǎng)系統(tǒng)

在審

• 申請(qǐng)?zhí)枺?/td>: 202110939211.1
• 申請(qǐng)日: 2021-08-16
• 公開(kāi)（公告）號(hào): CN113676532A
• 公開(kāi)（公告）日: 2021-11-19
• 發(fā)明（設(shè)計(jì)）人: 王小青;何奎;曹連峰;陶洋
• 申請(qǐng)（專(zhuān)利權(quán)）人: 廣州魯邦通智能科技有限公司
• 主分類(lèi)號(hào): H04L29/08
• 分類(lèi)號(hào): H04L29/08;G16Y30/00
• 代理公司: 廣州市科豐知識(shí)產(chǎn)權(quán)代理事務(wù)所(普通合伙) 44467
• 代理人: 羅嘯秋

本發(fā)明屬于通信領(lǐng)域，公開(kāi)了一種設(shè)備連接消息中間件的方法，包括如下步驟：步驟1：云平臺(tái)接收設(shè)備發(fā)送的激活請(qǐng)求，所述云平臺(tái)存儲(chǔ)有多個(gè)消息中間件的地址以及紀(jì)錄有各消息中間件連接的設(shè)備數(shù)量；步驟2：為設(shè)備分配一個(gè)消息中間件、將該消息中間件的地址發(fā)送至設(shè)備；設(shè)備通過(guò)地址連接對(duì)應(yīng)的消息中間件，并通過(guò)消息中間件和云平臺(tái)進(jìn)行通信連接。

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

本發(fā)明涉及通信領(lǐng)域，具體為一種設(shè)備連接消息中間件的方法、物聯(lián)網(wǎng)系統(tǒng)。

背景技術(shù)

消息中間件ActiveMQ的性能比較差，經(jīng)過(guò)大批量的技術(shù)驗(yàn)證，ActiveMQ按照最佳的最大接入設(shè)備量是1萬(wàn)臺(tái)，若需要接入幾萬(wàn)、十幾萬(wàn)甚至更多的設(shè)備，ActiveMQ的無(wú)法支撐的。

對(duì)于有多個(gè)消息中間件的情況，CN201910520789.6公開(kāi)了一種減少消息中間件連接數(shù)量的方法及其系統(tǒng)，方法包括：客戶(hù)端發(fā)送消息至代理層；代理層中的代理服務(wù)依據(jù)預(yù)設(shè)的分配策略，將所述消息分配至相應(yīng)的連接服務(wù)；接收到所述消息的連接服務(wù)將所述消息發(fā)送至所述消息中指定的MQ連接件。

該方法通過(guò)代理層進(jìn)行消息中間件的負(fù)載均衡，具體來(lái)說(shuō)，消息先發(fā)送至代理層的連接服務(wù)，由連接服務(wù)負(fù)責(zé)消息發(fā)送至哪個(gè)中間件。

這種方法在動(dòng)輒幾十萬(wàn)臺(tái)設(shè)備的應(yīng)用場(chǎng)景中時(shí)也是無(wú)能為力的，要求連接服務(wù)有較大的數(shù)據(jù)處理能力。

所以，本案解決的技術(shù)問(wèn)題是：如何實(shí)現(xiàn)多個(gè)消息中間件存在的條件下，設(shè)備如何更為合適的選擇消息中間件和云平臺(tái)進(jìn)行通信。

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

本發(fā)明的目的在于提供一種設(shè)備連接消息中間件的方法，該方法通過(guò)多個(gè)消息中間件來(lái)負(fù)載上萬(wàn)臺(tái)設(shè)備，由云平臺(tái)根據(jù)規(guī)則來(lái)調(diào)配消息中間件的資源，實(shí)現(xiàn)了上萬(wàn)臺(tái)設(shè)備的基于消息中間件的穩(wěn)定通信連接。

本發(fā)明還公開(kāi)了一種物聯(lián)網(wǎng)系統(tǒng)。

為實(shí)現(xiàn)上述目的，本發(fā)明提供如下技術(shù)方案：一種設(shè)備連接消息中間件的方法，包括如下步驟：

步驟1：云平臺(tái)接收設(shè)備發(fā)送的激活請(qǐng)求，所述云平臺(tái)存儲(chǔ)有多個(gè)消息中間件的地址以及紀(jì)錄有各消息中間件連接的設(shè)備數(shù)量；

步驟2：為設(shè)備分配一個(gè)消息中間件、將該消息中間件的地址發(fā)送至設(shè)備；設(shè)備通過(guò)地址連接對(duì)應(yīng)的消息中間件，并通過(guò)消息中間件和云平臺(tái)進(jìn)行通信連接。

在上述的設(shè)備連接消息中間件的方法中，當(dāng)設(shè)備無(wú)法和云平臺(tái)分配的消息中間件建立通信連接時(shí)，設(shè)備向云平臺(tái)發(fā)送激活請(qǐng)求。

在上述的設(shè)備連接消息中間件的方法中，當(dāng)設(shè)備從云平臺(tái)移除時(shí)，云平臺(tái)會(huì)通過(guò)jmx訪問(wèn)ActiveMQ進(jìn)行斷開(kāi)設(shè)備連接。

JMX(java management Extensions)即java管理擴(kuò)展,是一個(gè)為應(yīng)用程序,設(shè)備,系統(tǒng)等植入管理功能的框架.JMX可以跨越一系列異構(gòu)操作系統(tǒng)平臺(tái),系統(tǒng)體系結(jié)構(gòu)和網(wǎng)絡(luò)傳輸協(xié)議,靈活開(kāi)發(fā)無(wú)縫集成的系統(tǒng),網(wǎng)絡(luò)和服務(wù)管理應(yīng)用。

ActiveMQ開(kāi)放JMX的接口給外部系統(tǒng)增強(qiáng)功能使用，可通過(guò)ActiveMQ的接口進(jìn)行斷開(kāi)客戶(hù)端的連接。

在上述的設(shè)備連接消息中間件的方法中，所述步驟2中，根據(jù)各消息中間件上所連接的設(shè)備的數(shù)量，選擇連接設(shè)備數(shù)量最少的消息中間件分配給設(shè)備。

在上述的設(shè)備連接消息中間件的方法中，當(dāng)為設(shè)備分配了一個(gè)消息中間件之后，更新該消息中間件連接的設(shè)備數(shù)量的紀(jì)錄。

在上述的設(shè)備連接消息中間件的方法中，所述消息中間件為ActiveMQ消息中間件。

同時(shí)，本發(fā)明還公開(kāi)了一種物聯(lián)網(wǎng)系統(tǒng)，包括云平臺(tái)、多個(gè)消息中間件；

所述云平臺(tái)包括如下模塊：