независимая выполнение двух задач MQTT ESP8266
- Войдите на сайт для отправки комментариев
Чт, 26/03/2020 - 20:59
Прошу помощи в оптимизации собранного скетча. зашел в тупик.
Задача устройства:
1.общение с MQTT брокером и получения от него команд и отправка информации.
2.при нажатии кнопки без фиксации (4пин) подавать высокий или низкий сигнал на 5пин.
Проблема: Устройство работает отлично если подключается к WiFi и брокеру, но если WiFi или брокер недоступен то и не работает переключения по пину 4.
Необходимо чтоб функция подключения и работа с пином 4 шли независимо. Т.е. если нет связи то выключатель работал.
Буду крайне благодарен за помощь или навигацию.
#include <ESP8266WiFi.h> #include <PubSubClient.h> #include <OneWire.h> #include <DallasTemperature.h> #include "GyverTimer.h" #define ONE_WIRE_BUS 2 OneWire oneWire(ONE_WIRE_BUS); DallasTemperature sensors(&oneWire); GTimer myTimer(MS); const char *ssid = "2"; // Имя вайфай точки доступа const char *pass = "newton812"; // Пароль от точки доступа const char *mqtt_server = "192.168.0.10"; // Имя сервера MQTT const int mqtt_port = 1883; // Порт для подключения к серверу MQTT const char *mqtt_user = "812"; // Логи от сервер const char *mqtt_pass = "812"; // Пароль от сервера #define BUFFER_SIZE 100 bool LedState = false; int tm=300; int ls=5; float temp=0; int Number = 300; int knopka=0; // Функция получения данных от сервера void callback(const MQTT::Publish& pub) { Serial.print(pub.topic()); // выводим в сериал порт название топика Serial.print(" => "); Serial.print(pub.payload_string()); // выводим в сериал порт значение полученных данных String payload = pub.payload_string(); if(String(pub.topic()) == "test/led") // проверяем из нужного ли нам топика пришли данные { int stled = payload.toInt(); // преобразуем полученные данные в тип integer digitalWrite(5,stled); // включаем или выключаем светодиод в зависимоти от полученных значений данных ///client.publish("test/ledstatus",String(1)); // отправляем в топик для термодатчика значение led } } WiFiClient wclient; PubSubClient client(wclient, mqtt_server, mqtt_port); void setup() { sensors.begin(); Serial.begin(115200); delay(10); Serial.println(); Serial.println(); pinMode(5, OUTPUT); myTimer.setInterval(2000); } void loop() { if(digitalRead(4)==HIGH&&knopka==0)//если кнопка нажата // и перемення "knopka" равна 0 , то ... { delay(50);//защита от дребезга knopka++;//пишем 1 в переменную кнопка //это нужно для того что бы с каждым нажатием кнопки //происходило только одно действие digitalWrite(5, !digitalRead(5));//меняем значение порта на противоположное } if(digitalRead(4)==LOW&&knopka==1)//если кнопка НЕ нажата //и переменная knopka равна - 1 ,то ... { knopka=0;//обнуляем переменную "knopka" } // подключаемся к wi-fi if (WiFi.status() != WL_CONNECTED) { Serial.print("Connecting to "); Serial.print(ssid); Serial.println("..."); WiFi.begin(ssid, pass); if (WiFi.waitForConnectResult() != WL_CONNECTED) return; Serial.println("WiFi connected"); } // подключаемся к MQTT серверу if (WiFi.status() == WL_CONNECTED) { if (!client.connected()) { Serial.println("Connecting to MQTT server"); if (client.connect(MQTT::Connect("arduinoClient2") .set_auth(mqtt_user, mqtt_pass))) { Serial.println("Connected to MQTT server"); client.set_callback(callback); client.subscribe("test/led"); // подписывааемся по топик с данными для светодиода } else { Serial.println("Could not connect to MQTT server"); } } if (client.connected()){ client.loop(); TempSend(); Ls(); } } } void TempSend(){ if (tm==0) { sensors.requestTemperatures(); // от датчика получаем значение температуры float temp = sensors.getTempCByIndex(0); client.publish("test/temp",String(temp)); // отправляем в топик для термодатчика значение температуры Serial.println(temp); tm = 300; // пауза меду отправками значений температуры коло 3 секунд } tm--; delay(5); } void Ls(){ if (myTimer.isReady()){ if (digitalRead(5) == HIGH){ Serial.println(1); client.publish("test/ls",String(1)); } else { Serial.println(0); client.publish("test/ls",String(0)); } } delay(5); }
Наверно нужно что-то сделать с кодом, который выходит из функции в случае отсутствия связи.
Ну и в целом всю эту кашу переформатировать, разложить на функции и задокументировать. Иначе так и будешь с любой мелочью биться по пять часов.
Согласен что проблема тут, только не озаряет как подкрутить момент.
я победил вопрос, хотя может не очень красиво выглядит, но работает.
Суть в том что при невозможность соединиться программа не зацикливаться на сединениии, а временно переходить в "аварийный режим работы" и какое то время находиться в нем. Позже пробует еще раз подцепиться или далее по результату.
Да есть задержка именно на момент соединения, но мне кажется это не критично. аварийный режим на то и аварийный чтоб хоть как то, а не коллапс.
Мож еще кому понравиться. Публикую.
подпишусь
Для Ардуины есть библиотека Givertimers. Там можно управлять системными прерываниями (для шим например) без затрат времени процессора. Хорошо бы ее переделать под Esp
https://github.com/AlexGyver/GyverLibs/tree/master/GyverTimers
Библиотек, работающих без "затрат времени процессора" быть не может. Вас обманули.
Я такое не говорил)
Нужна библиотека (можно и просто код) настраивающая работу системного таймера и при этом чтобы не задреживалось выполнение основного кода. Хотя конечно несколько тактов наверное будет теряться.
Из урока Гайвера "Прерывания по таймеру", я так понял, что такое возможно.
https://www.youtube.com/watch?v=cD11fsQDjDM&ab_channel=%D0%97%D0%B0%D0%B...
Можно ввести в поисковике "esp8266 timer" и вылезет много всего, например
"...добрые люди прямо в ядро ESP для Arduino встроили библиотеку Ticker"
Нужна - напишите, в чем вопрос?
Другое дело, что просто переделать библиотеку для AVR на ESP не получится - нужно писать с нуля. Ну и, честно говоря, чтобы сделать это, нужна документация на ESP, а с ней, насколько я знаю, не все хорошо (но детально я в этом не разбирался).
Там все плохо. Все доступные "прерывания", в т.ч. и пинов реализованы как обработчики одного аппаратного таймера. Т.е. инитиш прерывание пина, а на самом деле в обработчике таймера активируется ветка в которой пин периодически (порядка 1мсек) проверяется и твое прерывание активируется когда проверка пина выявит изменение. Причем на этом механизме висят не только твои обработчики, но и системные тоже. Так что только имеем "встроили библиотеку Ticker". До настоящих аппаратных в esp не добратся похоже.