[發(fā)明專利]一種實(shí)現(xiàn)多路復(fù)用的MQTT協(xié)議通信方法及系統(tǒng)

在審

• 申請(qǐng)?zhí)枺?/td>: 202010754458.1
• 申請(qǐng)日: 2020-07-31
• 公開（公告）號(hào): CN111741129A
• 公開（公告）日: 2020-10-02
• 發(fā)明（設(shè)計(jì)）人: 王順;劉爽;閔濟(jì)海;葉增軍;姜紅杉
• 申請(qǐng)（專利權(quán)）人: 南京天創(chuàng)電子技術(shù)有限公司
• 主分類號(hào): H04L29/08
• 分類號(hào): H04L29/08;H04L29/06
• 代理公司: 南京華恒專利代理事務(wù)所(普通合伙) 32335
• 代理人: 裴素艷

1.一種實(shí)現(xiàn)多路復(fù)用的MQTT協(xié)議通信方法，其特征在于：具體步驟如下：

步驟1、在傳輸層建立若干TCP通道，同一組MQTT客戶端共用同一條TCP通道與MQTT代理服務(wù)器進(jìn)行通信連接，即：將同一組的若干MQTT客戶端與TCP通道構(gòu)成一對(duì)多映射關(guān)系，該一對(duì)多映射關(guān)系根據(jù)MQTT客戶端的登錄和離線動(dòng)態(tài)生成；

步驟2、在MQTT客戶端通過TCP通道登錄MQTT代理服務(wù)器，MQTT代理服務(wù)器獲取MQTT客戶端與TCP通道之間的映射關(guān)系，記錄到MQTT客戶端-TCP通道映射關(guān)系表中；

步驟3，工作時(shí)，當(dāng)MQTT代理服務(wù)器需要進(jìn)行消息轉(zhuǎn)發(fā)時(shí)，首先通過MQTT客戶端ID來查詢檢測該MQTT客戶端-TCP通道映射表，若找到對(duì)應(yīng)的TCP通道且確定對(duì)應(yīng)的MQTT客戶端，則MQTT代理服務(wù)器接著進(jìn)行消息轉(zhuǎn)發(fā)，否則轉(zhuǎn)發(fā)給該MQTT客戶端的消息被丟棄。

2.根據(jù)權(quán)利要求1所述的實(shí)現(xiàn)多路復(fù)用的MQTT協(xié)議通信方法，其特征在于：所述步驟3中在查詢檢測MQTT客戶端和TCP通道之間的一對(duì)多映射關(guān)系表時(shí)，分別獨(dú)立判斷TCP通道是否在線和MQTT客戶端是否在線。

3.根據(jù)權(quán)利要求1所述的實(shí)現(xiàn)多路復(fù)用的MQTT協(xié)議通信方法，其特征在于：所述步驟3中判斷TCP通道是否在線時(shí)以TCP通道是否收發(fā)消息數(shù)據(jù)為依據(jù)；若TCP通道沒有收發(fā)消息數(shù)據(jù)，則判斷TCP通道離線，并判斷與該TCP通道連接的對(duì)應(yīng)若干MQTT客戶端也為離線，然后將消息數(shù)據(jù)丟棄；若TCP通道能夠收發(fā)消息數(shù)據(jù)則判斷TCP通道在線，且與之關(guān)聯(lián)的MQTT客戶端的在線狀態(tài)保持不變。

4.根據(jù)權(quán)利要求1所述的實(shí)現(xiàn)多路復(fù)用的MQTT協(xié)議通信方法，其特征在于：所述步驟3中判斷MQTT客戶端是否在線判斷時(shí)以MQTT代理服務(wù)器是否收到MQTT客戶端發(fā)送的MQTT心跳幀為依據(jù)，若MQTT代理服務(wù)器能夠收到某一MQTT客戶端發(fā)送的MQTT心跳幀，則判斷該MQTT客戶端在線，否則判斷該MQTT客戶端離線，并將消息數(shù)據(jù)丟棄。

5.根據(jù)權(quán)利要求1所述的實(shí)現(xiàn)多路復(fù)用的MQTT協(xié)議通信方法，其特征在于：所述MQTT代理服務(wù)器的另一端通過TCP通道與標(biāo)準(zhǔn)MQTT客戶端通信。

6.一種執(zhí)行權(quán)利要求1至5任意一項(xiàng)所述的實(shí)現(xiàn)多路復(fù)用的MQTT協(xié)議通信方法的系統(tǒng)，其特征在于：包括MQTT代理服務(wù)器、標(biāo)準(zhǔn)MQTT客戶端和若干組MQTT客戶端；傳輸層中MQTT代理服務(wù)器與不同組MQTT客戶端之間通過對(duì)應(yīng)的TCP通道連接，建立多個(gè)TCP連接請(qǐng)求，通過MQTT客戶端登錄MQTT代理服務(wù)器時(shí)，先通過MQTT客戶端ID來查新獲取該MQTT客戶端與TCP通道之間的一對(duì)多映射關(guān)系；進(jìn)行消息收發(fā)時(shí)，分別獨(dú)立判斷TCP通道是否在線以及MQTT客戶端是否在線判斷；最終MQTT代理服務(wù)器實(shí)現(xiàn)多路復(fù)用；MQTT代理服務(wù)器的另一端通過TCP通道與標(biāo)準(zhǔn)MQTT客戶端通信。

7.一種計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)，其特征在于，所述計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)存儲(chǔ)有計(jì)算機(jī)程序，該計(jì)算機(jī)程序使計(jì)算機(jī)執(zhí)行時(shí)實(shí)現(xiàn)如權(quán)利要求1~5任意一項(xiàng)所述的實(shí)現(xiàn)多路復(fù)用的MQTT協(xié)議通信方法。