- \n
- ESP8266 connects to the free public MQTT broker<\/a><\/li>\n
- MQTT\u6559\u5b78\uff08\u516d\uff09\uff1a\u4f7f\u7528PubSubClient\u7a0b\u5f0f\u5eab\u958b\u767cArduino MQTT\u61c9\u7528<\/a><\/li>\n
- ESP8266 \u8fde\u63a5\u5230\u514d\u8d39\u7684\u516c\u5171 MQTT \u670d\u52a1\u5668<\/a><\/li>\n
- ESP8266: Connecting to MQTT broker<\/a><\/li>\n
- HOW TO PUBLISH WHILE SUBSCRIBING IN MQTT PROTOCOL WHILE USING ESP8266?<\/a><\/li>\n
- mqtt_meshblu_send_receive.ino<\/a><\/li>\n<\/ul>\n
--<\/p>\n
\u767c\u9001\u53ca\u8a02\u95b1<\/h2>\n
\u4e00\u6a23\u5148\u4f7f\u7528\u514d\u8cbb\u516c\u958b\u7684\u00a0test.mosquitto.org \u5be6\u9a57<\/p>\n
\u76ee\u6a19\u662f\u5b9a\u6642\u5f80\u4e0a\u767c\u9001\u8cc7\u6599\u4e26\u4e14\u8a02\u95b1\u63a7\u5236 LED \u7684\u4e3b\u984c\uff0cLED \u4e00\u6a23\u662f Onboard \u7684 D4<\/p>\n
#include <ESP8266WiFi.h>\r\n#include <PubSubClient.h>\r\n#include <ArduinoJson.h>\r\n\r\n\/\/\r\nconst char* ssid = \"ssid\";\r\nconst char* password = \"passowrd\";\r\nconst char *mqtt_broker = \"test.mosquitto.org\";\r\nconst int mqtt_port = 1883;\r\n\r\nWiFiClient wifi;\r\nPubSubClient client(wifi);\r\n\r\n\/\/ \u8a2d\u5b9a\u7528\u6236\u7aefID\r\nconst char clientID[] = \"hoyo_esp8266\";\r\n\/\/ \u8a2d\u5b9a\u4e3b\u984c\u540d\u7a31\r\nconst char topic[] = \"Hoyo\/ESP8266\";\r\n\/\/ \u5132\u5b58\u8a0a\u606f\u7684\u5b57\u4e32\u8b8a\u6578\r\nString msgStr = \"\";\r\n\/\/ \u5132\u5b58\u5b57\u5143\u9663\u5217\u683c\u5f0f\u7684\u8a0a\u606f\u5b57\u4e32\uff08\u53c3\u95b1\u4e0b\u6587\u8aaa\u660e\uff09\r\nchar json[25];\r\n\r\nvoid reconnect() {\r\n \/\/ \u82e5\u76ee\u524d\u6c92\u6709\u548c\u4f3a\u670d\u5668\u76f8\u9023\uff0c\u5247\u53cd\u8986\u57f7\u884c\u76f4\u5230\u9023\u7d50\u6210\u529f\u2026\r\n while (!client.connected()) {\r\n \/\/ \u6307\u5b9a\u7528\u6236\u7aefID\u4e26\u9023\u7d50MQTT\u4f3a\u670d\u5668\r\n \/\/ client.connect(clientID, mqtt_username, mqtt_password))\r\n if (client.connect(clientID)) {\r\n Serial.println(\"connected\");\r\n\r\n \/\/ \u6210\u529f\u9023\u7dda\u8a02\u95b1\u4e3b\u984c\r\n client.subscribe(\"esp8266\/test\");\r\n }\r\n else {\r\n \/\/ \u82e5\u9023\u7dda\u4e0d\u6210\u529f\uff0c\u5247\u986f\u793a\u932f\u8aa4\u8a0a\u606f\r\n Serial.print(\"failed, rc=\");\r\n Serial.print(client.state());\r\n Serial.println(\" try again in 5 seconds\");\r\n \/\/ \u7b49\u50195\u79d2\uff0c\u518d\u91cd\u65b0\u5617\u8a66\u9023\u7dda\u3002\r\n delay(5000);\r\n }\r\n }\r\n}\r\n\r\nvoid callback(char *topic, byte *payload, unsigned int length) {\r\n char inData[256];\r\n\r\n Serial.print(\"Message arrived in topic: \");\r\n Serial.println(topic);\r\n Serial.print(\"Message:\");\r\n for (int i = 0; i < length; i++) {\r\n inData[i] = (char)payload[i];\r\n Serial.print((char) payload[i]);\r\n }\r\n\r\n DynamicJsonDocument doc(1024);\r\n deserializeJson(doc, inData);\r\n JsonObject obj = doc.as<JsonObject>();\r\n \/\/ Serial.println(obj);\r\n String led = obj[\"LED\"];\r\n if (led == \"0\") digitalWrite(D4, HIGH);\r\n if (led == \"1\") digitalWrite(D4, LOW);\r\n Serial.println(led);\r\n\r\n Serial.println();\r\n Serial.println(\"-----------------------\");\r\n}\r\n\r\nvoid setup() {\r\n Serial.begin(9600);\r\n\r\n pinMode(D4, OUTPUT);\r\n\r\n WiFi.mode(WIFI_STA);\r\n WiFi.begin(ssid, password);\r\n while (WiFi.status() != WL_CONNECTED) {\r\n delay(500);\r\n Serial.println(\".\");\r\n }\r\n\r\n Serial.println(\"WiFi connected\");\r\n\r\n client.setServer(mqtt_broker, mqtt_port);\r\n client.setCallback(callback);\r\n}\r\n\r\nvoid loop() {\r\n\r\n \/\/ \u78ba\u8a8d\u7528\u6236\u7aef\u662f\u5426\u5df2\u9023\u4e0a\u4f3a\u670d\u5668\r\n if (!client.connected()) {\r\n \/\/ \u82e5\u6c92\u6709\u9023\u4e0a\uff0c\u5247\u57f7\u884c\u6b64\u81ea\u8a02\u51fd\u5f0f\u3002\r\n reconnect();\r\n }\r\n \/\/ \u66f4\u65b0\u7528\u6236\u7aef\u72c0\u614b\r\n client.loop();\r\n\r\n \/\/ \u5efa\u7acbMQTT\u8a0a\u606f\uff08JSON\u683c\u5f0f\u7684\u5b57\u4e32\uff09\r\n msgStr = msgStr + \"{\\\"temp\\\":\" + 10 + \",\\\"humid\\\":\" + 20 + \"}\";\r\n \/\/ \u628aString\u5b57\u4e32\u8f49\u63db\u6210\u5b57\u5143\u9663\u5217\u683c\u5f0f\r\n msgStr.toCharArray(json, 25);\r\n \/\/ \u767c\u5e03MQTT\u4e3b\u984c\u8207\u8a0a\u606f\r\n client.publish(topic, json);\r\n \/\/ \u6e05\u7a7aMQTT\u8a0a\u606f\u5167\u5bb9\r\n msgStr = \"\";\r\n\r\n delay(2000);\r\n}<\/pre>\n--<\/p>\n
Windows MQTT Client<\/h2>\n
- MQTT\u6559\u5b78\uff08\u516d\uff09\uff1a\u4f7f\u7528PubSubClient\u7a0b\u5f0f\u5eab\u958b\u767cArduino MQTT\u61c9\u7528<\/a><\/li>\n
![\"\"](\"https:\/\/blog.hoyo.idv.tw\/wp-content\/uploads\/2020\/12\/1607236213-300x203.png\")
<\/a><\/p>\n