参数	是否必须	参数说明
clientId	否	用户自定义合法的UTF-8字符串，可为空
username	是	填写实例名称
password	是	填写token，算法见访问鉴权其中：res=mqs/$实例名称

另外，connnect报文中，keepalive、will、session字段的使用限制如下：

功能	是否支持	说明
keepalive	支持	支持范围为：30~4800s
will	不支持	will、will retain 的flag必须为0，will qos必须为0
session	不支持	cleansession标记必须为1

2 订阅主题

订阅报文

订阅报文中topic格式如下，不支持通配符

$sys/pb/consume/$实例名称/$TOPIC/$SUB

订阅时request QoS必须大于0，否则订阅失败
订阅确认报文

平台采用MQTT SubAck报文进行订阅确认，返回成功时返回码固定为0x01

Request QoS	SubAck返回码	说明
0	0x80	订阅失败
1	0x01	订阅成功，最大QoS为1
2	0x01	订阅成功，最大QoS为1

取消订阅报文

客户端使用MQTT Unsubscribe报文进行订阅取消
取消订阅确认报文

服务端使用MQTT UnsubAck报文进行订阅取消确认

3 消息消费

订阅成功后MQ会根据生产消息的情况，通过publish报文的主动推送给客户端
消费时MQ推送的消息只会是QoS1
客户端消费到数据后需要按照获取到的数据先后顺序使用puback报文回复

4 数据解析

客户端接收到publish报文后，按照MQTT协议解析其payload数据段，然后按照如下步骤解析payload数据内容

Step 1 安装protobuf

下载地址： https://github.com/protocolbuffers/protobuf/releases

Step 2 下载下述.proto文件

onenet-mq.proto接口文件如下：

syntax = "proto3";

package mq;

message Msg{
    uint64 msgid          = 1; //MQ中该消息的真实id
    bytes data            = 2; //具体的数据
    uint64 timestamp      = 3; //精确到ms
}

保存onenet-mq.proto文件至本地

Step 3 编译proto文件

根据语言编译该文件，以Java为例

protoc --java_out=$DST_DIR $SRC_DIR/onenet-mq.proto

Step 4 将编译生成的源文件添加到项目

以Java为例，编译后生成OnenetMq.java文件，将该源文件添加到项目

Step 5 读取数据

调用 parseFrom() 方法，创建Msg对象obj
调用 obj.getMsgid() 获取消息id
调用 obj.getData() 获取消息数据（查看数据格式）
调用 obj.getTimestamp() 获取消息毫秒级时间戳

Java示例如下：

OnenetMq.Msg obj;
obj = OnenetMq.Msg.parseFrom(mqttPayload);
System.out.println(obj.getMsgid());
System.out.println(new String(obj.getData().toByteArray()));
System.out.println(obj.getTimestamp());

消息队列MQ消费端开发指南

消费协议

SDK 下载

开发流程

1 客户端连接