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

有效

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

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

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

若預(yù)先構(gòu)建的長(zhǎng)連接緩存區(qū)中沒(méi)有存儲(chǔ)所述物聯(lián)網(wǎng)中間件與所述物聯(lián)網(wǎng)網(wǎng)關(guān)的長(zhǎng)連接，且預(yù)先構(gòu)建的長(zhǎng)連接映射表中存儲(chǔ)有所述物聯(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)。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述接收針對(duì)物聯(lián)網(wǎng)網(wǎng)關(guān)的控制指令之前，還包括：

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

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

3.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述物聯(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信息。

4.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述物聯(lián)網(wǎng)中間件的相關(guān)信息包括：物聯(lián)網(wǎng)中間件的ID信息以及物聯(lián)網(wǎng)中間件的IP信息。

5.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述將所述控制指令發(fā)往所述物聯(lián)網(wǎng)網(wǎng)關(guān)之后，還包括：

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

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

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

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

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

與所述判斷單元相連的所述發(fā)送單元，用于當(dāng)預(yù)先構(gòu)建的長(zhǎng)連接緩存區(qū)中沒(méi)有存儲(chǔ)所述物聯(lián)網(wǎng)中間件與所述物聯(lián)網(wǎng)網(wǎng)關(guān)的長(zhǎng)連接，且預(yù)先構(gòu)建的長(zhǎng)連接映射表中存儲(chǔ)有所述物聯(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)。

7.根據(jù)權(quán)利要求6所述的系統(tǒng)，其特征在于，還包括與所述接收單元相連的注冊(cè)單元，其中：

所述注冊(cè)單元包括建立單元以及存儲(chǔ)單元；

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

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

8.根據(jù)權(quán)利要求7所述的系統(tǒng)，其特征在于，所述物聯(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信息。

9.根據(jù)權(quán)利要求7所述的系統(tǒng)，其特征在于，所述物聯(lián)網(wǎng)中間件的相關(guān)信息包括：物聯(lián)網(wǎng)中間件的ID信息以及物聯(lián)網(wǎng)中間件的IP信息。

10.根據(jù)權(quán)利要求7所述的系統(tǒng)，其特征在于，還包括與所述發(fā)送單元相連的注銷單元，用于根據(jù)接收的所述物聯(lián)網(wǎng)網(wǎng)關(guān)發(fā)送的注銷消息將所述長(zhǎng)連接緩存區(qū)中存儲(chǔ)的長(zhǎng)連接清除，同時(shí)，將所述長(zhǎng)連接映射表中存儲(chǔ)的映射關(guān)系清除。