用ESP32+MQTT玩转OneNet物模型：手把手实现温湿度上传与远程灯控

在智能家居和工业物联网快速发展的今天，如何将传感器数据高效上云并实现远程控制成为开发者关注的重点。中国移动OneNet平台凭借其稳定的MQTT服务和清晰的物模型定义，为嵌入式开发者提供了便捷的物联网解决方案。本文将基于ESP32开发板，通过实际项目演示如何利用OneJson物模型实现环境数据采集与设备控制的全流程。

1. 硬件准备与开发环境搭建

1.1 所需硬件组件清单

• ESP32开发板 （推荐ESP32-WROOM-32D）
• DHT22温湿度传感器（或SHT31更高精度型号）
• BH1750光照度传感器（可选）
• 面包板及杜邦线若干
• Micro USB数据线（用于供电和调试）

1.2 开发环境配置

首先确保已安装Arduino IDE并完成ESP32开发板支持包的添加：

# 在Arduino IDE首选项中添加开发板管理器网址
https://dl.espressif.com/dl/package_esp32_index.json

然后通过开发板管理器安装ESP32支持包。推荐使用v2.0.5以上版本以获得更稳定的WiFi和MQTT库支持。

注意：若遇到编译错误，请检查是否已安装以下依赖库：

• PubSubClient（MQTT客户端库）
• ArduinoJson（6.x版本）
• DHT sensor library

2. OneNet平台物模型配置

2.1 产品与设备创建流程

1. 登录OneNet控制台，进入 物联网开放平台
2. 创建新产品时选择：
   • 协议类型：MQTT
   • 数据格式：OneJson
   • 设备类型：直连设备

关键参数配置示例：

参数项	推荐值
产品名称	Smart_Environment
行业类别	智能家居
联网方式	WiFi
数据加密	禁用（测试阶段可关闭）

2.2 物模型定义规范

在 功能定义 页面添加以下物模型属性：

{
  "properties": [
    {
      "identifier": "temperature",
      "dataType": "float",
      "unit": "℃",
      "accessMode": "r"
    },
    {
      "identifier": "humidity",
      "dataType": "float",
      "unit": "%RH",
      "accessMode": "r"
    },
    {
      "identifier": "light",
      "dataType": "int",
      "unit": "lux",
      "accessMode": "r"
    },
    {
      "identifier": "led_switch",
      "dataType": "bool",
      "accessMode": "rw"
    }
  ]
}

提示： accessMode 中"r"表示只读，"rw"代表可读写，用于区分传感器数据上报和设备控制指令。

3. ESP32端代码实现

3.1 MQTT连接核心代码

在Arduino项目中引入关键库并配置连接参数：

#include <WiFi.h>
#include <PubSubClient.h>

const char* ssid = "Your_WiFi_SSID";
const char* password = "Your_WiFi_Password";
const char* mqttServer = "mqtts.heclouds.com";
const int mqttPort = 1883;
const char* clientId = "Device_001";
const char* username = "Your_Product_ID";
const char* mqttPassword = "Calculated_Token";

WiFiClient espClient;
PubSubClient client(espClient);

void setup_wifi() {
  delay(10);
  WiFi.begin(ssid, password);
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
}

void reconnect() {
  while (!client.connected()) {
    if (client.connect(clientId, username, mqttPassword)) {
      client.subscribe("$sys/Your_Product_ID/Your_Device_ID/thing/property/set");
    } else {
      delay(5000);
    }
  }
}

3.2 物模型数据上报实现

构建符合OneJson格式的传感器数据报文：

void reportSensorData(float temp, float humi, int light) {
  String payload = "{\"id\":\"123\",\"version\":\"1.0\",\"params\":{";
  payload += "\"temperature\":{\"value\":" + String(temp) + "},";
  payload += "\"humidity\":{\"value\":" + String(humi) + "},";
  payload += "\"light\":{\"value\":" + String(light) + "}}}";
  
  client.publish("$sys/Your_Product_ID/Your_Device_ID/thing/property/post", 
                payload.c_str());
}

3.3 指令接收与处理

解析平台下发的控制指令并执行相应操作：

void callback(char* topic, byte* payload, unsigned int length) {
  String message;
  for (int i=0;i<length;i++) {
    message += (char)payload[i];
  }
  
  DynamicJsonDocument doc(1024);
  deserializeJson(doc, message);
  
  if(doc.containsKey("params")) {
    JsonObject params = doc["params"];
    if(params.containsKey("led_switch")) {
      bool ledState = params["led_switch"];
      digitalWrite(LED_BUILTIN, ledState ? HIGH : LOW);
    }
  }
}

4. 联调测试与问题排查

4.1 平台侧调试工具使用

OneNet提供的 设备调试 功能包含三大实用工具：

1. 应用模拟器 ：模拟小程序端发送控制指令
2. 数据查看器 ：实时显示设备上报的数据流
3. 日志检索 ：分析通信过程中的异常情况

4.2 常见问题解决方案

• 连接超时 ：检查Token计算是否包含正确的时间戳
• 数据未显示 ：确认物模型标识符与代码中完全一致
• 控制无响应 ：验证订阅主题与发布主题是否匹配

典型错误对照表：

现象	可能原因	解决方案
MQTT连接失败	Token计算错误	使用官方工具校验Token
数据上报但平台未显示	物模型未定义或标识符不符	检查平台物模型定义
控制指令无响应	未订阅正确的set主题	确认订阅主题包含thing/property/set

5. 项目优化与扩展

5.1 低功耗设计技巧

• 启用ESP32的深度睡眠模式
• 设置数据上报间隔为300秒（满足多数场景）
• 采用批量上报减少通信次数

5.2 安全增强措施

• 启用TLS加密通信（端口8883）
• 实现定期Token刷新机制
• 添加设备心跳检测功能

完整项目代码建议采用模块化结构组织：

├── src/
│   ├── mqtt_handler.cpp    # MQTT通信封装
│   ├── sensor_driver.cpp   # 传感器驱动
│   └── onenet_protocol.cpp # OneJson协议处理
├── include/                # 头文件目录
└── platformio.ini          # 构建配置

在实际部署中发现，采用50秒的心跳间隔和QoS1的MQTT服务质量等级，能够在通信可靠性和功耗之间取得良好平衡。对于需要高实时性的灯光控制场景，建议单独建立控制通道而非复用数据上报通道。