Скиньте пожалуйста ваш скетч, может я чего то не замечаю,что нужно исправить.WZV писал(а):Я же по вашей схеме сделал, всё нормально работает. На Iobroker. Единственное что я изменил, так это название топика. Советую и вам поставить одно и тоже название топика в подписке и публикации на каждый выход реле.
Вот с этого и надо было начинать.yopopol писал(а):проверьте пожалуйста мой,если будет время
это как понимать? Куда записывать?yopopol писал(а):если записывать его из версии 2.2 , то всё отлично
пробовал менять,проблема не исчезлаWZV писал(а):Посмотрел ваш скетч. Может причина в названиях топиков, у меня через косую черту. Я задаю точнее адрес, типа фильтрации, чтобы на каждую ардуину приходило только то, что адресуется только ей. Посмотрите информацию, в интернете, о названиях топиков в MQTT.
Код: Выделить всё
#include <PubSubClient.h>
#include <SPI.h>
#include <Ethernet2.h>
bool EN;
bool MQTT_receivedMessage=0; //Флаг получения сообщения
bool MQTT_PublishPost=0; // Флаг публиковать все Публикации
EthernetClient ethClient;
//byte ethernet_mac[] = {0x04, 0x61, 0x77, 0xE9, 0xC0, 0x02};
byte ethernet_mac[] = {0x78, 0xAC, 0xC0, 0xBB, 0xB0, 0x77};
IPAddress ethernet_ip(192,168,1,37);
byte ethernet_dns[] = { 192,168,1,1 };
byte ethernet_gateway[] = { 192,168,1,1 };
byte ethernet_subnet[] = { 255,255,255,0 };
void callback(char* topic, byte* payload, unsigned int length); // обяляение функции,
PubSubClient MQTTclient( 192,168,1,35 , 1883 , callback, ethClient);
long lastReconnectAttempt= 0;
String MQTT_topictext; //Строка с топиком, с которого поступило сообщение
String MQTT_inputtext; //сообщение
const char *MQTTtext;
bool EN_186572787_5;
String Message_186572787_5;
bool New_186572787_5;
bool Send_57915906_5;
String Message_57915906_5;
bool lastSend_57915906_5=0;
bool Send_57915906_8;
String Message_57915906_8;
bool lastSend_57915906_8=0;
bool EN_186572787_1;
String Message_186572787_1;
bool New_186572787_1;
bool EN_186572787_2;
String Message_186572787_2;
bool New_186572787_2;
bool Send_57915906_1;
String Message_57915906_1;
bool lastSend_57915906_1=0;
bool EN_186572787_3;
String Message_186572787_3;
bool New_186572787_3;
bool Send_57915906_6;
String Message_57915906_6;
bool lastSend_57915906_6=0;
bool Send_57915906_7;
String Message_57915906_7;
bool lastSend_57915906_7=0;
bool Send_57915906_2;
String Message_57915906_2;
bool lastSend_57915906_2=0;
bool _gtv1 = 0;
bool _gtv2 = 0;
bool _gtv3 = 0;
bool _gtv4 = 0;
bool _bounseInputD7S = 0;
bool _bounseInputD7O = 0;
unsigned long _bounseInputD7P = 0UL;
bool _bounseInputD8S = 0;
bool _bounseInputD8O = 0;
unsigned long _bounseInputD8P = 0UL;
String _swi2;
bool _trgrt3 = 0;
bool _trgrt3I = 0;
bool _bounseInputD6S = 0;
bool _bounseInputD6O = 0;
unsigned long _bounseInputD6P = 0UL;
String _swi1;
String _swi5;
bool _trgrt2 = 0;
bool _trgrt2I = 0;
bool _bounseInputD9S = 0;
bool _bounseInputD9O = 0;
unsigned long _bounseInputD9P = 0UL;
bool _trgrt8 = 0;
bool _trgrt8I = 0;
bool _trgrt6 = 0;
bool _trgrt6I = 0;
void setup()
{
pinMode(9, INPUT);
digitalWrite(9, HIGH);
pinMode(8, INPUT);
digitalWrite(8, HIGH);
pinMode(7, INPUT);
digitalWrite(7, HIGH);
pinMode(6, INPUT);
digitalWrite(6, HIGH);
pinMode(3, OUTPUT);
pinMode(4, OUTPUT);
pinMode(5, OUTPUT);
_bounseInputD9O = digitalRead(9);
_bounseInputD8O = digitalRead(8);
_bounseInputD6O = digitalRead(6);
_bounseInputD7O = digitalRead(7);
Ethernet.begin(ethernet_mac, ethernet_ip );
delay(1000); //Задержка на запуск
}
void loop()
{
bool _bounceInputTmpD9 = (digitalRead (9));
if (_bounseInputD9S)
{
if (millis() >= (_bounseInputD9P + 40))
{_bounseInputD9O= _bounceInputTmpD9; _bounseInputD9S=0;}
}
else
{
if (_bounceInputTmpD9 != _bounseInputD9O )
{_bounseInputD9S=1; _bounseInputD9P = millis();}
}
bool _bounceInputTmpD8 = (digitalRead (8));
if (_bounseInputD8S)
{
if (millis() >= (_bounseInputD8P + 40))
{_bounseInputD8O= _bounceInputTmpD8; _bounseInputD8S=0;}
}
else
{
if (_bounceInputTmpD8 != _bounseInputD8O )
{_bounseInputD8S=1; _bounseInputD8P = millis();}
}
bool _bounceInputTmpD6 = (digitalRead (6));
if (_bounseInputD6S)
{
if (millis() >= (_bounseInputD6P + 40))
{_bounseInputD6O= _bounceInputTmpD6; _bounseInputD6S=0;}
}
else
{
if (_bounceInputTmpD6 != _bounseInputD6O )
{_bounseInputD6S=1; _bounseInputD6P = millis();}
}
bool _bounceInputTmpD7 = (digitalRead (7));
if (_bounseInputD7S)
{
if (millis() >= (_bounseInputD7P + 40))
{_bounseInputD7O= _bounceInputTmpD7; _bounseInputD7S=0;}
}
else
{
if (_bounceInputTmpD7 != _bounseInputD7O )
{_bounseInputD7S=1; _bounseInputD7P = millis();}
}
//Плата:1
//Наименование:Главный блок
EN = 1;
MQTT_PublishPost=0;
MQTT_receivedMessage=0;
if ( EN ){
if (!MQTTclient.connected()) { //Если нет сооедиения
long now = millis();
if (now - lastReconnectAttempt > 5000) { // ждем 5 секунд и пытаемся снова подключится
lastReconnectAttempt = now;
// Пересоедениется
if (reconnect()) { lastReconnectAttempt = 0; }
}
}
else {
// Соедиение установелно, проверка
MQTTclient.loop();
}
}
//Плата:2
//Наименование:Подписка
EN_186572787_5 = 1;
New_186572787_5=0;
if(EN_186572787_5)
{
if (MQTT_PublishPost){
MQTTclient.subscribe("/test/Ljustra"); //Подписатся на топик
Serial.println("podpiska");//Тест
}
if(MQTT_receivedMessage){
if(MQTT_topictext == "/test/Ljustra" ){ //если пришло сообщение от топика
Message_186572787_5= MQTT_inputtext;
New_186572787_5 =1; // сигнал о обновлении данных
}
}
}
if (New_186572787_5) {
_gtv1 = ((Message_186572787_5).equals(String("1")));
}
if (!(_bounseInputD9O)) { if (_trgrt8I) { _trgrt8 = 0;} else {_trgrt8 = 1; _trgrt8I = 1;} } else {_trgrt8 = 0; _trgrt8I = 0;};
if(!(_gtv1))
{_swi1=String("1");}
else
{_swi1=String("0");}
Send_57915906_5 = _trgrt8;
Message_57915906_5 = _swi1;
if ( MQTT_PublishPost || (Send_57915906_5 && !lastSend_57915906_5) )
{
// Serial.println("public");//Тест
MQTTtext = Message_57915906_5.c_str();
MQTTclient.publish( "/ATMega1/Ljustra" , MQTTtext);
}
lastSend_57915906_5 = Send_57915906_5;
if (_trgrt8) {
_gtv1 = !(_gtv1);
}
digitalWrite(3, !(_gtv1));
EN_186572787_1 = 1;
New_186572787_1=0;
if(EN_186572787_1)
{
if (MQTT_PublishPost){
MQTTclient.subscribe("/ATMega1/Lenta spal'nja"); //Подписатся на топик
Serial.println("podpiska");//Тест
}
if(MQTT_receivedMessage){
if(MQTT_topictext == "/ATMega1/Lenta spal'nja" ){ //если пришло сообщение от топика
Message_186572787_1= MQTT_inputtext;
New_186572787_1 =1; // сигнал о обновлении данных
}
}
}
if (New_186572787_1) {
_gtv2 = ((Message_186572787_1).equals(String("1")));
}
if (!(_bounseInputD8O)) { if (_trgrt6I) { _trgrt6 = 0;} else {_trgrt6 = 1; _trgrt6I = 1;} } else {_trgrt6 = 0; _trgrt6I = 0;};
if (_trgrt6) {
_gtv2 = !(_gtv2);
}
if(!(_gtv2))
{_swi5=String("1");}
else
{_swi5=String("0");}
Send_57915906_8 = _trgrt6;
Message_57915906_8 = _swi5;
if ( MQTT_PublishPost || (Send_57915906_8 && !lastSend_57915906_8) )
{
// Serial.println("public");//Тест
MQTTtext = Message_57915906_8.c_str();
MQTTclient.publish( "/ATMega1/Lenta spal'nja" , MQTTtext);
}
lastSend_57915906_8 = Send_57915906_8;
digitalWrite(4, !(_gtv2));
EN_186572787_2 = 1;
New_186572787_2=0;
if(EN_186572787_2)
{
if (MQTT_PublishPost){
MQTTclient.subscribe("/ATMega1/Tochki spal'nja"); //Подписатся на топик
Serial.println("podpiska");//Тест
}
if(MQTT_receivedMessage){
if(MQTT_topictext == "/ATMega1/Tochki spal'nja" ){ //если пришло сообщение от топика
Message_186572787_2= MQTT_inputtext;
New_186572787_2 =1; // сигнал о обновлении данных
}
}
}
if (New_186572787_2) {
_gtv3 = ((Message_186572787_2).equals(String("1")));
}
if (!(_bounseInputD7O)) { if (_trgrt2I) { _trgrt2 = 0;} else {_trgrt2 = 1; _trgrt2I = 1;} } else {_trgrt2 = 0; _trgrt2I = 0;};
if(!(_gtv3))
{_swi2=String("1");}
else
{_swi2=String("0");}
Send_57915906_1 = _trgrt2;
Message_57915906_1 = _swi2;
if ( MQTT_PublishPost || (Send_57915906_1 && !lastSend_57915906_1) )
{
// Serial.println("public");//Тест
MQTTtext = Message_57915906_1.c_str();
MQTTclient.publish( "/ATMega1/Tochki spal'nja" , MQTTtext);
}
lastSend_57915906_1 = Send_57915906_1;
if (_trgrt2) {
_gtv3 = !(_gtv3);
}
digitalWrite(5, !(_gtv3));
//Плата:3
//Наименование:ВЫКЛЮЧИТЬ ВСЁ
EN_186572787_3 = 1;
New_186572787_3=0;
if(EN_186572787_3)
{
if (MQTT_PublishPost){
MQTTclient.subscribe("/ATMega1/VYKLJuChIT'' VSJo"); //Подписатся на топик
Serial.println("podpiska");//Тест
}
if(MQTT_receivedMessage){
if(MQTT_topictext == "/ATMega1/VYKLJuChIT'' VSJo" ){ //если пришло сообщение от топика
Message_186572787_3= MQTT_inputtext;
New_186572787_3 =1; // сигнал о обновлении данных
}
}
}
if (( (New_186572787_3) || (!(_bounseInputD6O)) )) { if (_trgrt3I) { _trgrt3 = 0;} else {_trgrt3 = 1; _trgrt3I = 1;} } else {_trgrt3 = 0; _trgrt3I = 0;};
_gtv4 = _trgrt3;
if (_gtv4) {
_gtv1 = 0;
}
Send_57915906_6 = _gtv4;
Message_57915906_6 = String("0");
if ( MQTT_PublishPost || (Send_57915906_6 && !lastSend_57915906_6) )
{
// Serial.println("public");//Тест
MQTTtext = Message_57915906_6.c_str();
MQTTclient.publish( "/ATMega1/Ljustra" , MQTTtext);
}
lastSend_57915906_6 = Send_57915906_6;
if (_gtv4) {
_gtv2 = 0;
}
Send_57915906_7 = _gtv4;
Message_57915906_7 = String("0");
if ( MQTT_PublishPost || (Send_57915906_7 && !lastSend_57915906_7) )
{
// Serial.println("public");//Тест
MQTTtext = Message_57915906_7.c_str();
MQTTclient.publish( "/ATMega1/Lenta spal'nja" , MQTTtext);
}
lastSend_57915906_7 = Send_57915906_7;
if (_gtv4) {
_gtv3 = 0;
}
Send_57915906_2 = _gtv4;
Message_57915906_2 = String("0");
if ( MQTT_PublishPost || (Send_57915906_2 && !lastSend_57915906_2) )
{
// Serial.println("public");//Тест
MQTTtext = Message_57915906_2.c_str();
MQTTclient.publish( "/ATMega1/Tochki spal'nja" , MQTTtext);
}
lastSend_57915906_2 = Send_57915906_2;
}
void callback(char* topic, byte* payload, unsigned int length)
{
MQTT_topictext = String(topic); // присваиваем переменной название топика к которому подписались
MQTT_inputtext="";
// Serial.println("obrabot");//Тест
for (int i=0;i<length;i++) {
MQTT_inputtext += (char)payload[i]; // составляем строку из байтов, которая пришла в параметрах топика
}
// Serial.println(MQTT_inputtext ); //Тест
MQTT_receivedMessage=1;
}
boolean reconnect()
{
// Serial.println("recon"); //Тест
bool connectedPerformed;
if ( 1)connectedPerformed=MQTTclient.connect( "arduinoClient" , "bober777", "mustang777");
else connectedPerformed=MQTTclient.connect( "arduinoClient" );
if (connectedPerformed) {
MQTT_PublishPost=1;
//Serial.println("post"); //Тест
}
return MQTTclient.connected();
}
с библиотекой w5500?WZV писал(а): ↑09.01.2018{, 21:07}Возможно проблема с библиотеками.
