"# \u57fa\u4e8eESP8266\u548cDHT11\u7684MQTT\u63a5\u5165\n\n> 2024-04-07 | 2024-04-07\n> https:\/\/www.modbus.cn\/en\/docs\/esp8266\n\n---\n\n\u4e00\u3001\u5b89\u88c5Arduino\n\n1.\u4e0b\u8f7d\u5b89\u88c5\u5305\uff1a[\u70b9\u51fb\u6253\u5f00](https:\/\/www.arduino.cc\/en\/Main\/Donate)\n\n2.\u5b89\u88c5\uff1a\u76f4\u63a5\u70b9\u51fb\u4e0b\u4e00\u6b65\u76f4\u81f3\u5b89\u88c5\u5b8c\u6210\u3002\u5982\u4e0b\u56fe\u6240\u793a\uff1a\n\n![](https:\/\/image.modbus.cn\/wp-content\/uploads\/2024\/04\/20240407173341185.png)\n\n\u4e8c\u3001\u4e0b\u8f7dESP8266\u5f00\u53d1\u677f\u5e93\uff1a\n\n![](https:\/\/image.modbus.cn\/wp-content\/uploads\/2024\/04\/20240407173342614.png)\n\n\u5728\u8fd9\u9762\u586b\u5199ESP8266\u5f00\u53d1\u677f\u5730\u5740\uff1ahttp:\/\/arduino.esp8266.com\/stable\/package_esp8266com_index.json\uff0c\u4fdd\u5b58\u3002\n\n![](https:\/\/image.modbus.cn\/wp-content\/uploads\/2024\/04\/20240407173343597.png)\n\n![](https:\/\/image.modbus.cn\/wp-content\/uploads\/2024\/04\/20240407173343581.png)\n\n\u4e09\u3001\u8bbe\u7f6e\u5f00\u53d1\u677f\uff1a\n\n![](https:\/\/image.modbus.cn\/wp-content\/uploads\/2024\/04\/20240407173344525.png)\n\n\u57fa\u4e8eESP8266\u548cDHT11\u7684MQTT\u73af\u5883\u76d1\u6d4b\u7cfb\u7edf\uff1a\u5728Modbus\u7269\u8054\u7f51\u5e73\u53f0\u4e0a\u5b9e\u73b0\u5b9e\u65f6\u6570\u636e\u53d1\u5e03\u793a\u4f8b\uff1a\n\n```\n#include <ESP8266WiFi.h> \/\/ \u5f15\u5165ESP8266WiFi\u5e93\n#include <PubSubClient.h> \/\/ \u5f15\u5165MQTT\u5ba2\u6237\u7aef\u5e93\n#include <DHT.h> \/\/ \u5f15\u5165DHT\u5e93\n\n#define DHTPIN 5 \/\/ \u5b9a\u4e49DHT\u4f20\u611f\u5668\u8fde\u63a5\u7684GPIO\u7aef\u53e3\u53f7\u4e3a5\uff08\u5bf9\u5e94\u4e8eD1\uff09\n#define DHTTYPE DHT11 \/\/ \u5b9a\u4e49DHT\u4f20\u611f\u5668\u7c7b\u578b\u4e3aDHT11\nDHT dht(DHTPIN, DHTTYPE); \/\/ \u521d\u59cb\u5316DHT\u4f20\u611f\u5668\u5bf9\u8c61\n\nconst char* ssid = "218"; \/\/ WiFi\u8d26\u53f7\nconst char* password = "A1b2c3d4...5"; \/\/ WiFi\u5bc6\u7801\n\nconst char* mqtt_server = "iot.modbus.cn"; \/\/ MQTT\u670d\u52a1\u5668\u5730\u5740\nconst int mqtt_port = 1883; \/\/ MQTT\u670d\u52a1\u5668\u7aef\u53e3\u53f7\nconst char* mqtt_clientID = "4QR8TZ9ThuL4G"; \/\/ MQTT\u5ba2\u6237\u7aefID; 4QR8TZ9ThuL4G\u66ff\u6362\u6210\u81ea\u5df1\u7684\u8bbe\u5907\u53f7SN\nconst char* mqtt_user = "ceshi"; \/\/ MQTT\u7528\u6237\u540d;\u66ff\u6362\u6210\u81ea\u5df1Modbus\u4e91\u5e73\u53f0\u8d26\u6237\u540d\nconst char* mqtt_password = "123456"; \/\/ MQTT\u5bc6\u7801;\u66ff\u6362\u6210\u81ea\u5df1Modbus\u4e91\u5e73\u53f0\u5bc6\u7801\nconst char* mqtt_pub_topic = "\/dev\/coo\/4QR8TZ9ThuL4G"; \/\/ MQTT\u53d1\u5e03\u4e3b\u9898; 4QR8TZ9ThuL4G\u66ff\u6362\u6210\u81ea\u5df1\u7684\u8bbe\u5907\u53f7SN\nconst char* mqtt_sub_topic = "\/server\/coo\/4QR8TZ9ThuL4G"; \/\/ MQTT\u8ba2\u9605\u4e3b\u9898; 4QR8TZ9ThuL4G\u66ff\u6362\u6210\u81ea\u5df1\u7684\u8bbe\u5907\u53f7SN\n\nWiFiClient espClient; \/\/ WiFi\u5ba2\u6237\u7aef\u5bf9\u8c61\nPubSubClient client(espClient); \/\/ MQTT\u5ba2\u6237\u7aef\u5bf9\u8c61\n\n\/\/ \u8fde\u63a5WiFi\u7684\u51fd\u6570\nvoid setup_wifi() {\n    delay(10);\n    Serial.println();\n    Serial.print("\u8fde\u63a5\u5230 ");\n    Serial.println(ssid);\n\n    WiFi.begin(ssid, password);\n\n    while (WiFi.status() != WL_CONNECTED) {\n        delay(500);\n        Serial.print(".");\n    }\n\n    Serial.println("");\n    Serial.println("WiFi\u5df2\u8fde\u63a5");\n    Serial.println("IP\u5730\u5740: ");\n    Serial.println(WiFi.localIP());\n}\n\n\/\/ \u53d1\u5e03\u6d88\u606f\u7684\u51fd\u6570\nvoid publish_message() {\n    float humidity = dht.readHumidity(); \/\/ \u8bfb\u53d6\u6e7f\u5ea6\n    float temperature = dht.readTemperature(); \/\/ \u8bfb\u53d6\u6e29\u5ea6\n\n    char msg[200];\n    snprintf(msg, sizeof(msg), "[ { "sensor_device_id":1 , "port_id":1 , "sdata":%.1f }, { "sensor_device_id":1 , "port_id":2 , "sdata":%.1f } ]", temperature, humidity);\n    client.publish(mqtt_pub_topic, msg); \/\/ \u53d1\u5e03\u6d88\u606f\u5230MQTT\u670d\u52a1\u5668\n}\n\n\/\/ MQTT\u6d88\u606f\u56de\u8c03\u51fd\u6570\nvoid callback(char* topic, byte* payload, unsigned int length) {\n    Serial.print("\u63a5\u6536\u5230\u6d88\u606f [");\n    Serial.print(topic);\n    Serial.print("] ");\n    for (int i = 0; i < length; i++) {\n        Serial.print((char)payload[i]);\n    }\n    Serial.println();\n}\n\n\/\/ \u91cd\u65b0\u8fde\u63a5MQTT\u670d\u52a1\u5668\u7684\u51fd\u6570\nvoid reconnect() {\n    while (!client.connected()) {\n        Serial.print("\u5c1d\u8bd5\u8fde\u63a5MQTT\u670d\u52a1\u5668...");\n        if (client.connect(mqtt_clientID, mqtt_user, mqtt_password )) {\n            Serial.println("\u5df2\u8fde\u63a5");\n            client.subscribe(mqtt_sub_topic);\n        } else {\n            Serial.print("\u5931\u8d25\uff0crc=");\n            Serial.print(client.state());\n            Serial.println(" 5\u79d2\u540e\u518d\u6b21\u5c1d\u8bd5");\n            delay(5000);\n        }\n    }\n}\n\n\/\/ \u8bbe\u7f6e\u4e32\u53e3\uff0cWiFi\uff0cMQTT\u670d\u52a1\u5668\u548c\u7aef\u53e3\uff0c\u56de\u8c03\u51fd\u6570\nvoid setup() {\n    Serial.begin(115200); \/\/ \u8bbe\u7f6e\u4e32\u53e3\u6ce2\u7279\u7387\u4e3a115200\n    setup_wifi(); \/\/ \u8bbe\u7f6eWiFi\n    client.setServer(mqtt_server, mqtt_port); \/\/ \u8bbe\u7f6eMQTT\u670d\u52a1\u5668\u548c\u7aef\u53e3\n    client.setCallback(callback); \/\/ \u8bbe\u7f6eMQTT\u56de\u8c03\u51fd\u6570\n    dht.begin(); \/\/ \u5f00\u59cb\u8bfb\u53d6DHT\u4f20\u611f\u5668\u6570\u636e\n}\n\nvoid loop() {\n    if (!client.connected()) { \/\/ \u5982\u679c\u672a\u8fde\u63a5\u5230MQTT\u670d\u52a1\u5668\n        reconnect(); \/\/ \u91cd\u65b0\u8fde\u63a5\n    }\n    client.loop(); \/\/ \u6267\u884cMQTT\u5ba2\u6237\u7aef\u5faa\u73af\n\n    publish_message(); \/\/ \u53d1\u5e03\u6d88\u606f\n\n    delay(10000);  \/\/ \u5ef6\u8fdf10\u79d2\u540e\uff0c\u518d\u6b21\u53d1\u5e03\n}\n```\n\n\u8fd9\u4e2a\u7a0b\u5e8f\u662f\u9488\u5bf9ESP8266\u5fae\u63a7\u5236\u5668\u8bbe\u8ba1\u7684\uff0c\u4f7f\u7528DHT11\u4f20\u611f\u5668\u8bfb\u53d6\u6e29\u5ea6\u548c\u6e7f\u5ea6\u6570\u636e\uff0c\u7136\u540e\u901a\u8fc7MQTT\u534f\u8bae\u5c06\u6570\u636e\u53d1\u9001\u5230Modbus\u7269\u8054\u7f51\u5e73\u53f0\u3002\u8fd9\u4e2a\u7a0b\u5e8f\u7684\u4e3b\u8981\u90e8\u5206\u5305\u62ec\uff1a\n\n1. **\u5e93\u7684\u5f15\u7528**\uff1a\u7a0b\u5e8f\u5f15\u5165\u4e86`ESP8266WiFi.h`\uff08\u7528\u4e8eESP8266\u7684WiFi\u8fde\u63a5\uff09\u3001`PubSubClient.h`\uff08\u7528\u4e8eMQTT\u901a\u4fe1\uff09\u548c`DHT.h`\uff08\u7528\u4e8e\u8bfb\u53d6DHT11\u4f20\u611f\u5668\u6570\u636e\uff09\u8fd9\u4e09\u4e2a\u5e93\u3002\n\n2. **\u5168\u5c40\u53d8\u91cf\u548c\u5bf9\u8c61\u7684\u5b9a\u4e49**\uff1a\u5b9a\u4e49\u4e86\u8fde\u63a5WiFi\u548cModbus\u7269\u8054\u7f51\u5e73\u53f0\u6240\u9700\u7684\u4fe1\u606f\uff0c\u5982WiFi\u7684SSID\u548c\u5bc6\u7801\u3001MQTT\u670d\u52a1\u5668\u7684\u5730\u5740\u548c\u7aef\u53e3\u7b49\uff1b\u521b\u5efa\u4e86DHT\u5bf9\u8c61\u4ee5\u53caWiFi\u548cMQTT\u5ba2\u6237\u7aef\u5bf9\u8c61\u3002\n\n3. **setup_wifi()\u51fd\u6570**\uff1a\u6b64\u51fd\u6570\u7528\u4e8e\u8fde\u63a5\u6307\u5b9a\u7684WiFi\u7f51\u7edc\u3002\n\n4. **publish_message()\u51fd\u6570**\uff1a\u6b64\u51fd\u6570\u8bfb\u53d6DHT11\u4f20\u611f\u5668\u7684\u6e29\u5ea6\u548c\u6e7f\u5ea6\u6570\u636e\uff0c\u5c06\u6570\u636e\u5c01\u88c5\u6210JSON\u683c\u5f0f\u7684\u5b57\u7b26\u4e32\uff0c\u7136\u540e\u53d1\u5e03\u5230Modbus\u7269\u8054\u7f51\u5e73\u53f0\u7684\u7279\u5b9a\u4e3b\u9898\u3002\n\n5. **callback()\u51fd\u6570**\uff1a\u8fd9\u662f\u4e00\u4e2a\u56de\u8c03\u51fd\u6570\uff0c\u5f53ESP8266\u4eceModbus\u7269\u8054\u7f51\u5e73\u53f0\u63a5\u6536\u5230\u6d88\u606f\u65f6\uff0c\u6b64\u51fd\u6570\u5c06\u88ab\u8c03\u7528\u3002\n\n6. **reconnect()\u51fd\u6570**\uff1a\u5982\u679cESP8266\u4e0eModbus\u7269\u8054\u7f51\u5e73\u53f0\u7684\u8fde\u63a5\u65ad\u5f00\uff0c\u6b64\u51fd\u6570\u4f1a\u5c1d\u8bd5\u91cd\u65b0\u5efa\u7acb\u8fde\u63a5\u3002\n\n7. **setup()\u51fd\u6570**\uff1a\u8fd9\u662fArduino\u7a0b\u5e8f\u7684\u542f\u52a8\u51fd\u6570\uff0c\u7528\u4e8e\u521d\u59cb\u5316\u4e32\u53e3\u901a\u4fe1\u3001\u8fde\u63a5WiFi\u3001\u8bbe\u7f6eModbus\u7269\u8054\u7f51\u5e73\u53f0\u7684\u4fe1\u606f\u548c\u56de\u8c03\u51fd\u6570\u3001\u5f00\u59cb\u8bfb\u53d6DHT\u4f20\u611f\u5668\u6570\u636e\u3002\n\n8. **loop()\u51fd\u6570**\uff1a\u8fd9\u662fArduino\u7a0b\u5e8f\u7684\u4e3b\u5faa\u73af\uff0c\u4f1a\u6301\u7eed\u6267\u884c\u3002\u5728\u6b64\u51fd\u6570\u4e2d\uff0c\u5982\u679cESP8266\u4e0eModbus\u7269\u8054\u7f51\u5e73\u53f0\u7684\u8fde\u63a5\u65ad\u5f00\uff0c\u4f1a\u5c1d\u8bd5\u91cd\u65b0\u8fde\u63a5\uff0c\u7136\u540e\u6267\u884cMQTT\u5ba2\u6237\u7aef\u5faa\u73af\uff0c\u8bfb\u53d6\u5e76\u53d1\u5e03DHT11\u7684\u6e29\u5ea6\u548c\u6e7f\u5ea6\u6570\u636e\uff0c\u6bcf10\u79d2\u6267\u884c\u4e00\u6b21\u3002\n\n\u8fd9\u4e2a\u7a0b\u5e8f\u662f\u4e00\u4e2a\u57fa\u4e8eMQTT\u534f\u8bae\uff0c\u63a5\u5165Modbus\u7269\u8054\u7f51\u5e73\u53f0\u7684\u57fa\u7840\u5b9e\u4f8b\u3002\u7528\u6237\u53ef\u4ee5\u6839\u636e\u81ea\u5df1\u7684\u9700\u6c42\u8fdb\u884c\u4fee\u6539\u548c\u6269\u5c55\uff0c\u4ee5\u5b9e\u73b0\u66f4\u590d\u6742\u7684\u529f\u80fd\u548c\u66f4\u5e7f\u6cdb\u7684\u5e94\u7528\u3002\n\n---\n*modbus.cn*\n"