client.subscribe () занимает много времени (30-45 секунд) для получения сообщений - PullRequest
Новая
       27

client.subscribe () занимает много времени (30-45 секунд) для получения сообщений

0 голосов
/ 19 марта 2020

Во время работы с клиентом Arduino MQTT я заметил, что при публикации в topi c сообщения сразу отправляются брокеру. Я подтвердил это с помощью инструмента mqtt.fx. При получении сообщений от брокера по той же теме c я получаю опубликованные сообщения после большой задержки. Я использую брокер Mosquitto, настроенный на Openhab 2.5

Вот код, который я использую: 

#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);
}

Я сделал все это на плате разработки Wio Node, основанной на ESP8266 -12Е модуль. Я сталкиваюсь с той же проблемой при использовании функций client.subscribe() и client.publish() на разных платах. Я не могу понять, почему происходит такая огромная задержка. Это из-за ошибки в коде или я что-то не так делаю?

1 Ответ

2 голосов
/ 19 марта 2020

В вашем коде "огромная" задержка (l oop): 

   delay(1000);

Это останавливает обработку на 1 секунду в каждом цикле l oop, поэтому, если для обработки требуется десять циклов что-то его 10 бесполезных секунд, которые ваш процессор ждет в общей сложности. См. Пример blinkwithoutdelay в ArduinoIDE, как подождать, например, одну секунду, прежде чем повторно вводить процедуру, не блокируя другие активные (под) процедуры. В программах, основанных на общении, «старая» поговорка «Никогда не используйте задержку» верна на 100%.
Избавьтесь также от 

 delay(5000);

в процедуре переподключения в качестве хорошего упражнения.
Для мудрых ребят здесь: Да, я знаю
Задержка во время настройки (которая запускается только один раз) ), когда используется осторожно и сознательно не так уж плохо.

...