Подключение к MQTT приводит к тому, что датчик DHT11 перестает работать?

У меня есть проект, над которым я работаю, основанный на ESP32 от NodeMCU. У меня есть куча датчиков, подключенных к указанному ESP32 — все они работают, и сам код «работает» с небольшой причудой.

Проблема начинается с датчика DHT11. Я начал с базового кода DHT11 «hello world» (вы можете легко найти его с помощью поиска DHT11 в Google). Этот датчик работает в моем коде, который вы можете видеть ниже - я скопировал и вставил пример кода, и, за исключением изменения переменных, фактически вообще не изменил образец кода.

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

Я полагаю, что изолировал проблему в этом фрагменте кода и соответствующей функции, которую он вызывает (раньше это не было функцией — это был шаг устранения неполадок):

  if (!client.connected()) {
    reconnectMQ();
  } etc...

Переместив этот оператор и сгруппировав сообщения MQTT в конец, система выполняет полный цикл с правильными показаниями ровно один раз, но после вызова этой функции DHT11 начинает не читать.

Вещи, которые я пробовал:

• разные имена переменных для температуры и влажности (в случае, если в библиотеке MQ используются "t" и "h")
• порядок операций (цикл заработал один раз)
• изменение reconnectMQ() на полноценную функцию, а не просто на цикл в основном цикле
• изменение логики датчика DHT11, чтобы хотя бы не зависать вечно при попытке чтения - это значит, что он прошел эту часть, но с 0 значениями
• "отключение" MQ - это значит, что все работает, но, очевидно, это немного похоже на отсечение руки за вывихнутое запястье.
• БЕСКОНЕЧНЫЕ поиски в Google и Stack, прежде чем прибегнуть к этому сообщению.

Я ненавижу это делать, так как мой проект состоит из 200 строк, но я подозреваю, что нужен полный код, чтобы увидеть, что, возможно, происходит.

#include <time.h>
#include <DHT.h>
#include <WiFi.h>
#include <PubSubClient.h>

//используем контакт 23 для считывания температуры и влажности
//наш датчик типа DHT11
//создает экземпляр датчика DHT
#define DHTPIN 23
#define DHTTYPE DHT11
DHT dht(DHTPIN, DHTTYPE);

// Определяем входящие аналоговые контакты для датчиков влажности почвы
const int sm1Pin = 33;
const int sm2Pin = 34;
const int sm3Pin = 35;
const int sm4Pin = 32;

const int power = 22;
const int exec = 21;
const int net = 19;

// определяем пин для считывания уровня освещенности
const int light = 36;

//Инициализируем массивы полезной нагрузки MQTT
char data0[50];
char data1[50];
char data2[50];

// объявляем наши соединения Wifi и MQTT и другие постоянные настройки для сети
const char* ssid     = "*******";            // SSID (имя) сети Wi-Fi, к которой вы хотите подключиться
const char* password = "*******";                          // Пароль сети Wi-Fi
const char* mqtt_server = "192.168.1.195";                             // Целевой сервер mqtt
const char* input_string = "{\"Reporting\":\"GardenUnit1\", ";       // Название этого садового монитора
String clientId = "GP1";
int lcount = 0;

// объявляем наши соединения Wifi и MQTT
WiFiClient espClient;
PubSubClient client(espClient);

//
// Повторно подключается к шине сообщений MQTT, если соединение прервано или мы
// иначе не подключен.
//
void reconnectMQ() {

  digitalWrite(net, LOW);  // выключаем синий светодиод NET

  if (WiFi.status() != WL_CONNECTED) {
    Serial.println("Wifi not connected - configuring");
    setup_wifi();
  } else {
    Serial.println("Wifi Connected - connecting MQTT");
  }

  // Попытка подключения
  Serial.println("Attempting to connect to MQTT Server...");
  while (!client.connected()) {
    if (client.connect(clientId.c_str())) {
      Serial.println("connected to MQTT server");
    } else {
      Serial.print("failed, rc=");
      Serial.print(client.state());
      Serial.println(" try again in 5 seconds");
      // Подождите 5 секунд перед повторной попыткой
      delay(5000);
    }
  }

  // После подключения публикуем объявление...
  String payload = String(input_string) + "\"MQTT\":\"Reconnected\"}";
  payload.toCharArray(data1, (payload.length() + 1));
  client.publish("control", data1); //тема "control" предназначена только для уведомлений - меняйте под свои нужды

  digitalWrite(net, HIGH);  // включить синий светодиод NET
  delay(5000);
}

