STM32 进阶封神之路二十七MQTT 深度解析 —— 从协议原理到 OneNET 云平台接入底层逻辑 AT 指令开发上一篇我们掌握了 ESP8266 的 TCP 通信和透传实战这一篇聚焦物联网核心协议 ——MQTTMessage Queuing Telemetry Transport以及国内主流物联网云平台OneNET的接入开发。MQTT 是轻量级、低带宽的物联网通信协议专为受限设备和低功耗网络设计而 OneNET 提供了设备管理、数据存储、远程控制等一站式物联网解决方案两者结合是物联网项目的主流技术选型。本文基于 STM32F103ESP8266从 MQTT 协议底层原理、核心特性、报文格式到 OneNET 云平台设备创建、MQTT 连接配置、数据上传与远程控制手把手带你吃透 MQTT 协议和云平台接入逻辑为实战开发打下坚实基础一、MQTT 核心认知为什么它是物联网 “首选协议”1. MQTT 的核心定位与应用场景1核心定位MQTT 是 IBM 于 1999 年推出的基于发布 / 订阅Publish/Subscribe模式的轻量级物联网通信协议运行在 TCP/IP 协议之上核心目标是 “用最少的带宽和资源实现设备与云平台的可靠通信”。2核心优势对比 TCP 直连表格对比维度MQTT 协议TCP 直连带宽占用极低报文头仅 2 字节较高无统一报文格式冗余数据多资源消耗低适合 MCU、ESP8266 等受限设备较高需手动处理连接、重连、数据解析通信模式发布 / 订阅多设备间解耦通信点对点一对一通信多设备扩展复杂可靠性支持 QoS 等级0/1/2确保数据传输需手动实现重传、校验可靠性差功能扩展支持遗嘱消息、保留消息、主题过滤无原生扩展功能需自定义3典型应用场景低功耗设备传感器节点温湿度、光照、智能穿戴设备窄带宽网络2G/4G/NB-IoT 等无线通信场景多设备通信智能家居多个传感器上传数据手机 APP 远程控制云平台接入OneNET、阿里云、腾讯云等物联网平台的标准接入协议。2. MQTT 核心概念必掌握1发布 / 订阅模式Publish/SubscribeMQTT 的核心通信模式通过 “主题Topic” 实现设备间解耦通信无需直接建立连接发布者Publisher发送数据的设备如 STM32ESP8266 采集温湿度后发布数据订阅者Subscriber接收数据的设备 / 平台如 OneNET 云平台、手机 APP主题Topic数据的 “路径标识”类似文件系统路径如/stm32/dht11/temp发布者向主题发送数据订阅者订阅主题即可接收数据** broker代理服务器**接收发布者的消息转发给订阅对应主题的订阅者如 OneNET 云平台内置 MQTT broker。2QoS 服务质量等级Quality of ServiceMQTT 支持 3 种 QoS 等级适配不同可靠性需求表格QoS 等级核心定义传输机制适用场景QoS 0最多一次消息最多传输一次可能丢失发送者发送一次不等待确认非关键数据如普通温湿度采集QoS 1至少一次消息至少传输一次可能重复发送者发送后等待确认PUBACK未确认则重发重要数据如设备告警QoS 2恰好一次消息恰好传输一次无丢失无重复两次握手PUBREC→PUBREL→PUBCOMP确保仅传输一次关键数据如金融支付、设备控制指令3其他核心概念客户端 IDClient IDMQTT 客户端的唯一标识需在云平台注册如stm32_esp8266_001遗嘱消息Will Message设备异常断开连接时broker 自动发送的消息如 “设备离线”保留消息Retained Messagebroker 存储的最新消息新订阅者订阅主题后立即接收该消息用户名 / 密码Username/PasswordMQTT 连接认证信息由云平台分配如 OneNET 的设备 ID 和 API 密钥。3. MQTT 报文格式深度解析底层逻辑MQTT 报文是设备与 broker 通信的基础所有操作连接、发布、订阅、断开均通过报文实现核心格式如下1报文总体结构plaintext固定头Fixed Header 可变头Variable Header 有效载荷Payload2固定头所有报文必含长度2 字节起包含 “报文类型” 和 “剩余长度”第 1 字节控制字节高 4 位报文类型如 0x10CONNECT0x30PUBLISH0x82SUBACK低 4 位标志位如 QoS 等级、保留位第 2 字节起剩余长度表示可变头 有效载荷的总长度采用可变长度编码节省带宽。3常用报文类型及功能表格报文类型控制字节核心功能适用场景CONNECT0x10客户端向 broker 发起连接设备上电后连接云平台CONNACK0x20broker 响应连接请求成功 / 失败确认连接状态PUBLISH0x30~0x33客户端发布消息到主题传感器数据上传PUBACK0x40响应 QoS 1 的 PUBLISH 消息确认 QoS 1 消息接收SUBSCRIBE0x82客户端订阅主题手机 APP 订阅设备数据SUBACK0x90broker 响应订阅请求确认订阅成功DISCONNECT0xE0客户端主动断开连接设备正常关机4. MQTT 通信流程以设备上传数据为例设备MQTT 客户端通过 TCP 连接云平台的 MQTT broker默认端口 1883设备发送 CONNECT 报文含 Client ID、用户名、密码向 broker 请求连接broker 验证信息后发送 CONNACK 报文响应码 0 表示连接成功设备发送 PUBLISH 报文向指定主题如/stm32/dht11发布数据温湿度云平台订阅该主题接收 PUBLISH 报文存储数据并转发给其他订阅者如手机 APP设备完成数据上传后可发送 DISCONNECT 报文断开连接或保持连接等待下一次上传。二、OneNET 云平台基础配置MQTT 接入前置准备OneNET 是中国移动推出的物联网开放平台支持 MQTT、HTTP 等多种接入方式提供设备管理、数据存储、可视化等功能以下是 MQTT 接入的基础配置步骤1. 注册 OneNET 账号并创建产品访问 OneNET 官网https://open.iot.10086.cn/注册并登录账号进入 “开发者中心”点击 “创建产品”填写产品信息产品名称如 “STM32 传感器节点”产品类型选择 “智能硬件→传感器”网络类型选择 “WiFi”接入协议选择 “MQTT”数据格式选择 “自定义 JSON”点击 “确认创建”获取产品 ID后续 MQTT 连接需使用。2. 添加设备并获取认证信息进入创建的产品点击 “添加设备”填写设备名称如 “STM32_ESP8266_001”其他参数默认设备创建成功后获取核心认证信息MQTT 连接必需设备 ID设备的唯一标识如123456789设备密钥APIKey设备认证密码如abcdef1234567890MQTT broker 地址OneNET 的 MQTT 服务器地址mqtts.heclouds.comSSL 加密端口 8883非加密端口 1883。3. 创建数据点可选用于数据可视化进入产品的 “数据点管理”点击 “添加数据点”填写数据点信息如 “温度”标识符temp数据类型float单位℃“湿度”标识符humidity数据类型float单位%RH数据点用于云平台解析和可视化展示后续设备上传的 JSON 数据字段需与数据点标识符一致。三、STM32ESP8266 MQTT 客户端配置AT 指令开发ESP8266 支持 MQTT 相关 AT 指令需刷 MQTT 版本固件STM32 通过串口发送 AT 指令即可控制 ESP8266 作为 MQTT 客户端接入 OneNET 云平台以下是核心配置流程1. 硬件准备与连接硬件清单STM32F103C8T6、ESP8266-12F刷 MQTT AT 固件、DHT11 传感器、LED、3.3V 电源模块核心连接ESP8266 的 TX→STM32 的 PA10USART1_RXESP8266 的 RX→STM32 的 PA9USART1_TX其他连接同前序 ESP8266 实战。2. ESP8266 MQTT 核心 AT 指令解析ESP8266 的 MQTT AT 指令已封装 MQTT 协议细节无需手动构造报文核心指令如下表格指令功能描述示例OneNET 接入响应ATMQTTUSERCFGlinkID,scheme,clientID,username,password,keepalive,willFlag,willTopic,willMsg,willQos,willRetain配置 MQTT 用户信息ATMQTTUSERCFG0,1,stm32_esp8266_001,123456789,abcdef1234567890,60,1,/stm32/will,设备离线,0,0成功OK失败ERRORATMQTTCONNlinkID,host,port,reconnect连接 MQTT brokerATMQTTCONN0,mqtts.heclouds.com,8883,1成功MQTT CONNECTED失败MQTT CONNECT FAILATMQTTPUBlinkID,topic,dataLen,qos,retain发布消息到主题ATMQTTPUB0,/stm32/dht11,32,0,0→ 发送数据{temp:25.5,humidity:60.2}成功MQTT PUB SUCCESS失败MQTT PUB FAILATMQTTSUBlinkID,topic,qos订阅主题ATMQTTSUB0,/stm32/led/control,1成功MQTT SUB SUCCESS失败MQTT SUB FAILATMQTTDISCONNlinkID断开 MQTT 连接ATMQTTDISCONN0成功MQTT DISCONNECTED指令参数说明linkIDMQTT 连接 ID0~4ESP8266 支持 5 个同时连接scheme认证方式0 不认证1 用户名 / 密码认证keepalive心跳包间隔秒0~3600 broker 超过该时间未收到心跳则断开连接reconnect自动重连使能0 禁用1 启用dataLen发布数据的字节长度。3. STM32 串口配置与 ESP8266 通信串口配置与前序 ESP8266 实战一致波特率 115200bps启用中断接收核心代码如下仅展示关键函数c运行// 串口1发送AT指令并等待响应 uint8_t ESP8266_MQTT_SendCmd(uint8_t *cmd, uint8_t *resp, uint32_t timeout) { USART1_Clear_Recv_Buf(); USART1_SendString(cmd); USART1_SendByte(\r); USART1_SendByte(\n); uint32_t start_time SystemCoreClock / 1000 * timeout; while(start_time--) { if(USART1_Recv_Idle 1) { if(strstr((char*)USART1_Recv_Buf, (char*)resp) ! NULL) { printf(MQTT指令%s 响应%s\r\n, cmd, USART1_Recv_Buf); USART1_Clear_Recv_Buf(); return 1; } else { printf(MQTT指令%s 响应异常%s\r\n, cmd, USART1_Recv_Buf); USART1_Clear_Recv_Buf(); return 0; } } Delay_ms(1); } printf(MQTT指令%s 超时\r\n, cmd); USART1_Clear_Recv_Buf(); return 0; }4. MQTT 连接 OneNET 云平台配置c运行// OneNET MQTT配置参数替换为你的平台信息 #define MQTT_CLIENT_ID stm32_esp8266_001 #define MQTT_USERNAME 123456789 // 设备ID #define MQTT_PASSWORD abcdef1234567890// 设备APIKey #define MQTT_BROKER mqtts.heclouds.com // OneNET MQTT broker地址 #define MQTT_PORT 8883 // SSL加密端口 #define MQTT_KEEPALIVE 60 // 心跳间隔60秒 #define MQTT_WILL_TOPIC /stm32/will // 遗嘱主题 #define MQTT_WILL_MSG 设备离线 // 遗嘱消息 // MQTT连接OneNET uint8_t ESP8266_MQTT_Connect_OneNET(void) { uint8_t ret 0; uint8_t cmd[128]; // 1. 测试ESP8266是否在线 ret ESP8266_MQTT_SendCmd((uint8_t*)AT, (uint8_t*)OK, 1000); if(ret 0) return 0; // 2. 重启ESP8266 ret ESP8266_MQTT_SendCmd((uint8_t*)ATRST, (uint8_t*)OK, 3000); if(ret 0) return 0; Delay_ms(2000); // 3. 配置WiFi连接路由器 ret ESP8266_Init_STA((uint8_t*)MyWiFi, (uint8_t*)12345678); if(ret 0) return 0; // 4. 配置MQTT用户信息 sprintf((char*)cmd, ATMQTTUSERCFG0,1,\%s\,\%s\,\%s\,%d,1,\%s\,\%s\,0,0, MQTT_CLIENT_ID, MQTT_USERNAME, MQTT_PASSWORD, MQTT_KEEPALIVE, MQTT_WILL_TOPIC, MQTT_WILL_MSG); ret ESP8266_MQTT_SendCmd(cmd, (uint8_t*)OK, 2000); if(ret 0) return 0; // 5. 连接OneNET MQTT broker sprintf((char*)cmd, ATMQTTCONN0,\%s\,%d,1, MQTT_BROKER, MQTT_PORT); ret ESP8266_MQTT_SendCmd(cmd, (uint8_t*)MQTT CONNECTED, 5000); if(ret 0) return 0; printf(ESP8266 MQTT接入OneNET成功\r\n); return 1; }四、MQTT 数据上传与远程控制OneNET 实战1. 数据上传发布温湿度数据到 OneNETc运行// 发布DHT11温湿度数据到OneNET主题/stm32/dht11 void DHT11_MQTT_Publish(void) { if(DHT11_ReadData(dht11_data) 1) { uint8_t pub_data[64]; uint8_t cmd[64]; // 封装JSON数据字段与OneNET数据点一致 sprintf((char*)pub_data, {\temp\:%.1f,\humidity\:%.1f}, (float)(dht11_data.temp_int dht11_data.temp_dec/10.0), (float)(dht11_data.humidity_int dht11_data.humidity_dec/10.0)); // 发送MQTT发布指令QoS 0不保留 sprintf((char*)cmd, ATMQTTPUB0,\/stm32/dht11\,%d,0,0, strlen((char*)pub_data)); if(ESP8266_MQTT_SendCmd(cmd, (uint8_t*), 1000)) { // 发送实际数据 USART1_Clear_Recv_Buf(); USART1_SendString(pub_data); Delay_ms(500); if(strstr((char*)USART1_Recv_Buf, MQTT PUB SUCCESS) ! NULL) { printf(MQTT发布成功%s\r\n, pub_data); } else { printf(MQTT发布失败%s\r\n, USART1_Recv_Buf); } USART1_Clear_Recv_Buf(); } } else { printf(DHT11数据采集失败\r\n); } }2. 远程控制订阅主题接收 OneNET 控制指令c运行// 订阅远程控制主题/stm32/led/control uint8_t ESP8266_MQTT_Subscribe(void) { uint8_t cmd[64]; // 订阅主题QoS 1 sprintf((char*)cmd, ATMQTTSUB0,\/stm32/led/control\,1); return ESP8266_MQTT_SendCmd(cmd, (uint8_t*)MQTT SUB SUCCESS, 2000); } // 解析OneNET控制指令如LED_ON、LED_OFF void MQTT_Cmd_Parse(uint8_t *cmd_buf) { if(strstr((char*)cmd_buf, LED_ON) ! NULL) { LED_On(); // 发布指令执行结果到主题 ESP8266_MQTT_Publish_Result((uint8_t*)LED已点亮); } else if(strstr((char*)cmd_buf, LED_OFF) ! NULL) { LED_Off(); ESP8266_MQTT_Publish_Result((uint8_t*)LED已熄灭); } else { ESP8266_MQTT_Publish_Result((uint8_t*)未知指令); } } // 发布指令执行结果 void ESP8266_MQTT_Publish_Result(uint8_t *result) { uint8_t cmd[64]; uint8_t data[32]; sprintf((char*)data, {\result\:\%s\}, result); sprintf((char*)cmd, ATMQTTPUB0,\/stm32/led/result\,%d,0,0, strlen((char*)data)); if(ESP8266_MQTT_SendCmd(cmd, (uint8_t*), 1000)) { USART1_SendString(data); Delay_ms(300); } } // 处理ESP8266接收的MQTT订阅消息 void ESP8266_MQTT_Recv_Handle(void) { if(USART1_Recv_Idle 1) { // MQTT订阅消息格式MQTTSUBRECV:linkID,topic,dataLen,data uint8_t *recv_start strstr((char*)USART1_Recv_Buf, MQTTSUBRECV:); if(recv_start ! NULL) { // 提取指令数据跳过前缀 uint8_t *data_start strrchr((char*)recv_start, ,) 1; printf(收到OneNET控制指令%s\r\n, data_start); MQTT_Cmd_Parse(data_start); } USART1_Clear_Recv_Buf(); } }3. 主函数整合 MQTT 连接、数据上传与远程控制c运行int main(void) { // 初始化系统时钟、串口1、LED、DHT11 SystemInit(); USART1_Init_ESP8266(); LED_Init(); printf(STM32ESP8266 OneNET MQTT实战系统\r\n); printf(\r\n\r\n); // 1. MQTT连接OneNET uint8_t mqtt_connect_ret ESP8266_MQTT_Connect_OneNET(); if(mqtt_connect_ret 0) { printf(MQTT连接OneNET失败程序退出\r\n); while(1); } // 2. 订阅LED控制主题 uint8_t sub_ret ESP8266_MQTT_Subscribe(); if(sub_ret 0) { printf(订阅主题失败\r\n); } else { printf(订阅主题成功/stm32/led/control\r\n); } // 3. 主循环每5秒上传温湿度处理控制指令 while(1) { static uint32_t pub_cnt 0; if(pub_cnt 5000) { pub_cnt 0; DHT11_MQTT_Publish(); // 上传温湿度数据 } ESP8266_MQTT_Recv_Handle(); // 处理控制指令 Delay_ms(1); } }五、OneNET 云平台数据可视化与控制1. 数据可视化查看登录 OneNET 平台进入产品的 “设备列表”选择已接入的设备点击 “数据可视化”可查看实时上传的温湿度数据支持曲线图、数字显示等形式进入 “数据存储”可查看历史数据记录默认保存 30 天。2. 远程控制设备进入设备的 “调试中心”选择 “MQTT 调试”向主题/stm32/led/control发送指令 “LED_ON”STM32 接收后点亮 LED发送指令 “LED_OFF”LED 熄灭同时设备会向/stm32/led/result主题返回执行结果。六、MQTT 实战避坑指南10 高频错误1. MQTT 连接失败返回 MQTT CONNECT FAIL原因 1WiFi 连接失败ESP8266 未接入网络解决检查 WiFi 名称和密码确保 ESP8266 成功连接路由器原因 2Client ID、用户名、密码错误解决核对 OneNET 的设备 ID、APIKey确保 Client ID 唯一原因 3MQTT broker 地址或端口错误解决OneNET 非加密端口 1883SSL 加密端口 8883确保端口与地址匹配原因 4ESP8266 未刷 MQTT 版本固件解决下载 ESP8266 MQTT AT 固件乐鑫官网通过烧录工具刷入。2. MQTT 发布失败返回 MQTT PUB FAIL原因 1未建立 MQTT 连接解决先调用ESP8266_MQTT_Connect_OneNET建立连接再发布数据原因 2发布数据长度计算错误解决dataLen需与实际 JSON 数据的字节长度一致不可多算或少算原因 3主题格式错误如含特殊字符解决主题仅支持字母、数字、斜杠/、下划线_避免特殊字符。3. 接收不到 OneNET 控制指令原因 1未订阅控制主题解决调用ESP8266_MQTT_Subscribe订阅/stm32/led/control主题原因 2订阅的 QoS 等级与发布的 QoS 等级不匹配解决确保订阅和发布的 QoS 等级一致如均为 QoS 1原因 3串口接收缓冲区溢出未提取有效指令解决增大串口接收缓冲区正确解析MQTTSUBRECV:格式的消息。4. OneNET 平台无法解析数据原因上传的 JSON 数据字段与数据点标识符不一致解决确保 JSON 字段如temp、humidity与 OneNET 创建的数据点标识符完全一致。5. 心跳超时导致连接断开原因keepalive设置过小或设备未定期发送心跳包解决将keepalive设置为 60~120 秒设备定期发布数据或发送空消息维持心跳。七、总结MQTTOneNET 核心要点与进阶方向1. 核心要点回顾MQTT 核心基于发布 / 订阅模式通过主题实现设备与云平台解耦通信低带宽、低功耗OneNET 接入流程创建产品→添加设备→获取认证信息→ESP8266 MQTT 配置→连接→发布 / 订阅实战关键WiFi 连接是前提MQTT 认证信息正确是核心主题与数据格式匹配是保障避坑核心固件版本适配、参数配置正确、数据格式规范、心跳维持连接。2. 进阶学习方向MQTT 遗嘱消息与保留消息实战配置遗嘱消息实现设备离线告警QoS 1/2 等级应用针对关键数据配置 QoS 1 确保数据可靠传输手机 APP 开发通过 Android/iOS APP 订阅主题实现手机远程监控和控制多设备协同多个 STM32 设备接入 OneNET通过主题实现设备间通信NB-IoTMQTT结合 NB-IoT 模块如 BC28实现低功耗、广覆盖的物联网场景。掌握 MQTTOneNET 后你已具备物联网设备云接入的核心能力可应用于智能家居、工业监控、环境监测等场景。下一篇我们将学习 STM32 的 CAN 总线通信聚焦工业级设备间的高可靠性数据传输
STM32 进阶封神之路（二十七）：MQTT 深度解析 —— 从协议原理到 OneNET 云平台接入（底层逻辑 + AT 指令开发）
发布时间：2026/6/4 9:31:21
STM32 进阶封神之路二十七MQTT 深度解析 —— 从协议原理到 OneNET 云平台接入底层逻辑 AT 指令开发上一篇我们掌握了 ESP8266 的 TCP 通信和透传实战这一篇聚焦物联网核心协议 ——MQTTMessage Queuing Telemetry Transport以及国内主流物联网云平台OneNET的接入开发。MQTT 是轻量级、低带宽的物联网通信协议专为受限设备和低功耗网络设计而 OneNET 提供了设备管理、数据存储、远程控制等一站式物联网解决方案两者结合是物联网项目的主流技术选型。本文基于 STM32F103ESP8266从 MQTT 协议底层原理、核心特性、报文格式到 OneNET 云平台设备创建、MQTT 连接配置、数据上传与远程控制手把手带你吃透 MQTT 协议和云平台接入逻辑为实战开发打下坚实基础一、MQTT 核心认知为什么它是物联网 “首选协议”1. MQTT 的核心定位与应用场景1核心定位MQTT 是 IBM 于 1999 年推出的基于发布 / 订阅Publish/Subscribe模式的轻量级物联网通信协议运行在 TCP/IP 协议之上核心目标是 “用最少的带宽和资源实现设备与云平台的可靠通信”。2核心优势对比 TCP 直连表格对比维度MQTT 协议TCP 直连带宽占用极低报文头仅 2 字节较高无统一报文格式冗余数据多资源消耗低适合 MCU、ESP8266 等受限设备较高需手动处理连接、重连、数据解析通信模式发布 / 订阅多设备间解耦通信点对点一对一通信多设备扩展复杂可靠性支持 QoS 等级0/1/2确保数据传输需手动实现重传、校验可靠性差功能扩展支持遗嘱消息、保留消息、主题过滤无原生扩展功能需自定义3典型应用场景低功耗设备传感器节点温湿度、光照、智能穿戴设备窄带宽网络2G/4G/NB-IoT 等无线通信场景多设备通信智能家居多个传感器上传数据手机 APP 远程控制云平台接入OneNET、阿里云、腾讯云等物联网平台的标准接入协议。2. MQTT 核心概念必掌握1发布 / 订阅模式Publish/SubscribeMQTT 的核心通信模式通过 “主题Topic” 实现设备间解耦通信无需直接建立连接发布者Publisher发送数据的设备如 STM32ESP8266 采集温湿度后发布数据订阅者Subscriber接收数据的设备 / 平台如 OneNET 云平台、手机 APP主题Topic数据的 “路径标识”类似文件系统路径如/stm32/dht11/temp发布者向主题发送数据订阅者订阅主题即可接收数据** broker代理服务器**接收发布者的消息转发给订阅对应主题的订阅者如 OneNET 云平台内置 MQTT broker。2QoS 服务质量等级Quality of ServiceMQTT 支持 3 种 QoS 等级适配不同可靠性需求表格QoS 等级核心定义传输机制适用场景QoS 0最多一次消息最多传输一次可能丢失发送者发送一次不等待确认非关键数据如普通温湿度采集QoS 1至少一次消息至少传输一次可能重复发送者发送后等待确认PUBACK未确认则重发重要数据如设备告警QoS 2恰好一次消息恰好传输一次无丢失无重复两次握手PUBREC→PUBREL→PUBCOMP确保仅传输一次关键数据如金融支付、设备控制指令3其他核心概念客户端 IDClient IDMQTT 客户端的唯一标识需在云平台注册如stm32_esp8266_001遗嘱消息Will Message设备异常断开连接时broker 自动发送的消息如 “设备离线”保留消息Retained Messagebroker 存储的最新消息新订阅者订阅主题后立即接收该消息用户名 / 密码Username/PasswordMQTT 连接认证信息由云平台分配如 OneNET 的设备 ID 和 API 密钥。3. MQTT 报文格式深度解析底层逻辑MQTT 报文是设备与 broker 通信的基础所有操作连接、发布、订阅、断开均通过报文实现核心格式如下1报文总体结构plaintext固定头Fixed Header 可变头Variable Header 有效载荷Payload2固定头所有报文必含长度2 字节起包含 “报文类型” 和 “剩余长度”第 1 字节控制字节高 4 位报文类型如 0x10CONNECT0x30PUBLISH0x82SUBACK低 4 位标志位如 QoS 等级、保留位第 2 字节起剩余长度表示可变头 有效载荷的总长度采用可变长度编码节省带宽。3常用报文类型及功能表格报文类型控制字节核心功能适用场景CONNECT0x10客户端向 broker 发起连接设备上电后连接云平台CONNACK0x20broker 响应连接请求成功 / 失败确认连接状态PUBLISH0x30~0x33客户端发布消息到主题传感器数据上传PUBACK0x40响应 QoS 1 的 PUBLISH 消息确认 QoS 1 消息接收SUBSCRIBE0x82客户端订阅主题手机 APP 订阅设备数据SUBACK0x90broker 响应订阅请求确认订阅成功DISCONNECT0xE0客户端主动断开连接设备正常关机4. MQTT 通信流程以设备上传数据为例设备MQTT 客户端通过 TCP 连接云平台的 MQTT broker默认端口 1883设备发送 CONNECT 报文含 Client ID、用户名、密码向 broker 请求连接broker 验证信息后发送 CONNACK 报文响应码 0 表示连接成功设备发送 PUBLISH 报文向指定主题如/stm32/dht11发布数据温湿度云平台订阅该主题接收 PUBLISH 报文存储数据并转发给其他订阅者如手机 APP设备完成数据上传后可发送 DISCONNECT 报文断开连接或保持连接等待下一次上传。二、OneNET 云平台基础配置MQTT 接入前置准备OneNET 是中国移动推出的物联网开放平台支持 MQTT、HTTP 等多种接入方式提供设备管理、数据存储、可视化等功能以下是 MQTT 接入的基础配置步骤1. 注册 OneNET 账号并创建产品访问 OneNET 官网https://open.iot.10086.cn/注册并登录账号进入 “开发者中心”点击 “创建产品”填写产品信息产品名称如 “STM32 传感器节点”产品类型选择 “智能硬件→传感器”网络类型选择 “WiFi”接入协议选择 “MQTT”数据格式选择 “自定义 JSON”点击 “确认创建”获取产品 ID后续 MQTT 连接需使用。2. 添加设备并获取认证信息进入创建的产品点击 “添加设备”填写设备名称如 “STM32_ESP8266_001”其他参数默认设备创建成功后获取核心认证信息MQTT 连接必需设备 ID设备的唯一标识如123456789设备密钥APIKey设备认证密码如abcdef1234567890MQTT broker 地址OneNET 的 MQTT 服务器地址mqtts.heclouds.comSSL 加密端口 8883非加密端口 1883。3. 创建数据点可选用于数据可视化进入产品的 “数据点管理”点击 “添加数据点”填写数据点信息如 “温度”标识符temp数据类型float单位℃“湿度”标识符humidity数据类型float单位%RH数据点用于云平台解析和可视化展示后续设备上传的 JSON 数据字段需与数据点标识符一致。三、STM32ESP8266 MQTT 客户端配置AT 指令开发ESP8266 支持 MQTT 相关 AT 指令需刷 MQTT 版本固件STM32 通过串口发送 AT 指令即可控制 ESP8266 作为 MQTT 客户端接入 OneNET 云平台以下是核心配置流程1. 硬件准备与连接硬件清单STM32F103C8T6、ESP8266-12F刷 MQTT AT 固件、DHT11 传感器、LED、3.3V 电源模块核心连接ESP8266 的 TX→STM32 的 PA10USART1_RXESP8266 的 RX→STM32 的 PA9USART1_TX其他连接同前序 ESP8266 实战。2. ESP8266 MQTT 核心 AT 指令解析ESP8266 的 MQTT AT 指令已封装 MQTT 协议细节无需手动构造报文核心指令如下表格指令功能描述示例OneNET 接入响应ATMQTTUSERCFGlinkID,scheme,clientID,username,password,keepalive,willFlag,willTopic,willMsg,willQos,willRetain配置 MQTT 用户信息ATMQTTUSERCFG0,1,stm32_esp8266_001,123456789,abcdef1234567890,60,1,/stm32/will,设备离线,0,0成功OK失败ERRORATMQTTCONNlinkID,host,port,reconnect连接 MQTT brokerATMQTTCONN0,mqtts.heclouds.com,8883,1成功MQTT CONNECTED失败MQTT CONNECT FAILATMQTTPUBlinkID,topic,dataLen,qos,retain发布消息到主题ATMQTTPUB0,/stm32/dht11,32,0,0→ 发送数据{temp:25.5,humidity:60.2}成功MQTT PUB SUCCESS失败MQTT PUB FAILATMQTTSUBlinkID,topic,qos订阅主题ATMQTTSUB0,/stm32/led/control,1成功MQTT SUB SUCCESS失败MQTT SUB FAILATMQTTDISCONNlinkID断开 MQTT 连接ATMQTTDISCONN0成功MQTT DISCONNECTED指令参数说明linkIDMQTT 连接 ID0~4ESP8266 支持 5 个同时连接scheme认证方式0 不认证1 用户名 / 密码认证keepalive心跳包间隔秒0~3600 broker 超过该时间未收到心跳则断开连接reconnect自动重连使能0 禁用1 启用dataLen发布数据的字节长度。3. STM32 串口配置与 ESP8266 通信串口配置与前序 ESP8266 实战一致波特率 115200bps启用中断接收核心代码如下仅展示关键函数c运行// 串口1发送AT指令并等待响应 uint8_t ESP8266_MQTT_SendCmd(uint8_t *cmd, uint8_t *resp, uint32_t timeout) { USART1_Clear_Recv_Buf(); USART1_SendString(cmd); USART1_SendByte(\r); USART1_SendByte(\n); uint32_t start_time SystemCoreClock / 1000 * timeout; while(start_time--) { if(USART1_Recv_Idle 1) { if(strstr((char*)USART1_Recv_Buf, (char*)resp) ! NULL) { printf(MQTT指令%s 响应%s\r\n, cmd, USART1_Recv_Buf); USART1_Clear_Recv_Buf(); return 1; } else { printf(MQTT指令%s 响应异常%s\r\n, cmd, USART1_Recv_Buf); USART1_Clear_Recv_Buf(); return 0; } } Delay_ms(1); } printf(MQTT指令%s 超时\r\n, cmd); USART1_Clear_Recv_Buf(); return 0; }4. MQTT 连接 OneNET 云平台配置c运行// OneNET MQTT配置参数替换为你的平台信息 #define MQTT_CLIENT_ID stm32_esp8266_001 #define MQTT_USERNAME 123456789 // 设备ID #define MQTT_PASSWORD abcdef1234567890// 设备APIKey #define MQTT_BROKER mqtts.heclouds.com // OneNET MQTT broker地址 #define MQTT_PORT 8883 // SSL加密端口 #define MQTT_KEEPALIVE 60 // 心跳间隔60秒 #define MQTT_WILL_TOPIC /stm32/will // 遗嘱主题 #define MQTT_WILL_MSG 设备离线 // 遗嘱消息 // MQTT连接OneNET uint8_t ESP8266_MQTT_Connect_OneNET(void) { uint8_t ret 0; uint8_t cmd[128]; // 1. 测试ESP8266是否在线 ret ESP8266_MQTT_SendCmd((uint8_t*)AT, (uint8_t*)OK, 1000); if(ret 0) return 0; // 2. 重启ESP8266 ret ESP8266_MQTT_SendCmd((uint8_t*)ATRST, (uint8_t*)OK, 3000); if(ret 0) return 0; Delay_ms(2000); // 3. 配置WiFi连接路由器 ret ESP8266_Init_STA((uint8_t*)MyWiFi, (uint8_t*)12345678); if(ret 0) return 0; // 4. 配置MQTT用户信息 sprintf((char*)cmd, ATMQTTUSERCFG0,1,\%s\,\%s\,\%s\,%d,1,\%s\,\%s\,0,0, MQTT_CLIENT_ID, MQTT_USERNAME, MQTT_PASSWORD, MQTT_KEEPALIVE, MQTT_WILL_TOPIC, MQTT_WILL_MSG); ret ESP8266_MQTT_SendCmd(cmd, (uint8_t*)OK, 2000); if(ret 0) return 0; // 5. 连接OneNET MQTT broker sprintf((char*)cmd, ATMQTTCONN0,\%s\,%d,1, MQTT_BROKER, MQTT_PORT); ret ESP8266_MQTT_SendCmd(cmd, (uint8_t*)MQTT CONNECTED, 5000); if(ret 0) return 0; printf(ESP8266 MQTT接入OneNET成功\r\n); return 1; }四、MQTT 数据上传与远程控制OneNET 实战1. 数据上传发布温湿度数据到 OneNETc运行// 发布DHT11温湿度数据到OneNET主题/stm32/dht11 void DHT11_MQTT_Publish(void) { if(DHT11_ReadData(dht11_data) 1) { uint8_t pub_data[64]; uint8_t cmd[64]; // 封装JSON数据字段与OneNET数据点一致 sprintf((char*)pub_data, {\temp\:%.1f,\humidity\:%.1f}, (float)(dht11_data.temp_int dht11_data.temp_dec/10.0), (float)(dht11_data.humidity_int dht11_data.humidity_dec/10.0)); // 发送MQTT发布指令QoS 0不保留 sprintf((char*)cmd, ATMQTTPUB0,\/stm32/dht11\,%d,0,0, strlen((char*)pub_data)); if(ESP8266_MQTT_SendCmd(cmd, (uint8_t*), 1000)) { // 发送实际数据 USART1_Clear_Recv_Buf(); USART1_SendString(pub_data); Delay_ms(500); if(strstr((char*)USART1_Recv_Buf, MQTT PUB SUCCESS) ! NULL) { printf(MQTT发布成功%s\r\n, pub_data); } else { printf(MQTT发布失败%s\r\n, USART1_Recv_Buf); } USART1_Clear_Recv_Buf(); } } else { printf(DHT11数据采集失败\r\n); } }2. 远程控制订阅主题接收 OneNET 控制指令c运行// 订阅远程控制主题/stm32/led/control uint8_t ESP8266_MQTT_Subscribe(void) { uint8_t cmd[64]; // 订阅主题QoS 1 sprintf((char*)cmd, ATMQTTSUB0,\/stm32/led/control\,1); return ESP8266_MQTT_SendCmd(cmd, (uint8_t*)MQTT SUB SUCCESS, 2000); } // 解析OneNET控制指令如LED_ON、LED_OFF void MQTT_Cmd_Parse(uint8_t *cmd_buf) { if(strstr((char*)cmd_buf, LED_ON) ! NULL) { LED_On(); // 发布指令执行结果到主题 ESP8266_MQTT_Publish_Result((uint8_t*)LED已点亮); } else if(strstr((char*)cmd_buf, LED_OFF) ! NULL) { LED_Off(); ESP8266_MQTT_Publish_Result((uint8_t*)LED已熄灭); } else { ESP8266_MQTT_Publish_Result((uint8_t*)未知指令); } } // 发布指令执行结果 void ESP8266_MQTT_Publish_Result(uint8_t *result) { uint8_t cmd[64]; uint8_t data[32]; sprintf((char*)data, {\result\:\%s\}, result); sprintf((char*)cmd, ATMQTTPUB0,\/stm32/led/result\,%d,0,0, strlen((char*)data)); if(ESP8266_MQTT_SendCmd(cmd, (uint8_t*), 1000)) { USART1_SendString(data); Delay_ms(300); } } // 处理ESP8266接收的MQTT订阅消息 void ESP8266_MQTT_Recv_Handle(void) { if(USART1_Recv_Idle 1) { // MQTT订阅消息格式MQTTSUBRECV:linkID,topic,dataLen,data uint8_t *recv_start strstr((char*)USART1_Recv_Buf, MQTTSUBRECV:); if(recv_start ! NULL) { // 提取指令数据跳过前缀 uint8_t *data_start strrchr((char*)recv_start, ,) 1; printf(收到OneNET控制指令%s\r\n, data_start); MQTT_Cmd_Parse(data_start); } USART1_Clear_Recv_Buf(); } }3. 主函数整合 MQTT 连接、数据上传与远程控制c运行int main(void) { // 初始化系统时钟、串口1、LED、DHT11 SystemInit(); USART1_Init_ESP8266(); LED_Init(); printf(STM32ESP8266 OneNET MQTT实战系统\r\n); printf(\r\n\r\n); // 1. MQTT连接OneNET uint8_t mqtt_connect_ret ESP8266_MQTT_Connect_OneNET(); if(mqtt_connect_ret 0) { printf(MQTT连接OneNET失败程序退出\r\n); while(1); } // 2. 订阅LED控制主题 uint8_t sub_ret ESP8266_MQTT_Subscribe(); if(sub_ret 0) { printf(订阅主题失败\r\n); } else { printf(订阅主题成功/stm32/led/control\r\n); } // 3. 主循环每5秒上传温湿度处理控制指令 while(1) { static uint32_t pub_cnt 0; if(pub_cnt 5000) { pub_cnt 0; DHT11_MQTT_Publish(); // 上传温湿度数据 } ESP8266_MQTT_Recv_Handle(); // 处理控制指令 Delay_ms(1); } }五、OneNET 云平台数据可视化与控制1. 数据可视化查看登录 OneNET 平台进入产品的 “设备列表”选择已接入的设备点击 “数据可视化”可查看实时上传的温湿度数据支持曲线图、数字显示等形式进入 “数据存储”可查看历史数据记录默认保存 30 天。2. 远程控制设备进入设备的 “调试中心”选择 “MQTT 调试”向主题/stm32/led/control发送指令 “LED_ON”STM32 接收后点亮 LED发送指令 “LED_OFF”LED 熄灭同时设备会向/stm32/led/result主题返回执行结果。六、MQTT 实战避坑指南10 高频错误1. MQTT 连接失败返回 MQTT CONNECT FAIL原因 1WiFi 连接失败ESP8266 未接入网络解决检查 WiFi 名称和密码确保 ESP8266 成功连接路由器原因 2Client ID、用户名、密码错误解决核对 OneNET 的设备 ID、APIKey确保 Client ID 唯一原因 3MQTT broker 地址或端口错误解决OneNET 非加密端口 1883SSL 加密端口 8883确保端口与地址匹配原因 4ESP8266 未刷 MQTT 版本固件解决下载 ESP8266 MQTT AT 固件乐鑫官网通过烧录工具刷入。2. MQTT 发布失败返回 MQTT PUB FAIL原因 1未建立 MQTT 连接解决先调用ESP8266_MQTT_Connect_OneNET建立连接再发布数据原因 2发布数据长度计算错误解决dataLen需与实际 JSON 数据的字节长度一致不可多算或少算原因 3主题格式错误如含特殊字符解决主题仅支持字母、数字、斜杠/、下划线_避免特殊字符。3. 接收不到 OneNET 控制指令原因 1未订阅控制主题解决调用ESP8266_MQTT_Subscribe订阅/stm32/led/control主题原因 2订阅的 QoS 等级与发布的 QoS 等级不匹配解决确保订阅和发布的 QoS 等级一致如均为 QoS 1原因 3串口接收缓冲区溢出未提取有效指令解决增大串口接收缓冲区正确解析MQTTSUBRECV:格式的消息。4. OneNET 平台无法解析数据原因上传的 JSON 数据字段与数据点标识符不一致解决确保 JSON 字段如temp、humidity与 OneNET 创建的数据点标识符完全一致。5. 心跳超时导致连接断开原因keepalive设置过小或设备未定期发送心跳包解决将keepalive设置为 60~120 秒设备定期发布数据或发送空消息维持心跳。七、总结MQTTOneNET 核心要点与进阶方向1. 核心要点回顾MQTT 核心基于发布 / 订阅模式通过主题实现设备与云平台解耦通信低带宽、低功耗OneNET 接入流程创建产品→添加设备→获取认证信息→ESP8266 MQTT 配置→连接→发布 / 订阅实战关键WiFi 连接是前提MQTT 认证信息正确是核心主题与数据格式匹配是保障避坑核心固件版本适配、参数配置正确、数据格式规范、心跳维持连接。2. 进阶学习方向MQTT 遗嘱消息与保留消息实战配置遗嘱消息实现设备离线告警QoS 1/2 等级应用针对关键数据配置 QoS 1 确保数据可靠传输手机 APP 开发通过 Android/iOS APP 订阅主题实现手机远程监控和控制多设备协同多个 STM32 设备接入 OneNET通过主题实现设备间通信NB-IoTMQTT结合 NB-IoT 模块如 BC28实现低功耗、广覆盖的物联网场景。掌握 MQTTOneNET 后你已具备物联网设备云接入的核心能力可应用于智能家居、工业监控、环境监测等场景。下一篇我们将学习 STM32 的 CAN 总线通信聚焦工业级设备间的高可靠性数据传输
