[發(fā)明專利]一種支持物聯(lián)網(wǎng)中間件集群擴(kuò)展的方法和裝置

有效

• 申請?zhí)枺?/td>: 201410478865.9
• 申請日: 2014-09-18
• 公開（公告）號: CN104202420B
• 公開（公告）日: 2017-10-13
• 發(fā)明（設(shè)計(jì)）人: 李引;袁峰;吳鴻
• 申請（專利權(quán)）人: 廣州中國科學(xué)院軟件應(yīng)用技術(shù)研究所
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京集佳知識產(chǎn)權(quán)代理有限公司11227
• 代理人: 王寶筠

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

本申請涉及物聯(lián)網(wǎng)技術(shù)領(lǐng)域，更具體地說，涉及一種支持物聯(lián)網(wǎng)中間件集群擴(kuò)展的方法和裝置。

背景技術(shù)

物聯(lián)網(wǎng)系統(tǒng)是由物聯(lián)網(wǎng)應(yīng)用程序、物聯(lián)網(wǎng)網(wǎng)關(guān)、物聯(lián)網(wǎng)中間件和物聯(lián)網(wǎng)感知層硬件節(jié)點(diǎn)組成的。物聯(lián)網(wǎng)中間件作為連接物聯(lián)網(wǎng)應(yīng)用程序與物聯(lián)網(wǎng)網(wǎng)關(guān)之間的橋梁，運(yùn)行在服務(wù)器上，隨著物聯(lián)網(wǎng)應(yīng)用程序與物聯(lián)網(wǎng)網(wǎng)關(guān)之間通信并發(fā)次數(shù)的增加，承載該物聯(lián)網(wǎng)中間件運(yùn)行的服務(wù)器的計(jì)算、網(wǎng)絡(luò)和存儲等資源將隨之降低并最后達(dá)到最高負(fù)荷，從而出現(xiàn)無法連接的問題。

在現(xiàn)有技術(shù)中，針對這種情況，物聯(lián)網(wǎng)中間件會(huì)建立與物聯(lián)網(wǎng)網(wǎng)關(guān)的長連接，使得物聯(lián)網(wǎng)應(yīng)用能夠隨時(shí)控制和獲取物聯(lián)網(wǎng)網(wǎng)關(guān)及物聯(lián)網(wǎng)硬件節(jié)點(diǎn)的信息。所謂長連接，指在一個(gè)連接上可以連續(xù)發(fā)送多個(gè)數(shù)據(jù)包，在連接保持期間，如果沒有數(shù)據(jù)包發(fā)送，需要雙方發(fā)鏈路檢測包，保證雙方連接不中斷。

當(dāng)物聯(lián)網(wǎng)應(yīng)用系統(tǒng)要控制物聯(lián)網(wǎng)感知硬件節(jié)點(diǎn)時(shí)，通過物聯(lián)網(wǎng)中間件集群的負(fù)載均衡轉(zhuǎn)發(fā)器將請求按照一定的策略轉(zhuǎn)發(fā)到某一個(gè)物聯(lián)網(wǎng)中間件服務(wù)器上。由于目前已有的負(fù)載均衡轉(zhuǎn)發(fā)器的協(xié)議并沒有考慮長連接的這種情況，就有可能導(dǎo)致請求被轉(zhuǎn)發(fā)到?jīng)]有與物聯(lián)網(wǎng)網(wǎng)關(guān)建立長連接的物聯(lián)網(wǎng)中間件服務(wù)器上，導(dǎo)致操作請求失敗。此外，由于存在物聯(lián)網(wǎng)網(wǎng)關(guān)與物聯(lián)網(wǎng)中間件的長連接，這使得對某一個(gè)物聯(lián)網(wǎng)感知硬件節(jié)點(diǎn)的控制，需要轉(zhuǎn)發(fā)到特定的物聯(lián)網(wǎng)中間件服務(wù)器上，使得負(fù)載均衡轉(zhuǎn)發(fā)器不能真正實(shí)現(xiàn)負(fù)載均衡的功能。

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

有鑒于此，本申請?zhí)峁┝艘环N支持物聯(lián)網(wǎng)中間件集群擴(kuò)展的方法和裝置，可以實(shí)現(xiàn)物聯(lián)網(wǎng)中間件的擴(kuò)展，從而保證物聯(lián)網(wǎng)系統(tǒng)中操作請求的順利進(jìn)行，進(jìn)一步還能使負(fù)載均衡轉(zhuǎn)發(fā)器真正實(shí)現(xiàn)負(fù)載均衡的功能。。

為了實(shí)現(xiàn)上述目的，現(xiàn)提出的方案如下：

一種支持物聯(lián)網(wǎng)中間件集群擴(kuò)展的方法，包括：

接收針對物聯(lián)網(wǎng)網(wǎng)關(guān)的控制指令，利用負(fù)載均衡轉(zhuǎn)發(fā)器將所述控制命令發(fā)往任意一個(gè)物聯(lián)網(wǎng)中間件的服務(wù)器；

