mqtt
作者：如果能编程回忆
最后修改时间：2020年6月12日
概述
Air724模块内置MQTT协议，提供AT，LUAT，CSDK，DTU可供选择使用，接口简单使用方便。
MQTT简介
- 优势：长连接，低带宽，高可靠。
- 实用场景：需要服务器下发消息给设备，需要及时收到。例如，远程开关，充电桩等
几个重要名词
- username用户名，password密码，clientid用户标识，mqtt可以通过前两个参数保证连接的安全，通过clientid确保设备唯一性。
- qos消息质量，分为0，1，2三个等级，分别表示只发一次，至少收到一次和只收到一次，通过qos可以根据数据的重要性灵活选择发送方式以节省带宽和保证数据可靠。例如不重要的数据采集可使用qos0只发一次不关心服务器是否收到，重要的消息通过qos1确保能收到，付款信息危险设备开关等场景使用qos2保证数据到达的同时且不重复。
- host主机，port端口，mqtt需要连接的服务器参数。host可以说ip或者域名。
- topic主题，根据主题区别消息类型和来源，主要用来分类数据。同时mqtt是发布订阅模型，topic是发布和订阅者通信的重要通道。
- payload消息内容，发布和订阅的具体数据。
- retain保留消息，保留消息是一条将保留标志（retained flag）置为true的普通MQTT消息。broker会针对主题依照QoS级别保留最后一条保留消息，当订阅者订阅主题时会立即收到保留消息。broker仅为每个主题保留一条保留消息。
AT方式
连接网络
开机
通过拉低powerkey2秒进行开机，开机以后通过串口循环发送AT直到收到OK，如果90秒没有收到OK请拉低 RESET_IN_N 引脚 150ms 以上。或使用其他方法见开关机章节
查询卡状态
AT+CPIN?查询卡状态，直到收到+CPIN: READY，如果10s内没有收到建议重启模块
查询网络注册情况
AT+CGATT?查询是否注册网络收到+CGATT: 1值是1即为注册成功，正常情况下注册时间不会超过两分钟，如果超过两分钟没有注册可以进入飞行模式五秒后退出再查询，或者直接重启模块。
激活网络
AT+CSTT配置网络，非私有APN以外Cat1的固件支持根据卡自动配置APN，直接输入AT+CSTT即可，模块会按照自动获取的APN设置CSTT的APN。
AT+CIICR激活网络，在IP START的状态使用AT+CIICR激活网络，激活以后通过AT+CIFSR查询是否获取IP，如果成功就可以开始配置TCP连接了，如果不成功使用AT+CIPSHUT关闭移动网络，从AT+CSTT重新进行。
连接服务器
设置 MQTT 相关参数：AT+MCONFIG
| 命令类型 | 语法 | 返回 | 说明 |
|---|---|---|---|
| 设置命令 | AT+MCONFIG=[, [, , , , ]] |
OK | |
| ERROR | 正常返回 | ||
| 输入格式有误 | |||
| 测试命令 | AT+MCONFIG=? | +MCONFIG: [,[,(0-2),(0,1 ), , ]] |
|
| OK |
参数定义
| 参数 | 定义 | 取值 | 对取值的说明 |
|---|---|---|---|
| client identity | 字符串 | 最大 256 个字节。可以用”“括住，也可以不用”” | |
| username to login server | 字符串 | 最大 256 个字节。可以用”“括住，也可以不用”” | |
| password to login server | 字符串 | 最大 256 个字节。可以用”“括住，也可以不用”” | |
|
|
Quality of Service for will message | 0 |
PS：说明一下will_retain这个参数
终端设备publish消息时，如果retain值是true，则服务器会一直记忆，哪怕是服务器重启。因为会本地持久化。
如果服务器接收到终端publish某主题的消息，payload为空且retain值是true，则会删除这条持久化的消息。
如果服务器接收到终端publish某主题的消息，payload为空且retain值是false，则不会删除这条持久化的消息。
will_topic和will_message是遗嘱相关。
建立 TCP 连接：AT+MIPSTART或AT+SSLMIPSTART
语法规则：
普通链接： AT+MIPSTART=,
ssl连接：AT+SSLMIPSTART=,
返回OK表示成功，返回ERROR表示格式错误。
发送完这条指令后会有一些列URC上报。
1)单链接（AT+CIPMUX=0）
如果链接成功地建立，则上报： CONNECT OK
如果链接已经存在，则上报： ALREADY CONNECT
如果链接失败，则上报： STATE: CONNECT FAIL
2) 多链接（AT+CIPMUX=1） 如果链接成功地建立，则上报： 7,CONNECT OK
如果链接已经存在，则上报： ALREADY CONNECT
如果链接失败，则上报： 7,CONNECT FAIL
客户端向服务器请求会话连接：AT+MCONNECT
| 命令类型 | 语法 | 返回 | 说明 |
|---|---|---|---|
| 设置命令 | AT+MCONNECT= , |
OK | 设置成功 |
| 测试命令 | AT+MCONNECT=? | +MCONNECT:(0-1),(1-65535) | |
| OK | 测试命令的返回的是 和 的取值范围 |
||
| URC | 设置命令设置成功，返回OK后，后续会根据连接情况自动上报URC。 如果连接成功则返回：CONNACK OK 如果连接失败则返回：ERROR |
发布消息
| 命令类型 | 语法 | 返回 | 说明
| 设置命令 |
| AT+MPUB=,, , |
| PUBACK |
参数定义：
| 参数 | 定义 | 取值 | 取值说明 |
|---|---|---|---|
| 消息质量 | 0 | 只发一次 | |
| 1 | 最少到达一次 | ||
| 2 | 只有一次 | ||
| 消息保留标志 | 0 | 不保留 | |
| 1 | 保留 | ||
| 主题 | 字符串 | 最大 256 个字节。可以用”“括住，也可以不用”” | |
| 消息内容 | 字符串 | 最大 1360个字节。可以用”“括住，也可以不用”” 注:消息中内嵌的双引号请用\22 表达；控制字符 \r(0x0D)请用\0D 表达；控制字符\n（0x0A） 请用\0A 表达 如果是 MCU 发消息，请用\22，\0D，\0A 来 表达，即\需要转义成\ |
订阅消息
订阅主题：AT+MSUB
| 命令类型 | 语法 | 返回 | 说明 |
|---|---|---|---|
| 设置命令 | AT+MSUB=, | OK | |
| SUBACK | 成功 | ||
| ERROR | 失败 | ||
| 当输入设置命令成功以后，后续会有相应的URC上报。 当AT+MQTTMSGSET=0： +MSUB：,, | |||
| 当AT+MQTTMSGSET=1： +MSUB： |
参数定义：
| 参数 | 定义 | 取值 | 取值说明 |
|---|---|---|---|
| 主题 | 字符串 | 最大 256 个字节。可以用”“括住，也可以不用”” | |
| 消息质量 | 0 1 2 | 同前文 | |
| 数据长度 | 0到1360 | 单位：字节 | |
| 消息内容 | 字符串 | 最大1360字节 | |
|
|
消息编号 | 0到3 | 当订阅方式设置为缓存模式的时候收到消息会上报一条URC+MSUB： |
设置订阅消息的打印模式：AT+MQTTMSGSET
命令AT+MQTTMSGSET=成功返回OK失败返回ERROR,mode的取值是0或1，0为主动上报到串口。有新订阅消息时，上报的 URC 为： +MSUB：,,；1为缓存模式。有新订阅消息时，上报的 URC 为： +MSUB：
然后用 AT+MQTTMSGGET 来读消息。
打印收到的所有的订阅消息：AT+MQTTMSGGET
| 命令类型 | 语法 | 返回 | 说明 |
|---|---|---|---|
| 执行命令 | AT+MQTTMSGGET | [+MSUB: ,,] [+MSUB: ,,] [+MSUB: ,,] [+MSUB: ,,] | |
| OK | 执行命令将会打印收到的保 存在cache中的主题订阅消 息。执行完以后， 将会变成invalid。 | ||
| 查询命令 | AT+MQTTMSGGET? | +MQTTMSGGET：0, +MQTTMSGGET：1, +MQTTMSGGET：2, +MQTTMSGGET：3, | |
| OK | |||
| 测试命令 | AT+MQTTMSGGET=? | OK |
| 参数 | 定义 | 取值 | 取值说明 |
|---|---|---|---|
| 主题 | 字符串 | 最大256字节 | |
| 消息长度 | 0到1360 | 字节 | |
| 消息内容 | 字符串 | 最大1360字节 | |
| 消息状态 | VALID | 有数据, AT+MQTTMSGGET 执行模块 可以打印这些消息 | |
| INVALID | 没有数据 |
MQTT 消息编码格式切换：AT+MQTTMODE
命令AT+MQTTMODE=，成功返回OK失败返回ERROR,mode的取值是0或1，0为ASCII格式，1为HEX格式。
查询 MQTT 连接状态：AT+MQTTSTATU
命令AT+MQTTSTATU，成功返回+MQTTSTATU :OK，失败返回ERROR。
取值说明
| 值 | 状态 |
|---|---|
| 0 | 离线 |
| 1 | 已经认证可以发送数据 |
| 2 | 未认证，需要发送 MCONNECT 命令 |
LUAT方式
连接服务器
- 参数
| 传入值类型 | 释义 |
|---|---|
| string | clientId |
| number | 可选参数，默认为300，keepAlive 心跳间隔(单位为秒)，默认300秒 |
| string | 可选参数，默认为""，username 用户名，用户名为空配置为””或者nil |
| string | 可选参数，默认为""，password 密码，密码为空配置为””或者nil |
| number | 可选参数，默认为1，cleanSession 1/0 |
| table | 可选参数，默认为nil，will 遗嘱参数，格式为{qos=, retain=, topic=, payload=} |
| string | 可选参数，默认为"3.1.1"，version MQTT版本号 |
- 参数
| 传入值类型 | 释义 |
|---|---|
| string | host 服务器地址 |
| param | port string或者number类型，服务器端口 |
| string | 可选参数，默认为"tcp"，transport “tcp”或者”tcp_ssl” |
| table | 可选参数，默认为nil，cert，table或者nil类型，ssl证书，当transport为”tcp_ssl”时，此参数才有意义。cert格式如下： { caCert = “ca.crt”, –CA证书文件(Base64编码 X.509格式)，如果存在此参数，则表示客户端会对服务器的证书进行校验；不存在则不校验 clientCert = “client.crt”, –客户端证书文件(Base64编码 X.509格式)，服务器对客户端的证书进行校验时会用到此参数 clientKey = “client.key”, –客户端私钥文件(Base64编码 X.509格式) clientPassword = “”, –客户端证书文件密码[可选] } |
| number | timeout, 链接服务器最长超时时间 |
返回值
result true表示成功，false或者nil表示失败
订阅主题
mqttc:subscribe(topic, qos)
- 参数
| 传入值类型 | 释义 |
|---|---|
| param | topic，string或者table类型，一个主题时为string类型，多个主题时为table类型，主题内容为UTF8编码 |
| param | 可选参数，默认为0，qos，number或者nil，topic为一个主题时，qos为number类型(0/1/2，默认0)；topic为多个主题时，qos为nil |
返回值
- 参数
| 传入值类型 | 释义 |
|---|---|
| param | topic，string或者table类型，一个主题时为string类型，多个主题时为table类型，主题内容为UTF8编码 |
- 返回值
bool true表示成功，false或者nil表示失败
mqttc:receive(timeout, msg)
接收消息
- 参数
| 传入值类型 | 释义 |
|---|---|
| number | timeout 接收超时时间，单位毫秒 |
| string | 可选参数，默认为nil，msg 可选参数，控制socket所在的线程退出recv阻塞状态 |
- 返回值
local mqttc = mqtt.client(misc.getImei(), 300, "user", "password") while not mqttc:connect(host, port) do sys.wait(2000) end if mqttc:subscribe(string.format("/device/%s/req", misc.getImei())) then if mqttc:publish(string.format("/device/%s/report", misc.getImei()), "test publish " .. os.time()) then while true do local r, data, param = mqttc:receive(, "pub_msg") if r then log.info("这是收到了服务器下发的消息:", data.payload or "nil") elseif data == "pub_msg" then log.info("这是收到了订阅的消息和参数显示:", data, param) mqttc:publish(string.format("/device/%s/resp", misc.getImei()), "response " .. param) elseif data == "timeout" then log.info("这是等待超时主动上报数据的显示!") mqttc:publish(string.format("/device/%s/report", misc.getImei()), "test publish " .. os.time()) else -- 网络链接被断开 break end end end end mqttc:disconnect() 在连接服务器成功以后，代码进入这个死循环，recv(, “pub_msg”)里的第一个参数表示最长阻塞时间，这个时间的主要作用是用于心跳维持连接，因为timeout退出阻塞的前提是在这个时间内没有发送和接收数据；第二个参数是控制退出的字符串，其原理类似于sys.subscribe(id, callback)msg就是id，用于订阅来自其他协程的数据，发送数据的方法就是sys.publish(…)触发时rev会退出并携带参数；
发布消息
mqttc:publish(topic, payload, qos, retain)
发布一条消息
- 参数
| 传入值类型 | 释义 |
|---|---|
| string | topic UTF8编码的字符串 |
| string | payload 用户自己控制payload的编码，mqtt.lua不会对payload做任何编码转换 |
| number | 可选参数，默认为0，qos 0/1/2, default 0 |
| number | 可选参数，默认为0，retain 0或者1 |
- 返回值
bool 发布成功返回true，失败返回false
- 例子
断开连接
mqttc:disconnect()
断开与服务器的连接
- 参数
无
- 返回值
nil
- 例子
mqttc = mqtt.client("clientid-123", nil, nil, false) mqttc:connect("mqttserver.com", 1883, "tcp") process data mqttc:disconnect() CSDK
DTU固件
发布者：全栈程序员-站长，转载请注明出处：https://javaforall.net/209393.html原文链接：https://javaforall.net
