【干货】超详细!TPC7062封装MQTT协议教程

电子说

1.2w人已加入

描述

一.功能简介

通过将报文分解为16进制格式的字符串(比如:101C00044D51545404C2),再通过TPC-7062进行组包,利用串口服务器的TCP/IP协议栈连接服务器,实现TCP客户端透明传输连接MQTT服务器。

实现MQTT协议直连的前提是设备本身具有或者是外接串口联网设备实现,比如笔者所使用的TPC7062是不具备TCP/IP协议栈的纯串口控制屏,可通过连接亿佰特公司所生产的串口服务器(NB114)实现TCP客户端连接服务器。

NB114串口服务器本身就具对MQTT协议进行封装,可直接实现串口设备连接MQTT服务器,本文为了分析MQTT报文将不使用MQTT模式连接服务器,仅使用TCP客户端模式连接MQTT服务器通过MCGS脚本对数据进行组包发送。

二.报文详解

TPC驱动使用和字符转换:

TPC7062使用官方提供的扫码枪设备驱动,实现该功能不可使用Modbus等具有协议的驱动需,要使用支持串口数据透明传输的设备驱动。由于设备多处会使用到字符转换,因此独立配置三个“用户策略”用于字符转换:MQTT协议报文中TPC驱动和字符转换教程

MQTT字符长度计算:PC7062封装MQTT协议字符长度计算教程

连接报文:PC7062封装MQTT协议链接报文步骤教程

心跳报文:

PINGREQ:C0 00

服务器返回:D0 00

心跳报文基于MCGS的循环策略周期发送,

封装


 

封装


 

订阅报文

SUBSCRIBE:82 +字符总长度(遵循剩余字符算法)+00 00+订阅地址长度(2字节)+订阅地址+服务等级(00、01、02).....+订阅地址+服务等级(00、01、02)(可同时订阅多个主题)。

服务器响应:9003000000(最大Qos0),9003000001(最大QoS1)。

MCGS脚本配置如下:

封装

第一步:初始化发送缓存变量;

第二步:为发送缓存变量写入报文标识符(0000);

第三步:传入SUB-TOPIC字符到计算缓存变量,用于计算和字符转换(调用前文提到的长度计算脚本和ASCII转HEX脚本);

第四步:保存计算结果;

封装

第五步:封装服务等级仅支持0、1;

封装

第六步:将之前的缓存的字符串传入长度计算算出字符总长;

封装

第七步:封装报文头及可变长度;

封装

第八步:等待服务器响应;

封装

若订阅请求报文发送错误(非服务器许可主题和服务等级)服务器会断开连接,因此超时后发送心跳更新在线状态;

发布报文:PC7062封装MQTT协议发布报文教程  

三.实例演示

通过连接阿里云MQTT服务器,并使用阿里云NTP服务获取当前时间,请求格式参考阿里云用户手册NTP服务。

封装


 

审核编辑 黄昊宇

打开APP阅读更多精彩内容
声明:本文内容及配图由入驻作者撰写或者入驻合作网站授权转载。文章观点仅代表作者本人,不代表电子发烧友网立场。文章及其配图仅供工程师学习之用,如有内容侵权或者其他违规问题,请联系本站处理。 举报投诉

全部0条评论

快来发表一下你的评论吧 !

×
20
完善资料,
赚取积分