esp826601s怎么链接mqtt

### ESP8266-01S 连接到 MQTT 服务器教程 #### 准备工作 确保已安装 Arduino IDE 并配置好支持 ESP8266 开发板。下载并安装必要的库文件，如 PubSubClient 和 WiFiEsp。 #### 示例代码 下面是一个简单的示例程序来说明如何让 ESP8266-01S 成功连接至 MQTT 服务器： ```cpp #include <ESP8266WiFi.h> #include <PubSubClient.h> // 替换成自己的Wi-Fi SSID和密码 const char* ssid = "your_SSID"; const char* password = "your_PASSWORD"; // MQTT Broker 地址与端口号 const char* mqtt_server = "broker_address"; const int mqtt_port = 1883; WiFiClient espClient; PubSubClient client(espClient); void setup_wifi() { delay(10); Serial.println(); Serial.print("Connecting to "); Serial.println(ssid); WiFi.begin(ssid, password); while (WiFi.status() != WL_CONNECTED) { delay(500); Serial.print("."); } randomSeed(micros()); Serial.println(""); Serial.println("WiFi connected"); Serial.println("IP address: "); Serial.println(WiFi.localIP()); } void reconnect() { // 循环直到重新连接成功 while (!client.connected()) { Serial.print("Attempting MQTT connection..."); if (client.connect("ESP8266Client")) { Serial.println("connected"); // 订阅主题 client.subscribe("test/topic"); } else { Serial.print("failed, rc="); Serial.print(client.state()); Serial.println(" try again in 5 seconds"); delay(5000); } } } void callback(char* topic, byte* payload, unsigned int length) { Serial.print("Message arrived ["); Serial.print(topic); Serial.print("] "); for (int i = 0; i < length; i++) { Serial.print((char)payload[i]); } Serial.println(); // 处理接收到的消息... } void setup() { pinMode(LED_BUILTIN, OUTPUT); // 初始化内置 LED 引脚 digitalWrite(LED_BUILTIN, LOW); // 关闭 LED Serial.begin(115200); setup_wifi(); // 设置 Wi-Fi 连接 client.setServer(mqtt_server, mqtt_port); client.setCallback(callback); } void loop() { if (!client.connected()) { reconnect(); } client.loop(); // 发送心跳包保持在线状态 static unsigned long lastMsg = 0; const unsigned long interval = 10 * 1000UL; if (millis() - lastMsg > interval) { lastMsg = millis(); String msg = "hello world!"; Serial.print("Publish message: "); Serial.println(msg); client.publish("outTopic", msg.c_str()); } } ``` 此代码实现了基本的功能：建立 Wi-Fi 连接、尝试连接到指定的 MQTT broker、处理消息回调以及定时发送心跳数据以维持会话活跃[^4]。