esp8266连接onenet协议mqtt

#include <ESP8266WiFi.h>
#include <PubSubClient.h>
#include <DHT11.h>

// 定义WiFi连接信息
const char* ssid = "your_wifi_ssid";
const char* password = "your_wifi_password";

// 定义OneNet服务器信息
const char* onenetServer = "mqtt.heclouds.com";
const int onenetPort = 6002;
const char* productId = "your_product_id";
const char* apiKey = "your_api_key";

// 定义DHT11引脚
const int dhtPin = D5;

// 初始化DHT11对象
DHT11 dht;

// 初始化WiFi和MQTT客户端对象
WiFiClient espClient;
PubSubClient client(espClient);

// 连接WiFi和OneNet服务器
void setupWifi() {
  delay(10);
  Serial.println();
  Serial.print("Connecting to ");
  Serial.println(ssid);

  WiFi.begin(ssid, password);

  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }

  Serial.println("");
  Serial.println("WiFi connected");
  Serial.println("IP address: ");
  Serial.println(WiFi.localIP());
}

// 连接到OneNet服务器
void setupOneNet() {
  client.setServer(onenetServer, onenetPort);
}

// 处理接收到的消息
void callback(char* topic, byte* payload, unsigned int length) {
  Serial.println("Message arrived");
  Serial.print("Topic: ");
  Serial.println(topic);
  Serial.print("Payload: ");
  for (int i = 0; i < length; i++) {
    Serial.print((char)payload[i]);
  }
  Serial.println();
}

// 发送数据到OneNet平台
void sendData(float temperature, float humidity) {
  char tempString[10];
  char humString[10];
  dtostrf(temperature, 4, 2, tempString);
  dtostrf(humidity,  4, 2, humString);

  // 构建JSON数据字符串
  String json = "{\"temperature\":" + String(tempString) + ",\"humidity\":" + String(humString) + "}";

  // 发布JSON数据到OneNet
  client.publish(productId, json.c_str());
}

void setup() {
  Serial.begin(115200);
  setupWifi();
  setupOneNet();
  dht.attach(dhtPin);
}

void loop() {
  if (!client.connected()) {
    // 尝试连接到OneNet服务器
    if (client.connect(productId, apiKey, NULL)) {
      Serial.println("Connected to OneNet");
      // 订阅接收消息的主题
      client.setCallback(callback);
      client.subscribe(productId);
    } else {
      Serial.print("Connection to OneNet failed, rc=");
      Serial.print(client.state());
      Serial.println(" retrying in 5 seconds");
      delay(5000);
    }
  } else {
    // 获取温湿度数据
    int temperature = dht.readTemperature();
    int humidity = dht.readHumidity();
    // 发送数据到OneNet
    sendData(temperature, humidity);
    delay(5000);
  }

  // 处理MQTT消息
  client.loop();
}