MQTT AT 示例¶
本文档主要提供在 ESP 设备上运行 MQTT AT Commands 命令的详细示例。
重要
文档中所描述的例子均基于设备已连接 Wi-Fi 的前提。
基于 TCP 的 MQTT 连接（需要本地创建 MQTT 代理）（适用于数据量少）¶
以下示例同时使用两块 ESP32 开发板，其中一块作为 MQTT 发布者（只作为 MQTT 发布者角色），另一块作为 MQTT 订阅者（只作为 MQTT 订阅者角色）。
示例介绍了如何基于 TCP 创建 MQTT 连接。首先您需要创建一个本地 MQTT 代理，假设 MQTT 代理的 IP 地址为 192.168.3.102，端口为 8883。
重要
步骤中以 ESP32 MQTT 发布者 开头的操作只需要在 ESP32 MQTT 发布者端执行即可，以 ESP32 MQTT 订阅者 开头的操作只需要在 ESP32 MQTT 订阅者端执行即可。如果操作没有特别指明在哪端操作，则需要在发布者端和订阅者端都执行。
设置 MQTT 用户属性。
ESP32 MQTT 发布者：
命令：
AT+MQTTUSERCFG=0,1,"publisher","espressif","123456789",0,0,""
响应：
OK
ESP32 MQTT 订阅者：
命令：
AT+MQTTUSERCFG=0,1,"subscriber","espressif","123456789",0,0,""
响应：
OK
连接 MQTT 代理。
命令：
AT+MQTTCONN=0,"192.168.3.102",8883,1
响应：
+MQTTCONNECTED:0,1,"192.168.3.102","8883","",1 OK
说明：
您输入的 MQTT 代理域名或 MQTT 代理 IP 地址可能与上述命令中的不同。
订阅 MQTT 主题。
ESP32 MQTT 订阅者：
命令：
AT+MQTTSUB=0,"topic",1
响应：
OK
发布 MQTT 消息（字符串）。
ESP32 MQTT 发布者：
命令：
AT+MQTTPUB=0,"topic","test",1,0
响应：
OK
说明：
如果 ESP32 MQTT 发布者成功发布消息，以下信息将会在 ESP32 MQTT 订阅者端提示。
+MQTTSUBRECV:0,"topic",4,test
关闭 MQTT 连接。
命令：
AT+MQTTCLEAN=0
响应：
OK
基于 TCP 的 MQTT 连接（需要本地创建 MQTT 代理）（适用于数据量多）¶
以下示例同时使用两块 ESP32 开发板，其中一块作为 MQTT 发布者（只作为 MQTT 发布者角色），另一块作为 MQTT 订阅者（只作为 MQTT 订阅者角色）。
示例介绍了如何基于 TCP 创建 MQTT 连接。首先您需要创建一个本地 MQTT 代理，假设 MQTT 代理的 IP 地址为 192.168.3.102，端口为 8883。
如果您发布消息的数据量相对较多，已经超过了单条 AT 指令的长度阈值 256，则建议您可以使用 AT+MQTTPUBRAW 命令。
重要
步骤中以 ESP32 MQTT 发布者 开头的操作只需要在 ESP32 MQTT 发布者端执行即可，以 ESP32 MQTT 订阅者 开头的操作只需要在 ESP32 MQTT 订阅者端执行即可。如果操作没有特别指明在哪端操作，则需要在发布者端和订阅者端都执行。
设置 MQTT 用户属性。
ESP32 MQTT 发布者：
命令：
AT+MQTTUSERCFG=0,1,"publisher","espressif","123456789",0,0,""
响应：
OK
ESP32 MQTT 订阅者：
命令：
AT+MQTTUSERCFG=0,1,"subscriber","espressif","123456789",0,0,""
响应：
OK
连接 MQTT 代理。
命令：
AT+MQTTCONN=0,"192.168.3.102",8883,1
响应：
+MQTTCONNECTED:0,1,"192.168.3.102","8883","",1 OK
说明：
您输入的 MQTT 代理域名或 MQTT 代理 IP 地址可能与上述命令中的不同。
订阅 MQTT 主题。
ESP32 MQTT 订阅者：
命令：
AT+MQTTSUB=0,"topic",1
响应：
OK
发布 MQTT 消息（字符串）。
假设你想要发布消息的数据如下，长度为 427 字节。
{"headers": {"Accept": "application/json","Accept-Encoding": "gzip, deflate","Accept-Language": "en-US,en;q=0.9,zh-CN;q=0.8,zh;q=0.7","Content-Length": "0","Host": "httpbin.org","Origin": "http://httpbin.org","Referer": "http://httpbin.org/","User-Agent": "Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/91.0.4472.114 Safari/537.36","X-Amzn-Trace-Id": "Root=1-6150581e-1ad4bd5254b4bf5218070413"}}ESP32 MQTT 发布者：
命令：
AT+MQTTPUBRAW=0,"topic",427,0,0
响应：
OK >
上述响应表示 AT 已准备好接收串行数据，此时您可以输入数据，当 AT 接收到的数据长度达到
<length>后，数据传输开始。+MQTTPUB:OK
说明：
AT输出>字符后，数据中的特殊字符不需要转义字符进行转义，也不需要以新行结尾（CR-LF）。如果 ESP32 MQTT 发布者成功发布消息，以下信息将会在 ESP32 MQTT 订阅者端提示。
+MQTTSUBRECV:0,"topic",427,{"headers": {"Accept": "application/json","Accept-Encoding": "gzip, deflate","Accept-Language": "en-US,en;q=0.9,zh-CN;q=0.8,zh;q=0.7","Content-Length": "0","Host": "httpbin.org","Origin": "http://httpbin.org","Referer": "http://httpbin.org/","User-Agent": "Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/91.0.4472.114 Safari/537.36","X-Amzn-Trace-Id": "Root=1-6150581e-1ad4bd5254b4bf5218070413"}}
关闭 MQTT 连接。
命令：
AT+MQTTCLEAN=0
响应：
OK
基于 TLS 的 MQTT 连接（需要本地创建 MQTT 代理）¶
以下示例同时使用两块 ESP32 开发板，其中一块作为 MQTT 发布者（只作为 MQTT 发布者角色），另一块作为 MQTT 订阅者（只作为 MQTT 订阅者角色）。
示例介绍了如何基于 TLS 创建 MQTT 连接。首先您需要创建一个本地 MQTT 代理，假设 MQTT 代理的 IP 地址为 192.168.3.102，端口为 8883。
重要
步骤中以 ESP32 MQTT 发布者 开头的操作只需要在 ESP32 MQTT 发布者端执行即可，以 ESP32 MQTT 订阅者 开头的操作只需要在 ESP32 MQTT 订阅者端执行即可。如果操作没有特别指明在哪端操作，则需要在发布者端和订阅者端都执行。
设置时区和 SNTP 服务器。
命令：
AT+CIPSNTPCFG=1,8,"ntp1.aliyun.com"
响应：
OK
查询 SNTP 时间。
命令：
AT+CIPSNTPTIME?
响应：
+CIPSNTPTIME:Thu Sep 2 18:57:03 2021 OK
说明：
您的查询 SNTP 结果可能与上述响应中的不同。
请确保 SNTP 时间一定是真实有效的时间，不能是 1970 年及之前的时间。
设置时间是为了在 TLS 认证时校验证书的有效期。
设置 MQTT 用户属性。
ESP32 MQTT 发布者：
命令：
AT+MQTTUSERCFG=0,4,"publisher","espressif","123456789",0,0,""
响应：
OK
ESP32 MQTT 订阅者：
命令：
AT+MQTTUSERCFG=0,4,"subscriber","espressif","123456789",0,0,""
响应：
OK
设置 MQTT 连接属性。
命令：
AT+MQTTCONNCFG=0,0,0,"lwtt","lwtm",0,0
响应：
OK
连接 MQTT 代理。
命令：
AT+MQTTCONN=0,"192.168.3.102",8883,1
响应：
+MQTTCONNECTED:0,4,"192.168.3.102","8883","",1 OK
说明：
您输入的 MQTT 代理域名或 MQTT 代理 IP 地址可能与上述命令中的不同。
订阅 MQTT 主题。
ESP32 MQTT 订阅者：
命令：
AT+MQTTSUB=0,"topic",1
响应：
OK
发布 MQTT 消息（字符串）。
ESP32 MQTT 发布者：
命令：
AT+MQTTPUB=0,"topic","test",1,0
响应：
OK
说明：
如果 ESP32 MQTT 发布者成功发布消息，以下信息将会在 ESP32 MQTT 订阅者端提示。
+MQTTSUBRECV:0,"topic",4,test
关闭 MQTT 连接。
命令：
AT+MQTTCLEAN=0
响应：
OK
基于 WSS 的 MQTT 连接¶
以下示例同时使用两块 ESP32 开发板，其中一块作为 MQTT 发布者（只作为 MQTT 发布者角色），另一块作为 MQTT 订阅者（只作为 MQTT 订阅者角色）。
示例介绍了如何基于 WSS 创建 MQTT 连接。MQTT 代理域名为 test.mosquitto.org，端口为 8081 。
重要
步骤中以 ESP32 MQTT 发布者 开头的操作只需要在 ESP32 MQTT 发布者端执行即可，以 ESP32 MQTT 订阅者 开头的操作只需要在 ESP32 MQTT 订阅者端执行即可。如果操作没有特别指明在哪端操作，则需要在发布者端和订阅者端都执行。
设置时区和 SNTP 服务器。
命令：
AT+CIPSNTPCFG=1,8,"ntp1.aliyun.com"
响应：
OK
查询 SNTP 时间。
命令：
AT+CIPSNTPTIME?
响应：
+CIPSNTPTIME:Thu Sep 2 18:57:03 2021 OK
说明：
您的查询 SNTP 结果可能与上述响应中的不同。
请确保 SNTP 时间一定是真实有效的时间，不能是 1970 年及之前的时间。
设置时间是为了在 TLS 认证时校验证书的有效期。
设置 MQTT 用户属性。
ESP32 MQTT 发布者：
命令：
AT+MQTTUSERCFG=0,7,"publisher","espressif","1234567890",0,0,""
响应：
OK
ESP32 MQTT 订阅者：
命令：
AT+MQTTUSERCFG=0,7,"subscriber","espressif","1234567890",0,0,""
响应：
OK
连接 MQTT 代理。
命令：
AT+MQTTCONN=0,"test.mosquitto.org",8081,1
响应：
+MQTTCONNECTED:0,7,"test.mosquitto.org","8081","/",1 OK
说明：
您输入的 MQTT 代理域名或 MQTT 代理 IP 地址可能与上述命令中的不同。
订阅 MQTT 主题。
ESP32 MQTT 订阅者：
命令：
AT+MQTTSUB=0,"topic",1
响应：
OK
发布 MQTT 消息（字符串）。
ESP32 MQTT 发布者：
命令：
AT+MQTTPUB=0,"topic","test",1,0
响应：
OK
说明：
如果 ESP32 MQTT 发布者成功发布消息，以下信息将会在 ESP32 MQTT 订阅者端提示。
+MQTTSUBRECV:0,"topic",4,test
关闭 MQTT 连接。
命令：
AT+MQTTCLEAN=0
响应：
OK