ESP8266入门教程11：连接MQTT服务器 将第三方库PubSubClient下载到lib文件夹 git clone https://github.com/knolleary/pubsubclient.git 一、阿里云IOT使用 1、打开阿里云IOT官网，登录阿里云账号 https://iot.console.aliyun.com 2、创建实例 3、新建产品 4、自定义主题  5、添加设备  6、查看设备配置   二、连接阿里云MQTT服务器 1、修改PubSubClient.h头文件，否则无法连接阿里云MQTT服务器 将MQTT_MAX_PACKET_SIZE的值改为1024 将MQTT_KEEPALIVE的值改为65 2、代码解析 第27行：创建WIFI客户端 第28行：创建MQTT客户端 第29行：创建任务对象 第30行：定义MQTT消息发送函数 第32行：发送消息前先判断MQTT服务器是否连接成功 第37行：发送MQTT消息 第47行：定义MQTT消息接收函数 第53行：定义MQTT服务器连接函数 第54行：请求连接MQTT服务器 第59行：订阅MQTT主题 第64行：开始定时任务，每隔三秒发送一条MQTT消息 第67行：结束定时任务 第82行：设置MQTT服务器主机地址和端口号 第84行：设置MQTT消息接收回调函数 第94行：保持MQTT客户端心跳，否则会连接中断 三、测试效果 四、完整代码 #include #include #include #include "../lib/pubsubclient/src/PubSubClient.h" #define WIFI_SSID "WWW" #define WIFI_PASS "00000000" #define MQTT_HOST "MQTT服务器地址" #define MQTT_PORT 1883 #define MQTT_CLIENT_ID "MQTT客户端名称" #define MQTT_USER "MQTT用户名" #define MQTT_PASS "MQTT登录密码" void connectWIFI() { // 连接WIFI热点 WiFi.begin(WIFI_SSID, WIFI_PASS); int retryCount = 1; while (WiFi.status() != WL_CONNECTED) { Serial.println("重试次数: " + String(retryCount)); retryCount++; delay(1000); } Serial.println("WIFI连接成功"); Serial.println("IP地址: " + WiFi.localIP().toString()); } WiFiClient wifiClient; PubSubClient mqttClient(wifiClient); Ticker ticker; void sendMsg() { if (mqttClient.connected()) { String topic = "/a1aeNGS45Gg/"; topic += "ESP8266"; topic += "/user/info"; String payload = "Hello World !"; if (mqttClient.publish(topic.c_str(), payload.c_str())) { Serial.println("MQTT消息发送成功"); } else { Serial.println("MQTT消息发送失败"); } } else { Serial.println("MQTT服务器未连接"); } } void recvMsg(char *topic, uint8_t *payload, size_t length) { Serial.println("topic: " + String(topic)); Serial.println("payload: " + String((char *)payload).substring(0, length)); Serial.println("length: " + String(length)); } void connectMQTT() { if (mqttClient.connect(MQTT_CLIENT_ID, MQTT_USER, MQTT_PASS)) { Serial.println("MQTT服务器连接成功"); String topic = "/a1aeNGS45Gg/"; topic += "ESP8266"; topic += "/user/info"; if (mqttClient.subscribe(topic.c_str())) { Serial.println("MQTT主题订阅成功"); } else { Serial.println("MQTT主题订阅失败"); } ticker.attach(3, sendMsg); } else { Serial.println("MQTT服务器连接失败"); ticker.detach(); delay(3000); } } void setup() { // put your setup code here, to run once: // 设置波特率 Serial.begin(9600); Serial.println(); // 连接WIFI热点 connectWIFI(); // 配置MQTT服务器 mqttClient.setServer(MQTT_HOST, MQTT_PORT); // 设置回调函数 mqttClient.setCallback(recvMsg); // 连接MQTT服务器 connectMQTT(); } void loop() { // put your main code here, to run repeatedly: // 判断MQTT服务器是否连接成功 if (mqttClient.connected()) { mqttClient.loop(); } else { connectMQTT(); } }