ESP8266循环结合HTTP与MQTT调用时反复断连的解决方案问询

核心原因分析 #

ESP8266的Wi-Fi硬件资源有限，同步HTTP请求会长时间占用Wi-Fi连接并阻塞主线程，导致MQTT客户端无法及时发送心跳包或调用loop()方法维持连接，最终被MQTT Broker判定为连接断开。

具体修复方案 #

1. 重构循环逻辑，优先保证MQTT连接维持 #

将MQTT的连接检查与loop()调用放在循环最前端，确保它被高频执行，不被HTTP请求长时间阻塞。同时改用非阻塞定时触发HTTP请求，避免同步请求占用过多时间。

2. 优化HTTP请求的资源管理 #

• 给HTTP请求设置超时时间，防止请求卡住导致主线程阻塞
• 每次HTTP请求完成后，主动关闭连接释放Wi-Fi资源
• 避免短时间内频繁发起HTTP请求，增加请求间隔

3. 优化MQTT重连逻辑 #

添加重连延迟机制，避免连接失败时反复重试，进一步占用资源。

修复后的代码示例 #

#include <ESP8266WiFi.h>
#include <ESP8266HTTPClient.h>
#include <PubSubClient.h>

WiFiClient espClient;
PubSubClient mqttClient(espClient);
HTTPClient http;

// Wi-Fi与MQTT配置
const char* ssid = "YOUR_SSID";
const char* password = "YOUR_PASSWORD";
const char* mqttServer = "YOUR_MQTT_BROKER";
const int mqttPort = 1883;
const char* mqttTopic = "YOUR_TOPIC";

// HTTP请求定时参数
unsigned long previousHttpMillis = 0;
const long httpRequestInterval = 10000; // 每10秒发起一次HTTP请求

void setup() {
  Serial.begin(115200);
  WiFi.begin(ssid, password);
  
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
  Serial.println("WiFi connected");

  mqttClient.setServer(mqttServer, mqttPort);
}

void loop() {
  // 优先处理MQTT连接与心跳
  if (!mqttClient.connected()) {
    reconnectMQTT();
  }
  mqttClient.loop();

  // 非阻塞式触发HTTP请求
  unsigned long currentMillis = millis();
  if (currentMillis - previousHttpMillis >= httpRequestInterval) {
    previousHttpMillis = currentMillis;
    sendHttpRequest();
  }
}

// 优化后的MQTT重连函数
void reconnectMQTT() {
  static unsigned long lastReconnectAttempt = 0;
  unsigned long currentMillis = millis();

  // 每5秒尝试一次重连，避免频繁重试
  if (currentMillis - lastReconnectAttempt > 5000) {
    lastReconnectAttempt = currentMillis;
    if (mqttClient.connect("ESP8266_Client")) {
      Serial.println("MQTT connected");
      mqttClient.subscribe(mqttTopic); // 按需订阅主题
    } else {
      Serial.print("MQTT连接失败，错误码: ");
      Serial.println(mqttClient.state());
    }
  }
}

// 封装HTTP请求函数，添加资源清理与超时
void sendHttpRequest() {
  if (WiFi.status() != WL_CONNECTED) {
    Serial.println("Wi-Fi未连接，跳过HTTP请求");
    return;
  }

  http.begin(espClient, "http://your-api-url.com/data");
  http.setTimeout(5000); // 设置5秒超时

  int httpCode = http.GET();
  if (httpCode > 0) {
    String payload = http.getString();
    Serial.print("HTTP响应码: ");
    Serial.println(httpCode);
    Serial.print("响应内容: ");
    Serial.println(payload);

    // 可将HTTP获取的数据通过MQTT发布
    mqttClient.publish(mqttTopic, payload.c_str());
  } else {
    Serial.print("HTTP请求失败，错误码: ");
    Serial.println(httpCode);
  }

  // 强制释放HTTP连接资源
  http.end();
  espClient.stop();
}

额外优化建议 #

• 降低HTTP请求频率：根据实际需求调整httpRequestInterval，避免过于频繁占用Wi-Fi资源
• 调整MQTT心跳参数：初始化MQTT客户端时，通过setKeepAlive()设置合适的心跳间隔（比如30秒），确保ESP8266能在间隔内完成心跳发送
• 减小HTTP数据量：请求仅获取必要数据，避免传输大体积内容
• 调试定位：通过串口打印HTTP请求耗时、MQTT连接状态，进一步排查是否存在其他阻塞点

内容的提问来源于stack exchange，提问作者Kalpesh Navadiya