client.subscribe() 需要很长时间（30-45 秒）来接收消息

Question

在使用 Arduino MQTT 客户端时，我观察到，当我发布到一个主题时，消息会立即发送到代理。我在 mqtt.fx 工具的帮助下确认了这一点。在从代理处接收同一主题的消息时，我在长时间延迟后收到已发布的消息。我正在使用在 Openhab 2.5

上配置的 Mosquitto 代理

这是我正在使用的代码：

#include <Arduino.h>
#include <ESP8266WiFi.h>
#include <PubSubClient.h>
#include <Wire.h>
#include <SeeedOLED.h>

const char* ssid = "Network";
const char* password = "NetworkPass";

#define mqtt_server "OpenhabIP"

WiFiClient espClient;
PubSubClient client(espClient);

void reconnect() {
  while (!client.connected()) {
    Serial.print("Attempting MQTT connection...");
    if (client.connect("ESP8266Client","user","pass")) {
      Serial.println("connected");
    }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){
  char k=(char)payload[0];
  if(k=='0'){
    SeeedOled.clearDisplay();          
    SeeedOled.setNormalDisplay();      
    SeeedOled.setPageMode();           
    SeeedOled.setTextXY(0, 0);         
    SeeedOled.putString("Magnet");
  }else{
    SeeedOled.clearDisplay();          
    SeeedOled.setNormalDisplay();      
    SeeedOled.setPageMode();           
    SeeedOled.setTextXY(0, 0);         
    SeeedOled.putString("No Magnet");
  }
}

void setup()
{
  pinMode(15, OUTPUT); //To enable Wio Link Board
  digitalWrite(15, 1);
  Serial.begin(9600);
  Wire.begin(4,5);
  SeeedOled.init();
  WiFi.begin(ssid, password);
  Serial.print("Connecting");
  while (WiFi.status() != WL_CONNECTED)
  {
    delay(500);
    Serial.print(".");
  }
  Serial.println();
  Serial.print("Connected, IP address: ");
  Serial.println(WiFi.localIP());
  client.setServer(mqtt_server,1883);
  pinMode(3, INPUT); //Enable Input for hall sensor
  client.setCallback(callback);
}

void loop()
{
  if (!client.connected()) {
    reconnect();
  }
  client.loop();
  client.publish("EntComp/HallSensor",String(digitalRead(3)).c_str(),true);
  client.subscribe("EntComp/HallSensor");
  delay(1000);
}

我是在基于 ESP8266-12E 模块的 Wio Node 开发板上完成的。在不同的板上使用 client.subscribe() 和 client.publish() 函数时，我遇到了同样的问题。我不明白为什么会有这么大的延迟。是代码有问题还是我做错了什么？

Answer 1

您的代码（循环）有 "huge" 延迟：

   delay(1000);

这会在每个循环周期中停止处理 1 秒，因此如果它需要十个周期来处理某些东西，那么您的 CPU 总共等待 10 秒。请参阅 ArduinoIDE 中的 blinkwithoutdelay 示例如何等待，例如在重新进入例程之前持续一秒钟，而不会阻止其他活动（子）例程。在基于通信的程序中，"old" 说法 "Never use delay" 是 100% 正确的。
也去掉

 delay(5000);

在重新连接例程中作为一个很好的练习。
对于这里的聪明人：是的，我知道
设置过程中的延迟（只运行一次）是在谨慎和故意使用的情况下还不错。

client.subscribe() 需要很长时间（30-45 秒）来接收消息

client.subscribe() taking a long time (30-45 seconds) to receive messages

c++

arduino

mqtt

esp8266