一．功能簡(jiǎn)介

通過(guò)將報(bào)文分解為16進(jìn)制格式的字符串（比如：101C00044D51545404C2），再通過(guò)TPC-7062進(jìn)行組包，利用串口服務(wù)器的TCP/IP協(xié)議棧連接服務(wù)器，實(shí)現(xiàn)TCP客戶(hù)端透明傳輸連接MQTT服務(wù)器。

實(shí)現(xiàn)MQTT協(xié)議直連的前提是設(shè)備本身具有或者是外接串口聯(lián)網(wǎng)設(shè)備實(shí)現(xiàn)，比如筆者所使用的TPC7062是不具備TCP/IP協(xié)議棧的純串口控制屏，可通過(guò)連接億佰特公司所生產(chǎn)的串口服務(wù)器（NB114）實(shí)現(xiàn)TCP客戶(hù)端連接服務(wù)器。

NB114串口服務(wù)器本身就具對(duì)MQTT協(xié)議進(jìn)行封裝，可直接實(shí)現(xiàn)串口設(shè)備連接MQTT服務(wù)器，本文為了分析MQTT報(bào)文將不使用MQTT模式連接服務(wù)器，僅使用TCP客戶(hù)端模式連接MQTT服務(wù)器通過(guò)MCGS腳本對(duì)數(shù)據(jù)進(jìn)行組包發(fā)送。

二．報(bào)文詳解

TPC驅(qū)動(dòng)使用和字符轉(zhuǎn)換：

TPC7062使用官方提供的掃碼槍設(shè)備驅(qū)動(dòng)，實(shí)現(xiàn)該功能不可使用Modbus等具有協(xié)議的驅(qū)動(dòng)需，要使用支持串口數(shù)據(jù)透明傳輸?shù)脑O(shè)備驅(qū)動(dòng)。由于設(shè)備多處會(huì)使用到字符轉(zhuǎn)換，因此獨(dú)立配置三個(gè)“用戶(hù)策略”用于字符轉(zhuǎn)換：MQTT協(xié)議報(bào)文中TPC驅(qū)動(dòng)和字符轉(zhuǎn)換教程

MQTT字符長(zhǎng)度計(jì)算：PC7062封裝MQTT協(xié)議字符長(zhǎng)度計(jì)算教程

連接報(bào)文：PC7062封裝MQTT協(xié)議鏈接報(bào)文步驟教程

心跳報(bào)文：

PINGREQ：C0 00

服務(wù)器返回：D0 00

心跳報(bào)文基于MCGS的循環(huán)策略周期發(fā)送，

訂閱報(bào)文

SUBSCRIBE：82 +字符總長(zhǎng)度（遵循剩余字符算法）+00 00+訂閱地址長(zhǎng)度（2字節(jié)）+訂閱地址+服務(wù)等級(jí)（00、01、02）.....+訂閱地址+服務(wù)等級(jí)（00、01、02）（可同時(shí)訂閱多個(gè)主題）。

服務(wù)器響應(yīng)：9003000000(最大Qos0)，9003000001(最大QoS1)。

MCGS腳本配置如下：

第一步：初始化發(fā)送緩存變量；

第二步：為發(fā)送緩存變量寫(xiě)入報(bào)文標(biāo)識(shí)符（0000）；

第三步：傳入SUB-TOPIC字符到計(jì)算緩存變量，用于計(jì)算和字符轉(zhuǎn)換（調(diào)用前文提到的長(zhǎng)度計(jì)算腳本和ASCII轉(zhuǎn)HEX腳本）；

第四步：保存計(jì)算結(jié)果；

第五步：封裝服務(wù)等級(jí)僅支持0、1；

第六步：將之前的緩存的字符串傳入長(zhǎng)度計(jì)算算出字符總長(zhǎng)；

第七步：封裝報(bào)文頭及可變長(zhǎng)度；

第八步：等待服務(wù)器響應(yīng)；

若訂閱請(qǐng)求報(bào)文發(fā)送錯(cuò)誤（非服務(wù)器許可主題和服務(wù)等級(jí)）服務(wù)器會(huì)斷開(kāi)連接，因此超時(shí)后發(fā)送心跳更新在線(xiàn)狀態(tài)；

發(fā)布報(bào)文：PC7062封裝MQTT協(xié)議發(fā)布報(bào)文教程

三．實(shí)例演示

通過(guò)連接阿里云MQTT服務(wù)器，并使用阿里云NTP服務(wù)獲取當(dāng)前時(shí)間，請(qǐng)求格式參考阿里云用戶(hù)手冊(cè)NTP服務(wù)。

審核編輯黃昊宇