[發(fā)明專(zhuān)利]一種實(shí)現(xiàn)同步請(qǐng)求響應(yīng)的MQTT協(xié)議通信方法

有效

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

1. 一種實(shí)現(xiàn)同步請(qǐng)求響應(yīng)的MQTT協(xié)議通信方法，包括MQTT代理服務(wù)器和多個(gè)MQTT客戶(hù)端，每個(gè)MQTT客戶(hù)端均與MQTT代理服務(wù)器建立一條用于發(fā)布和訂閱主題的TCP連接，即Message連接；其特征在于：每個(gè)MQTT客戶(hù)端還均與MQTT代理服務(wù)器之間另設(shè)一條用于同步通訊的TCP連接，即Service連接通道；MQTT協(xié)議中增加值為15的用于請(qǐng)求SERVICEREQ/響應(yīng)SERVICERSP的控制報(bào)文，該請(qǐng)求SERVICEREQ/響應(yīng)SERVICERSP控制報(bào)文包括固定報(bào)頭Fixedheader、可變報(bào)頭Variable header和有效載荷Payload；

MQTT協(xié)議的CONNECT控制報(bào)文的固定報(bào)頭中，其控制報(bào)文類(lèi)型標(biāo)志位0位用來(lái)表示創(chuàng)建的是Message連接還是Service連接，0代表Message連接，1表示Service連接；

MQTT協(xié)議的CONNACK控制報(bào)文的固定報(bào)頭中，其控制報(bào)文類(lèi)型標(biāo)志位0位表示連接確認(rèn)的是Message連接還是Service連接，0代表Message連接，1表示Service連接；

MQTT協(xié)議的PINGREQ控制報(bào)文固定報(bào)頭中，其控制報(bào)文類(lèi)型標(biāo)志位0位表示連接保活請(qǐng)求的是Message連接還是Service連接，0代表Message連接，1表示Service連接；

MQTT協(xié)議的PINGRSP控制報(bào)文固定報(bào)頭中，其控制報(bào)文類(lèi)型標(biāo)志位0位表示連接保活響應(yīng)的是Message連接還是Service連接，0代表Message連接，1表示Service連接；

MQTT協(xié)議的DISCONNECT控制報(bào)文固定報(bào)頭中，其控制報(bào)文類(lèi)型標(biāo)志位0位表示關(guān)閉的是Message連接還是Service連接，0代表Message連接，1表示Service連接；

實(shí)現(xiàn)同步請(qǐng)求響應(yīng)的MQTT協(xié)議通信方法為：

步驟1、若MQTT客戶(hù)端A要和MQTT客戶(hù)端B進(jìn)行請(qǐng)求響應(yīng)交互，則MQTT客戶(hù)端A和MQTT客戶(hù)端B首先在初始化時(shí)，需要?jiǎng)?chuàng)建Service連接通道并進(jìn)行周期保活操作；

步驟2、Service連接通道建立后，MQTT客戶(hù)端A發(fā)送SERVICEREQ請(qǐng)求給MQTT代理服務(wù)器，MQTT代理服務(wù)器將請(qǐng)求透?jìng)鹘oMQTT客戶(hù)端B，MQTT客戶(hù)端B解析所收到的請(qǐng)求內(nèi)容，并發(fā)送SERVICERSP請(qǐng)求給MQTT代理服務(wù)器，MQTT代理服務(wù)器將響應(yīng)透?jìng)鹘oMQTT客戶(hù)端A來(lái)處理；至此一個(gè)完整的請(qǐng)求響應(yīng)交互流程完成；

步驟3、當(dāng)MQTT客戶(hù)端A和MQTT客戶(hù)端B下線時(shí)，發(fā)送Service DISCONNECT關(guān)閉該Service連接通道。

2.根據(jù)權(quán)利要求1所述的實(shí)現(xiàn)同步請(qǐng)求響應(yīng)的MQTT協(xié)議通信方法，其特征在于：所述步驟2中MQTT代理請(qǐng)求響應(yīng)的轉(zhuǎn)發(fā)過(guò)程如下：

步驟2.1、MQTT代理服務(wù)器收到MQTT客戶(hù)端A發(fā)送的請(qǐng)求消息后，放到緩存池中；

步驟2.2、MQTT代理服務(wù)器從請(qǐng)求緩存池中取出請(qǐng)求消息根據(jù)消息接收客戶(hù)端標(biāo)識(shí)符轉(zhuǎn)發(fā)給MQTT客戶(hù)端B；

步驟2.3、MQTT客戶(hù)端B收到請(qǐng)求消息后給MQTT代理服務(wù)器發(fā)送一個(gè)響應(yīng)消息；

步驟2.4、MQTT代理服務(wù)器收到響應(yīng)消息存到響應(yīng)消息緩存池中，并將與之對(duì)應(yīng)的請(qǐng)求消息從請(qǐng)求消息緩沖池中移除，如果沒(méi)收到響應(yīng)消息或者M(jìn)QTT客戶(hù)端B不在線會(huì)在相應(yīng)時(shí)間段內(nèi)進(jìn)行多次嘗試；

步驟2.5、MQTT代理服務(wù)器從響應(yīng)消息緩存池中取出響應(yīng)消息根據(jù)消息接收客戶(hù)端標(biāo)識(shí)符轉(zhuǎn)發(fā)給MQTT客戶(hù)端A；

步驟2.6、MQTT客戶(hù)端A收到響應(yīng)消息給MQTT代理服務(wù)器回一個(gè)響應(yīng)確認(rèn)幀；

步驟2.7、MQTT代理服務(wù)器將該響應(yīng)消息從響應(yīng)消息緩沖池中去除，否則會(huì)嘗試多次重發(fā)。

3.根據(jù)權(quán)利要求1所述的實(shí)現(xiàn)同步請(qǐng)求響應(yīng)的MQTT協(xié)議通信方法，其特征在于：所述請(qǐng)求SERVICEREQ/響應(yīng)SERVICERSP控制報(bào)文中，固定報(bào)頭的控制報(bào)文類(lèi)型標(biāo)志位0位表示是請(qǐng)求還是響應(yīng)，0代表請(qǐng)求控制報(bào)文，1表示響應(yīng)控制報(bào)文；可變報(bào)頭Variable header的報(bào)文標(biāo)識(shí)符表示本次請(qǐng)求的唯一標(biāo)識(shí)，響應(yīng)的報(bào)文標(biāo)識(shí)符要和請(qǐng)求的報(bào)文標(biāo)識(shí)符相同。