Onenet mqtt数据通信整理

60 阅读 0 评论 40 点赞

我是靠谱客的博主懦弱汽车，最近开发中收集的这篇文章主要介绍Onenet mqtt数据通信整理，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

Onenet mqtt数据通信整理

（wangxl@20200707）

创建产品

1、选多协议接入--mqtt（旧版）---添加产品

创建设备

设备列表--添加设备

添加数据流模板power

设备端连接

1、建立mqtt连接（OneNET平台地址为 183.230.40.39 ：6002）

2、设备登陆上报信息(:CONNECT类型的数据包)
设备登陆报文是在建立TCP连接之后，用于告知OneNET平台，该终端DTU对应的是平台上的哪一个设备，数据用何种方式进行解析；
格式为根据MQTT报文协议V3.1.1中规定:

根据MQTT报文协议中规定，每一个MQTT包总共包含三部分：

（1）Fixed Header部分定义如下：

（2）CONNECT类型的消息是有可变报头和负载的。对于可变报头部分，按照以下格式编码：

（3）负载部分的数据是按照以下格式编码

3、生成登陆上报数据包

int mqtt_connect_messageV311(unsigned char *mqtt_message,char *client_id,char *username,char *password)

{

char i = 0;

char client_id_length = strlen(client_id);

int username_length = strlen(username);

int password_length = strlen(password);

int packetLen = 10 + 2 + client_id_length + 2 + username_length + 2 + password_length;

mqtt_message[0] = 16; // MQTT Message Type CONNECT

mqtt_message[1] = packetLen%256; //remainning length

baseIndex = 2;

if( packetLen >127 ){//

mqtt_message[2] = 1;//packetLen/127;

baseIndex = 3;

}

mqtt_message[baseIndex] = 0; // Protocol Name Length MSB

mqtt_message[baseIndex+1] = 4; // Protocol Name Length LSB

mqtt_message[baseIndex+2] = 77; // ASCII Code for M

mqtt_message[baseIndex+3] = 81; // ASCII Code for Q

mqtt_message[baseIndex+4] = 84; // ASCII Code for T

mqtt_message[baseIndex+5] = 84; // ASCII Code for T

mqtt_message[baseIndex+6] = 4; //MQTT协议版本 MQTT Protocol version = 3.1.1 这个必须固定为4，即3.1.1版，OneNET只支持这一版本协议，不支持更早版本的协议。

mqtt_message[baseIndex+7] = 194; // conn flags 0xc2 使能user flag 、password flag 、Cleaning Session flag ,不允许匿名登陆，因此user flag 、password flag这两个标志位在连接时必须设置为1，否则认为协议错误，平台将会断开连接

mqtt_message[baseIndex+8] = 0; // 保持连接以秒为单位高位 Length MSB，OneNET规定最短120秒，最长65535秒，这里设置的值180，也就是180秒

mqtt_message[baseIndex+9] = 180; // Keep-alive Time Length LSB

mqtt_message[baseIndex+10] = 0; // Client ID length MSB

mqtt_message[baseIndex+11] = client_id_length;// Client ID length LSB

baseIndex += 12;

// Client ID 即 onenet设备ID(DeviceID)"68888999"

for(i = 0; i < client_id_length; i++){

mqtt_message[baseIndex + i] = client_id[i];

}

baseIndex = baseIndex+client_id_length;

//username 即 onenet产品ID(ProduceID)"223344"

mqtt_message[baseIndex] = 0; //username length MSB

mqtt_message[baseIndex+1] = username_length; //username length LSB

baseIndex = baseIndex+2;

for(i = 0; i < username_length ; i++){

mqtt_message[baseIndex + i] = username[i];

}

baseIndex = baseIndex + username_length;

//password 即 onenet AuthCode 为鉴权信息（创建设备的时候所指定）"88888"

mqtt_message[baseIndex] = 0; //password length MSB

mqtt_message[baseIndex+1] = password_length; //password length LSB

baseIndex = baseIndex + 2;

for(i = 0; i < password_length ; i++){

mqtt_message[baseIndex + i] = password[i];

}

baseIndex += password_length;

return baseIndex;

}

发送hex：[37]10 23 00 04 4D 51 54 54 04 C2 00 B4 00 08 36 38 38 38 38 39 39 39 00 06 32 32 33 33 34 34 00 05 38 38 38 38 38

发送：[37]_x0010_#MQTT麓6888899922334488888

[2020-07-06 17:17:56 ] 接收hex[4]：20 02 01 00 //00 连接成功

4、发送CONNECT报文之后,OneNet平台上相应的设备在线。

五、数据上报

包文格式：固定报头+可变报头+负载

1、固定报头

根据MQTT协议规定的上传报文中的固定报头格式如下：

TCP负载第一个字节0x32中的“3”表示上传数据报文，其中的“2”表示QoS值为1

2、可变报头其报文格式如下：

（1）TopicName主题名：”$dp”，OneNET规定，”$dp”为系统上传数据点的指令;（2）PacketIdentifier报文标识符，QoS为1时，这两个字节是必须的，固定为0x00 0x0a。

3、负载Payload包含真正的数据点内容,支持的格式如下：

数据类型3(type == 3)格式说明：

Byte 1	数据点类型指示：type=3 // JSON格式2字符串	0	0	0	0	0	0	1	1
Byte 2	//指示后面字符串长度固定两字节长度高位字节
Byte 3	固定两字节长度低位字节
Byte 4	通用格式： { “datastream_id1”:”value1”, “datastream_id2”:”value2”, … } 示例： {“temperature”:22.5,”humidity”:”95.2%”}
… … … …




Byte n