手把手教你用STM32F103C8T6+ESP8266-01S，把MQ-2气体传感器数据传到OneNet（附完整代码）-洪萨配资

STM32+ESP8266物联网实战：MQ-2气体数据上云全流程解析

在智能家居和工业监测领域，气体浓度检测始终是核心需求之一。当我们手头有STM32开发板、ESP8266模块和MQ-2传感器时，如何将它们组合成一个完整的物联网监测系统？本文将彻底拆解从硬件连接到云端可视化的全流程，不同于基础教程的是，我们会深入探讨MQTT连接优化、数据打包技巧以及OneNet平台的高级配置方法。

1. 硬件架构设计与连接规范

1.1 组件选型与功能定位

STM32F103C8T6：作为主控制器，负责传感器数据采集、逻辑处理以及与WiFi模块通信
ESP8266-01S：提供WiFi连接能力，通过AT指令集实现TCP/IP协议栈
MQ-2气体传感器：检测可燃气体和烟雾浓度，输出模拟电压信号
CH340转串口模块：用于开发调试时的串口通信

1.2 精确接线方案

采用三线制串口通信连接方式，特别注意电平匹配问题：

STM32引脚	ESP8266引脚	功能说明
PA9(TX)	RX	数据发送
PA10(RX)	TX	数据接收
PA4	RST	硬件复位
3.3V	VCC	电源输入
GND	GND	共地连接

关键提示：ESP8266-01S的工作电压必须严格控制在3.3V，5V输入会导致模块损坏

传感器接口配置：

// MQ-2模拟输入配置 void ADC1_Init(void) { RCC->APB2ENR |= 0x00000004; // 开启ADC1时钟 GPIOA->CRL &= 0x0FFFFFFF; // PA7模拟输入模式 ADC1->SQR3 = 0x00000007; // 通道7作为第一个转换 ADC1->CR2 = 0x00000001; // 开启ADC并启动转换 }

2. 通信协议栈深度优化

2.1 AT指令交互层

建立稳定的WiFi连接需要精确的指令时序控制：

# 典型AT指令序列示例 AT_Cmds = [ "AT+RST", # 模块复位 "AT+CWMODE=1", # 设置为Station模式 "AT+CWJAP=\\"SSID\\",\\"PASSWORD\\"", # 连接WiFi "AT+CIPSTART=\\"TCP\\",\\"183.230.40.39\\",6002", # 建立TCP连接 "AT+CIPMODE=1", # 开启透明传输模式 "AT+CIPSEND" # 进入数据发送模式 ]

2.2 MQTT协议实现要点

在STM32上实现轻量级MQTT客户端需要关注三个核心机制：

心跳保持：每30秒发送PINGREQ包
QoS等级：采用QoS0避免复杂确认流程
主题设计：
- 发布主题：$dp(平台定义的数据点主题)
- 订阅主题：device_ctrl(用于接收平台指令)

关键数据结构：

typedef struct { uint8_t header; // 固定头 uint8_t msg_type; // 消息类型 uint16_t msg_id; // 消息标识 uint32_t body_len; // 数据体长度 uint8_t *payload; // 有效载荷 } MQTT_Packet;

3. 数据采集与协议封装

3.1 传感器数据处理流程

MQ-2传感器输出需要经过三重处理：

ADC采样：12位精度，100Hz采样率
滑动滤波：采用窗口大小为5的移动平均滤波
浓度换算：根据传感器特性曲线转换为ppm值

优化后的采集代码：

#define SAMPLE_TIMES 5 // 采样次数 uint16_t Get_Gas_Value(void) { uint32_t sum = 0; for(uint8_t i=0; i<SAMPLE_TIMES; i++) { sum += ADC_GetValue(7); // 通道7采样 Delay_ms(10); } return (sum/SAMPLE_TIMES)*3300/4096; // 转换为电压值(mV) }

3.2 数据打包规范

采用JSON格式组织传感器数据，确保平台兼容性：

{ "datastreams": [ { "id": "gas", "datapoints": [ { "value": 256, "at": "2023-07-20T15:30:45Z" } ] } ] }

二进制协议封装函数：

void MQTT_PackageData(uint8_t *buf, float gas_val) { char json[100]; sprintf(json, "{\\"gas\\":%.1f}", gas_val); buf[0] = 0x03; // 发布标志 buf[1] = 0x00; // 剩余长度高位 buf[2] = strlen(json); // 剩余长度低位 memcpy(buf+3, json, strlen(json)); }

4. OneNet平台高级配置

4.1 产品创建设计原则

协议选择：MQTT私有协议
设备认证：采用设备ID+鉴权信息双因素认证
数据格式：JSON标准格式

4.2 数据可视化配置技巧

仪表盘联动：创建多个视图展示实时数据和历史趋势
阈值告警：设置气体浓度超标触发规则
API扩展：通过HTTP API对接第三方应用

平台关键参数获取位置：

产品ID：产品详情页 → 基本信息
设备ID：设备列表 → 设备详情
鉴权信息：设备详情 → 鉴权信息

5. 系统稳定性优化策略

5.1 连接异常处理机制

实现三级重连策略：

WiFi断开：立即尝试重新连接路由器
TCP断开：延时2秒后重建TCP连接
MQTT断开：完整重走连接流程

void Network_Handler(void) { if(WiFi_Status() == DISCONNECTED) { WiFi_Reconnect(3); // 最大重试3次 } else if(MQTT_PingTimeout()) { MQTT_Reconnect(); } }

5.2 数据缓存与补传

设计环形缓冲区应对网络波动：

#define BUF_SIZE 10 typedef struct { uint32_t timestamp; float gas_value; uint8_t uploaded; } DataPoint; DataPoint data_buf[BUF_SIZE]; uint8_t buf_head = 0; uint8_t buf_tail = 0; void Save_Data(float val) { data_buf[buf_head].timestamp = Get_UnixTime(); data_buf[buf_head].gas_value = val; data_buf[buf_head].uploaded = 0; buf_head = (buf_head+1) % BUF_SIZE; }