независимая выполнение двух задач MQTT ESP8266

Felekc
Offline
Зарегистрирован: 11.06.2018

Прошу помощи в оптимизации собранного скетча. зашел в тупик.

Задача устройства:

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

 

rkit
Offline
Зарегистрирован: 23.11.2016

Наверно нужно что-то сделать с кодом, который выходит из функции в случае отсутствия связи.

if (WiFi.waitForConnectResult() != WL_CONNECTED)
	return;

Ну и в целом всю эту кашу переформатировать, разложить на функции и задокументировать. Иначе так и будешь с любой мелочью биться по пять часов.

Felekc
Offline
Зарегистрирован: 11.06.2018

Согласен что проблема тут, только не озаряет как подкрутить момент. 

Felekc
Offline
Зарегистрирован: 11.06.2018

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

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

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

Мож еще кому понравиться. Публикую.

// Светодиод подлкючен к 5 пину
// Датчик температуры ds18b20 к 2 пину

#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 = "1"; // Имя вайфай точки доступа
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"
}
client.loop();
Conect();
}

// конец основного цикла

// Функция отправки показаний с термодатчика
void Conect()
{
// подключаемся к 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("Fol");
client.loop();
fol();

}

// подключаемся к 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);
      
}
      
void fol()
{
  int a =0;
  label:
  Serial.println("Fol start" );
  Serial.println(a);
  
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"
}

delay(100);
a++;
if (a > 200)
{
  return;
}
else
{
goto label;
}
}      


 

ua6em
ua6em аватар
Offline
Зарегистрирован: 17.08.2016

подпишусь

Alexxx
Offline
Зарегистрирован: 06.07.2017

Для Ардуины есть библиотека Givertimers. Там можно управлять системными прерываниями (для шим например) без затрат времени процессора. Хорошо бы ее переделать под Esp

https://github.com/AlexGyver/GyverLibs/tree/master/GyverTimers

sadman41
Offline
Зарегистрирован: 19.10.2016

Библиотек, работающих без "затрат времени процессора" быть не может. Вас обманули.

Alexxx
Offline
Зарегистрирован: 06.07.2017

Я такое не говорил)

Нужна библиотека (можно и просто код) настраивающая работу системного таймера и при этом чтобы не задреживалось выполнение основного кода. Хотя конечно несколько тактов наверное будет теряться.

Из урока Гайвера "Прерывания по таймеру", я так понял, что такое возможно.

https://www.youtube.com/watch?v=cD11fsQDjDM&ab_channel=%D0%97%D0%B0%D0%B...

 

 

OK0
Offline
Зарегистрирован: 06.03.2020

Можно ввести в поисковике "esp8266 timer" и вылезет много всего, например 

"...добрые люди прямо в ядро ESP для Arduino встроили библиотеку Ticker"

andriano
andriano аватар
Offline
Зарегистрирован: 20.06.2015

Нужна - напишите, в чем вопрос?

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

Logik
Offline
Зарегистрирован: 05.08.2014

Там все плохо. Все доступные "прерывания", в т.ч. и пинов реализованы как обработчики одного аппаратного таймера. Т.е. инитиш прерывание пина, а на самом деле в обработчике таймера активируется ветка в которой пин периодически (порядка 1мсек) проверяется и твое прерывание активируется когда проверка пина выявит изменение.  Причем на этом механизме висят не только твои обработчики, но и системные тоже. Так что только имеем "встроили библиотеку Ticker". До настоящих аппаратных в esp не добратся похоже.