esp8266nodemcu连接onenet的代码

以下是ESP8266 NodeMCU连接OneNET的基本代码框架：
#include <ESP8266WiFi.h>
#include <PubClient.h>

// Replace with your network credentials
const* ssid = "your_SSID";
const char password = "your_PASSWORD";

// Replace with your One MQTT server and port
const char* server = ".heclouds.com";
const int port = 6002;

// Replace with your OneNET device ID and API key
const char* deviceId = "your_DEVICE_ID";
const char* apiKey "your_API_KEY";

// Create an instance of the WiFiClient object
WiFiClient wifiClient;

// Create an instance of the PubSubClient object
PubSubClient mqttClient(wifiClient);

// Function to connect to OneNET MQTT server
void connectToMqttServer() {
while (!mqttClient.connected()) {
Serial.println("Connecting to OneNET MQTT server...");

// Create a unique client ID using the ESP8266 MAC address
String clientId = "ESP8266Client-";
clientId += String(WiFi.macAddress());

// Connect to OneNET MQTT server
if (mqttClient.connect(clientId.c_str(), deviceId, apiKey)) {
Serial.println("Connected to OneNET MQTT server!");
} else {
Serial.print("Failed to connect to OneNET MQTT server with error code ");
Serial.println(mqttClient.state());
delay(2000);
}
}
}

void setup() {
Serial.begin(9600);

// Connect to Wi-Fi network
WiFi.begin(ssid, password);
while (WiFi.status() != WL_CONNECTED) {
delay(1000);
Serial.println("Connecting to WiFi network...");
}
Serial.println("Connected to WiFi network!");

// Set OneNET MQTT server and port
mqttClient.setServer(server, port);

// Connect to OneNET MQTT server
connectToMqttServer();
}

void loop() {
// Add your code here to publish or subscribe to MQTT topics
}
登录后复制
在上面的代码中，你需要将以下变量替换为你自己的值：

ssid 和 password：你的 Wi-Fi 网络 SSID 和密码
server 和 port：OneNET MQTT 服务器地址和端口
deviceId 和 apiKey：你的 OneNET 设备 ID 和 API 密钥

接下来，你可以在 loop() 函数中添加你的代码来发布或订阅 MQTT 主题。例如，下面是一个发布消息到 OneNET 的例子：
void loop() {
// Check if connected to OneNET MQTT server
if (!mqttClient.connected()) {
connectToMqttServer();
}

// Publish a message to OneNET
mqttClient.publish("topic", "message");

// Wait for a few seconds
delay(5000);
}
登录后复制
这将发布一个名为 "topic" 的主题，并将消息 "message" 发送到 OneNET。你可以通过 OneNET 控制台查看接收到的消息。