void setup_wifi() {
  delay(10);
  Serial.print("Connecting to ");
  Serial.print(ssid); Serial.println(" ...");

  WiFi.begin(ssid, password);             // Подключаемся к сети Wi-Fi

  while (WiFi.status() != WL_CONNECTED) // Подождите, пока Wi-Fi подключится
    delay(1000);
    Serial.print('.');

  Serial.println('\n');
  Serial.println("Connected!");  
  Serial.print("IP address:\t");
  Serial.println(WiFi.localIP());         // Отправляем IP-адрес ESP32 на последовательный порт

}

void setup() {
  Serial.begin(9600); // открываем последовательный порт, устанавливаем скорость передачи 9600 бит/с
  // Эти параметры контролируют точность показаний и возможность снижения напряжения ESP32.
  // Затухание номер 3 равно 11 дБ
  analogSetWidth(10);
  analogSetAttenuation((adc_attenuation_t)3);

  // Определяем настройки подключения к серверу MQTT, а затем запускаем подключение MQTT
  client.setServer(mqtt_server, 1883);

  // Установить выходные и входные контакты в правильные режимы
  pinMode (power, OUTPUT);
  pinMode (exec, OUTPUT);
  pinMode (net, OUTPUT);

  // Включите зеленый индикатор питания
  digitalWrite (power, HIGH);

  //Подключаемся к беспроводной сети
  setup_wifi();

  //Этот вызов запускает экземпляр датчика dht11
  dht.begin();
}

void loop() {
  // Включите КРАСНЫЙ индикатор EXEC — это означает, что берется образец
  digitalWrite (exec, HIGH);

  // Чтение DHT11 Temp and Humidity — влажность в %, а температура в градусах Цельсия
  float hum = dht.readHumidity();
  float temp = dht.readTemperature();
  // Проверяем, не завершились ли какие-либо операции чтения, но вставляем фиктивные данные, чтобы система продолжала работать
    if (isnan(hum) || isnan(temp)) {
        Serial.println("Failed to read from DHT sensor!");
        client.publish("garden1", "{\"Error\":\"Humidty/Temp Sensor Offline!\"}");
        hum = 0;
        temp = 0;
    } else {
        // вывод результата в Терминал
        Serial.print("Humidity: ");
        Serial.print(hum);
        Serial.print(" %\t");
        Serial.print("Temperature: ");
        Serial.print(temp);
        Serial.println(" *C ");
    }

  //Чтение значения и печать в серийный номер для S1
  float s1 = analogRead(sm1Pin); 
  Serial.print("Sensor 1: ");
  Serial.print(s1); 
  Serial.println();
  //Чтение значения и печать в серийный номер для S2
  float s2 = analogRead(sm2Pin); 
  Serial.print("Sensor 2: ");
  Serial.print(s2); 
  Serial.println();
  //Чтение значения и печать в серийный номер для S3
  float s3 = analogRead(sm3Pin); 
  Serial.print("Sensor 3: ");
  Serial.print(s3); 
  Serial.println();
  //Чтение значения и печать в серийный номер для S4
  float s4 = analogRead(sm4Pin); 
  Serial.print("Sensor 4: ");
  Serial.print(s4); 
  Serial.println();

  float L1 = analogRead(light);
  Serial.print("Light level: ");
  Serial.print(L1);
  Serial.println();


  if (!client.connected()) {
    reconnectMQ();
  }

  String payload = String(input_string) + "\"S1\":\"" + s1 + "\", \"S2\":\"" + s2 + "\", \"S3\":\"" + s3 + "\", \"S4\":\"" + s4 + "\"}";
  payload.toCharArray(data0, (payload.length() + 1));
  Serial.println("Publishing message 1:");
  while (!client.publish("garden1", data0)) {
    Serial.print(".");
  }
  String payload2 = String(input_string) + "\"Humidity\":\"" + hum + "\", \"Temperature\":\"" + temp + "\", \"Light\":\"" + L1 + "\"}";
  payload2.toCharArray(data2, (payload2.length() + 1));
  Serial.println("Publishing message 2:");
  while (!client.publish("garden1", data2)){
    Serial.print(".");
  }

  //Выключить КРАСНЫЙ индикатор EXEC — это означает, что образец готов
  digitalWrite (exec, LOW);
  lcount = lcount + 1;
  delay(10000);
}

Что происходит, когда код, который у меня есть здесь, работает, так это то, что я вижу все сообщения на сервере Mosquito и в последовательном мониторе, и цикл работает, как и ожидалось. Из-за логики, которую я должен был использовать, чтобы программа продолжала работать, после первого считывания с DHT11 температура и шум навсегда возвращаются к 0. Это явно не то, чего я хочу.

Что очевидно: Что-то происходит между первым чтением DHT11 и следующим, что делает его несчастным.

Что не так: Что это такое. Это что-то происходит в соединении MQTT, но я не могу понять, что это такое, или изолировать это.

Теперь я оставляю это сообществу. Какого черта здесь происходит?!