client.subscribe（）需要很长时间来接收消息

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()功能时，我面临相同的问题。我不明白为什么会有这么大的延迟。是因为代码中的错误还是我做错了？

[在使用Arduino MQTT客户端时，我观察到，当我发布一个主题时，消息立即发送到代理。我在mqtt.fx工具的帮助下确认了这一点。而...

Answer 1

您的代码中存在“巨大”延迟：