若預(yù)先構(gòu)建的長連接緩存區(qū)中沒有存儲所述物聯(lián)網(wǎng)中間件與所述物聯(lián)網(wǎng)網(wǎng)關(guān)的長連接，且預(yù)先構(gòu)建的長連接映射表中存儲有所述物聯(lián)網(wǎng)網(wǎng)關(guān)的相關(guān)信息，則，

根據(jù)所述相關(guān)信息中攜帶的IP信息建立與所述物聯(lián)網(wǎng)網(wǎng)關(guān)的連接，并將所述控制指令發(fā)往所述物聯(lián)網(wǎng)網(wǎng)關(guān)。

優(yōu)選的，所述接收針對物聯(lián)網(wǎng)網(wǎng)關(guān)的控制指令之前，還包括：

根據(jù)接收到的物聯(lián)網(wǎng)網(wǎng)關(guān)發(fā)送的注冊消息，建立與所述物聯(lián)網(wǎng)網(wǎng)關(guān)的長連接；

將所述長連接存入所述預(yù)先構(gòu)建的長連接緩存區(qū)中，同時(shí)，將所述物聯(lián)網(wǎng)網(wǎng)關(guān)的相關(guān)信息以及所述物聯(lián)網(wǎng)中間件的相關(guān)信息作為映射關(guān)系存儲于預(yù)先構(gòu)建的長連接映射表中。

優(yōu)選的，所述物聯(lián)網(wǎng)網(wǎng)關(guān)的相關(guān)信息包括：物聯(lián)網(wǎng)網(wǎng)關(guān)的ID信息以及物聯(lián)網(wǎng)網(wǎng)關(guān)的IP信息。

優(yōu)選的，所述物聯(lián)網(wǎng)中間件的相關(guān)信息包括：物聯(lián)網(wǎng)中間件的ID信息以及物聯(lián)網(wǎng)中間件的IP信息。

優(yōu)選的，所述將所述控制指令發(fā)往所述物聯(lián)網(wǎng)網(wǎng)關(guān)之后，還包括：

根據(jù)接收的所述物聯(lián)網(wǎng)網(wǎng)關(guān)發(fā)送的注銷消息將所述長連接緩存區(qū)中存儲的長連接清除，同時(shí)，將所述長連接映射表中存儲的映射關(guān)系清除。

一種支持物聯(lián)網(wǎng)中間件集群擴(kuò)展的系統(tǒng)，包括：接收單元、構(gòu)建單元、判斷單元以及發(fā)送單元，其中：

所述接收單元，用于接收針對物聯(lián)網(wǎng)網(wǎng)關(guān)的控制指令，利用負(fù)載均衡轉(zhuǎn)發(fā)器將所述控制命令發(fā)往任意一個(gè)物聯(lián)網(wǎng)中間件的服務(wù)器；

所述構(gòu)建單元，用于預(yù)先構(gòu)建長連接緩存區(qū)以及長連接映射表；

分別與所述接收單元以及所述構(gòu)建單元相連的所述判斷單元，用于判斷所述構(gòu)建單元構(gòu)建的所述長連接緩存區(qū)中是否存儲有所述物聯(lián)網(wǎng)中間件與所述物聯(lián)網(wǎng)網(wǎng)關(guān)的長連接，以及，判斷所述預(yù)先構(gòu)建的長連接映射表中是否存儲有所述物聯(lián)網(wǎng)網(wǎng)關(guān)的相關(guān)信息；

與所述判斷單元相連的所述發(fā)送單元，用于當(dāng)預(yù)先構(gòu)建的長連接緩存區(qū)中沒有存儲所述物聯(lián)網(wǎng)中間件與所述物聯(lián)網(wǎng)網(wǎng)關(guān)的長連接，且預(yù)先構(gòu)建的長連接映射表中存儲有所述物聯(lián)網(wǎng)網(wǎng)關(guān)的相關(guān)信息時(shí)，根據(jù)所述相關(guān)信息中攜帶的IP信息建立與所述物聯(lián)網(wǎng)網(wǎng)關(guān)的連接，并將所述控制指令發(fā)往所述物聯(lián)網(wǎng)網(wǎng)關(guān)。

優(yōu)選的，還包括與所述接收單元相連的注冊單元，其中：

所述注冊單元包括建立單元以及存儲單元；

所述建立單元，用于根據(jù)接收到的物聯(lián)網(wǎng)網(wǎng)關(guān)發(fā)送的注冊消息，建立與所述物聯(lián)網(wǎng)網(wǎng)關(guān)的長連接；

所述存儲單元，用于將所述長連接存入所述預(yù)先構(gòu)建的長連接緩存區(qū)中，同時(shí)，將所述物聯(lián)網(wǎng)網(wǎng)關(guān)的相關(guān)信息以及所述物聯(lián)網(wǎng)中間件的相關(guān)信息作為映射關(guān)系存儲于預(yù)先構(gòu)建的長連接映射表中。