Драйвер Mqtt + Arduino

instalator

Я же написал "в твоём коде заменил библиотеку для ENC28J60 (#include <uipethernet.h>) и адрес DS18BB20", а он всё callbac ну я и стёр эту функцию в PubSubClient client(server, 1883, callback, ethClient) получилось вот так PubSubClient client(server, 1883, ethClient) .Понимаю что это неправильно, про бывал другие примеры ситуация похожая. Так как спросить больше не у кого, прошу помощи у вас. В чём может быть проблема? Вот этот код компилируется нормально.

! #include <spi.h>#include <uipethernet.h>// UIP Ethernet Library to support ENC28J60 ethernet module.
! #include <pubsubclient.h>// MQTT publisher/subscriber client library
! #include <wire.h>#include <liquidcrystal_i2c.h>// i2C bus converter compatible library for LCD
! LiquidCrystal_I2C lcd(0x27,16,2);
! byte mac[] = { 0xDE, 0xED, 0xBA, 0xFE, 0xFE, 0xED }; // Set the mac address for the arduino nano mcu
! byte server[] = { 192, 168, 1, 16 }; // Set MQTT broker server IP address
! //char server[] = "xxx.xxxxxxx.xxx"; // Set MQTT broker server domain address
! byte ip[] = { 192, 168, 1, 11 }; // Set the IP address for the arduino nano mcu
! int LED = 6; // Initialize digital pin 6 to LED variable
! String msgString; // Initialize msgString variable
! void callback(char* topic, byte* payload, unsigned int length) {
! // Handle message arrived upon a publish from a MQTT client
! char message_buff[100];
! int i;
! for(i=0; i <length; i++)/{<br="">message_buff = payload;
! }
! message_buff = '\0';
! msgString = String(message_buff);
! Serial.println("message arrived: " + msgString); // Serial output of received callback payload
! if(msgString == "0")
! {
! digitalWrite(LED, LOW); // If message payload received is 0, LED is turned off
! lcd.clear(); // Clear previously printed values in the LCD
! lcd.print("D6 : OFF"); // Print The Message on LCD
! lcd.setCursor(0,1); // Set top cursor position on 16x2 LCD module
! }
! else if (msgString == "1")
! {
! digitalWrite(LED, HIGH); // If message payload received is 1, LED is turned on
! lcd.clear(); // Clear previously printed values in the LCD
! lcd.print("D6 : ON"); // Print The Message on LCD
! lcd.setCursor(0,1); // Set top cursor position on 16x2 LCD module
! } else {
! lcd.clear(); // Clear previously printed values in the LCD
! lcd.print("Device Status"); // Print Device Status message on LCD
! lcd.setCursor(0,1); // Set top cursor position on 16x2 LCD module
! lcd.print(msgString); // Print The message payload on LCD
! lcd.setCursor(1,1); // Set top cursor position on 16x2 LCD module
! }
! }
! EthernetClient ethClient;
! PubSubClient client(server, 1883, callback, ethClient); // Initialize a MQTT client instance
! void setup()
! {
! Serial.begin(9600); // Set the Serial Buad rate to 9600
! pinMode(LED, OUTPUT); // Set LED connected pin to OUTPUT mode
! lcd.init(); // Initialize the 16X2 LCD
! lcd.backlight();
! Ethernet.begin(mac, ip);
! if (client.connect("arduinoClient")) { // Check the MQTT broker connectivity
! client.publish("topic","connected"); // Publish ethernet connected status to MQTT topic
! client.subscribe("topic"); // Subscribe to a MQTT topic
! }
! }
! void loop()
! {
! client.loop();
! }____</length;></liquidcrystal_i2c.h></wire.h></pubsubclient.h></uipethernet.h></spi.h> ______Что за ошибку дает при компиляции? у меня нету твоих библиотек, проверить не могу.

Какую кстати версию библиотеки PubSubClient.h юзаете?

Добавил которая стоит у меня, вроде 1.9 версия.

Обновил у себя до версии 2.4 все нормально компилится. Мой код который я выкладывал компилится у вас? или ошибки только когда добавляете свеоего кода?___
266_pubsubclient.zip___</uipethernet.h> `

Haus · javascript: 4.1.10

Твой код без изменений, PubSubClient.h 2.4, ошибка Kitchen_Mqtt:16: error: 'callback' was not declared in this scope.

Если в коде две строчки переставить в другое место всё компилится

! ////////////////////////////////////////////////////////////////////////////
! void callback(char* topic, byte* payload, unsigned int length) {
! payload[length] = '\0';
! // Serial.print(topic);
! // Serial.print("=");
! String strTopic = String(topic);
! String strPayload = String((char*)payload);
! // Serial.println(strPayload);
! callback_iobroker(strTopic, strPayload);
! }
! EthernetClient ethClient;
! PubSubClient client(server, 1883, callback, ethClient);
! ////////////////////////////////////////////////////////////////////////////
! void setup() {
! //Serial.begin(57600);
! // Serial.println("start");

instalator

Там проект состоит из двух файлов они должны быть в одном каталоге, если в среде ардуино не появляется вторая вкладка то добавь в проект файл с функциями.

Haus · javascript: 4.1.10

Два файла есть, когда две строчки как писал переставляю в другое место то проект компилируется и работает. Правильно ли это?

instalator

~~@Haus:~~

Два файла есть, когда две строчки как писал переставляю в другое место то проект компилируется и работает. Правильно ли это? `
Выложить свои библиотеки

Haus · javascript: 4.1.10

~~@instalator:~~

~~@Haus:~~

Два файла есть, когда две строчки как писал переставляю в другое место то проект компилируется и работает. Правильно ли это? Выложить свои библиотеки

#include <spi.h>1.0.0

#include <ethernet.h>1.1.1

#include <pubsubclient.h>2.4.0

#include <servo.h>1.1.1

#include <dht.h>DHTlib

#include <onewire.h>2.3.1

#include <dallastemperature.h>3.7.5

Arduino 1.6.6

Проблема в чём то другом…..</dallastemperature.h></onewire.h></dht.h></servo.h></pubsubclient.h></ethernet.h></spi.h>

instalator

~~@Haus:~~

~~@instalator:~~

~~@Haus:~~

Два файла есть, когда две строчки как писал переставляю в другое место то проект компилируется и работает. Правильно ли это? Выложить свои библиотеки

#include <spi.h>1.0.0

#include <ethernet.h>1.1.1

#include <pubsubclient.h>2.4.0

#include <servo.h>1.1.1

#include <dht.h>DHTlib

#include <onewire.h>2.3.1

#include <dallastemperature.h>3.7.5

Arduino 1.6.6

Проблема в чём то другом…..</dallastemperature.h></onewire.h></dht.h></servo.h></pubsubclient.h></ethernet.h></spi.h> `
Я имел ввиду именно твои библиотеки от твоего проекта.

у меня Arduino 1.6.4

А ты выкинул колбэк из кода у тебя при изменении переменной в iob ардуина реагирует?

electric69

~~@instalator:~~

А ты выкинул колбэк из кода у тебя при изменении переменной в iob ардуина реагирует? `
Я несколько сообщений назад уже спрашивал, ответа не получил))
~~@electric69:~~

~~@Haus:~~

"Я просто оставлю свой код, который реально работает у меня в данный момент."

Спасибо за примеры опробовал работает.

Вопрос, в твоём коде заменил библиотеку для ENC28J60 и адрес DS18BB20.

Не мог скомпелировать всё ругался на callbac и указывал на строчку, так как в коде не понимаю стёр callbac и всё сработало.

Температуры показывает , переменные создались. Не связано ли это с ENC28J60 ?

! EthernetClient ethClient;
! //PubSubClient client(server, 1883, callback, ethClient);
! PubSubClient client(server, 1883, ethClient);
! #define id_connect "myhome-kitchen"
! #define Prefix_subscribe "myhome/Kitchen/" `
Ардуина отправляет (публикует) данные в ioBroker.

А как обстоят дела с подпиской? Данные от ioBroker передаются в ардуину? `

Haus · javascript: 4.1.10

Чего то мы не разберёмся. Вот это твой проект который у меня не компилируется. Я в нём сделал изменение в строке 15, 16 (закомментировал) и добавил строку 72, 73(перенёс сюда строку 15, 16) при таком положение всё компилируется. Если тебя не затруднит проверить этот код и ответить на один вопрос, имеет ли какое то значение где расположены по коду эти две строчки? Я в коде дуб :oops:

443_kitchen_mqtt_haus.zip

Haus · javascript: 4.1.10

~~@electric69:~~

~~@instalator:~~

А ты выкинул колбэк из кода у тебя при изменении переменной в iob ардуина реагирует? `
Я несколько сообщений назад уже спрашивал, ответа не получил))
~~@electric69:~~

~~@Haus:~~

"Я просто оставлю свой код, который реально работает у меня в данный момент."

Спасибо за примеры опробовал работает.

Вопрос, в твоём коде заменил библиотеку для ENC28J60 и адрес DS18BB20.

Не мог скомпелировать всё ругался на callbac и указывал на строчку, так как в коде не понимаю стёр callbac и всё сработало.

Температуры показывает , переменные создались. Не связано ли это с ENC28J60 ?

! EthernetClient ethClient;
! //PubSubClient client(server, 1883, callback, ethClient);
! PubSubClient client(server, 1883, ethClient);
! #define id_connect "myhome-kitchen"
! #define Prefix_subscribe "myhome/Kitchen/" `
Ардуина отправляет (публикует) данные в ioBroker.

А как обстоят дела с подпиской? Данные от ioBroker передаются в ардуину?

Извини что пропустил вопрос, просто тема про выкинутое слово callbak из строчки сам понял что дурак. :roll:

Сейчас большая проблема с ENC28J60 точней с библиотекой <uipethernet.h>в arduino nano сжирает всю память.</uipethernet.h>

instalator

~~@Haus:~~

Чего то мы не разберёмся. Вот это твой проект который у меня не компилируется. Я в нём сделал изменение в строке 15, 16 (закомментировал) и добавил строку 72, 73(перенёс сюда строку 15, 16) при таком положение всё компилируется. Если тебя не затруднит проверить этот код и ответить на один вопрос, имеет ли какое то значение где расположены по коду эти две строчки? Я в коде дуб :oops:

filename="Kitchen_Mqtt_HAUS.zip" index="0">~~ `
У меня компилится и так и так, вообще не пойму что за ошибка у тебя может быть.

А вообще должно все работать так как ты перенес, может в что в новой версии ардуиновкой среды намутили, ща обновлю проверю

instalator

Ну да точно, намудрили в 1.6.4 версии. Если вызываеш функцию то она должна быть объявлена до вызова.

Перенеси участок кода````
void callback(char* topic, byte* payload, unsigned int length) {
payload[length] = '\0';
// Serial.print(topic);
// Serial.print("=");
String strTopic = String(topic);
String strPayload = String((char*)payload);
// Serial.println(strPayload);
callback_iobroker(strTopic, strPayload);
}

выше, поставь перед строками:

EthernetClient ethClient;
PubSubClient client(server, 1883, callback, ethClient);

Хотя можешь оставить как ты сделал, все должно работать норм.

Haus · javascript: 4.1.10

Я уже даже сделал то что описывал в своих желаниях с LCD но с одним датчиком температуры(считывает с датчика, отображает на дисплей и отсылает iobrokery), больше не лезет в ардуину ( библиотека для ENC28J60 жирная). Может есть какой пример что бы ардуина только принимала значение температуры с с сервера (1wire драйвер) и транслировала их на дисплей? Андрей обещался что MegaD+i2c+LCD поженит мне даже удобней было бы, но с переходом на 2561 чувствую зима закончится :) .

Haus · javascript: 4.1.10

С наступающим

Может кто подсказать, ардуина публикует топики

! if (client.connect(id_connect)) {
! client.publish("myhome/Boiler_room/Temp_akum_heat_1_1", "0");
! client.publish("myhome/Boiler_room/Temp_akum_heat_1_2", "0");
! client.publish("myhome/Boiler_room/Temp_akum_heat_1_3", "0");
! client.publish("myhome/Boiler_room/Temp_akum_heat_1_4", "0");
! client.subscribe("myhome/Boiler_room/#");
и сама их читая отображает на LCD

! if (strcmp(topic, "myhome/Boiler_room/Temp_akum_heat_1_1")==0){
! lcd.setCursor(3,0);
! lcd.print(strPayload);
! lcd.print((char)223);
! }
! if (strcmp(topic, "myhome/Boiler_room/Temp_akum_heat_1_2")==0){
! lcd.setCursor(3,1);
! lcd.print(strPayload);
! lcd.print((char)223);
Как сделать чтобы в iobroker в топике "myhome/Boiler_room/Temp_akum_heat_1_1" появилось значение из драйвера owfs "owfs.0.wires.akum_heat_1_1"

instalator

~~@Haus:~~

С наступающим

Может кто подсказать, ардуина публикует топики

! if (client.connect(id_connect)) {
! client.publish("myhome/Boiler_room/Temp_akum_heat_1_1", "0");
! client.publish("myhome/Boiler_room/Temp_akum_heat_1_2", "0");
! client.publish("myhome/Boiler_room/Temp_akum_heat_1_3", "0");
! client.publish("myhome/Boiler_room/Temp_akum_heat_1_4", "0");
! client.subscribe("myhome/Boiler_room/#");
и сама их читая отображает на LCD

! if (strcmp(topic, "myhome/Boiler_room/Temp_akum_heat_1_1")==0){
! lcd.setCursor(3,0);
! lcd.print(strPayload);
! lcd.print((char)223);
! }
! if (strcmp(topic, "myhome/Boiler_room/Temp_akum_heat_1_2")==0){
! lcd.setCursor(3,1);
! lcd.print(strPayload);
! lcd.print((char)223);
Как сделать чтобы в iobroker в топике "myhome/Boiler_room/Temp_akum_heat_1_1" появилось значение из драйвера owfs "owfs.0.wires.akum_heat_1_1" `
Добавь скрипт:

on({id: 'owfs.0.wires.akum_heat_1_1', change: 'any'}, function (obj) {
         setState('mqtt.0.myhome.Boiler_room.Temp_akum_heat_1_1', obj.newState.val);
});

Haus · javascript: 4.1.10

~~@instalator:~~

~~@Haus:~~

С наступающим

Может кто подсказать, ардуина публикует топики

! if (client.connect(id_connect)) {
! client.publish("myhome/Boiler_room/Temp_akum_heat_1_1", "0");
! client.publish("myhome/Boiler_room/Temp_akum_heat_1_2", "0");
! client.publish("myhome/Boiler_room/Temp_akum_heat_1_3", "0");
! client.publish("myhome/Boiler_room/Temp_akum_heat_1_4", "0");
! client.subscribe("myhome/Boiler_room/#");
и сама их читая отображает на LCD

! if (strcmp(topic, "myhome/Boiler_room/Temp_akum_heat_1_1")==0){
! lcd.setCursor(3,0);
! lcd.print(strPayload);
! lcd.print((char)223);
! }
! if (strcmp(topic, "myhome/Boiler_room/Temp_akum_heat_1_2")==0){
! lcd.setCursor(3,1);
! lcd.print(strPayload);
! lcd.print((char)223);
Как сделать чтобы в iobroker в топике "myhome/Boiler_room/Temp_akum_heat_1_1" появилось значение из драйвера owfs "owfs.0.wires.akum_heat_1_1" `
Добавь скрипт:
on({id: 'owfs.0.wires.akum_heat_1_1', change: 'any'}, function (obj) {
         setState('mqtt.0.myhome.Boiler_room.Temp_akum_heat_1_1', obj.newState.val);
    }
});
```` `  

Ругается на последнюю строчку если убрать } работает. Как бы ещё что бы одна цифра после запятой была. За ранние спасибо :)

instalator

~~@Haus:~~

Ругается на последнюю строчку если убрать } работает. Как бы ещё что бы одна цифра после запятой была. За ранние спасибо :) `

on({id: 'owfs.0.wires.akum_heat_1_1', change: 'any'}, function (obj) {
         setState('mqtt.0.myhome.Boiler_room.Temp_akum_heat_1_1', parseFloat(obj.newState.val).toFixed(1));
});

как то так

Haus · javascript: 4.1.10

Ляпота :D

!
Огромное спасибо instalator

Haus · javascript: 4.1.10

Выложу свой код для Mqtt+Arduino+ENC28J60+LCD(i2c). Суть такова Arduino публикует топики и на них подписывается. На сервере работает javascript который записывает с драйвера owfs значение в топики, а Arduino их читает и отображает на LCD.

1. Топики публикую " " без нулей, это нечего?

2. Довольно часто сервер теряет связь с Arduino, как можно сделать чтобы Arduino реконектнулась (если на Arduino нажать ресет всё работает дальше)?

#include <spi.h>#include <uipethernet.h>// UIP Ethernet Library to support ENC28J60 ethernet module. 
#include <pubsubclient.h>// MQTT publisher/subscriber client library
#include <wire.h>#include <liquidcrystal_i2c.h>// i2C bus converter compatible library for LCD

LiquidCrystal_I2C lcd(0x27,16,2);

byte mac[]    = {  0xDE, 0xED, 0xBA, 0xFE, 0xFE, 0xED }; // Set the mac address for the arduino nano mcu 
byte server[] = { 192, 168, 1, 11 };                     // Set MQTT broker server IP address
//char server[] = "xxx.xxxxxxx.xxx";                       // Set MQTT broker server domain address 
byte ip[]     = { 192, 168, 1, 16 };                     // Set the IP address for the arduino nano mcu 

#define id_connect "LCD-accumulator_tanks_1"
#define Prefix_subscribe "myhome/Boiler_room/"

void callback(char* topic, byte* payload, unsigned int length) {
  payload[length] = '\0';
  String strTopic = String(topic);
  String strPayload = String((char*)payload);
    if (strcmp(topic, "myhome/Boiler_room/Temp_accum_tanks_1_1")==0){
    lcd.setCursor(3,0);
    lcd.print(strPayload);
    //lcd.print((char)223);
    }
    if (strcmp(topic, "myhome/Boiler_room/Temp_accum_tanks_1_2")==0){
    lcd.setCursor(3,1);
    lcd.print(strPayload);
    //lcd.print((char)223);
    }
    if (strcmp(topic, "myhome/Boiler_room/Temp_accum_tanks_1_3")==0){
    lcd.setCursor(12,0);
    lcd.print(strPayload);
    //lcd.print((char)223);
    }
    if (strcmp(topic, "myhome/Boiler_room/Temp_accum_tanks_1_4")==0){
    lcd.setCursor(12,1);
    lcd.print(strPayload);
    //lcd.print((char)223);
    } 
}

EthernetClient ethClient;
PubSubClient client(server, 1883, callback, ethClient);

void setup() {
  lcd.init();
  lcd.backlight();
  lcd.clear();
  lcd.setCursor(0,0);
  lcd.print("T1:");
  lcd.setCursor(0,1);
  lcd.print("T2:");
  lcd.setCursor(9,0);
  lcd.print("T3:");
  lcd.setCursor(9,1);
  lcd.print("T4:");

  Ethernet.begin(mac, ip);
  if (client.connect(id_connect)) {                    // Check the MQTT broker connectivity
    client.publish("myhome/Boiler_room/Temp_accum_tanks_1_1", " ");
    client.publish("myhome/Boiler_room/Temp_accum_tanks_1_2", " ");
    client.publish("myhome/Boiler_room/Temp_accum_tanks_1_3", " ");
    client.publish("myhome/Boiler_room/Temp_accum_tanks_1_4", " ");
    client.subscribe("myhome/Boiler_room/#");
  }
}

void loop() {
  client.loop();
    if (!client.connected()) {
      if (client.connect(id_connect)) {
      client.subscribe("myhome/Boiler_room/#");
      }
    }
}</liquidcrystal_i2c.h></wire.h></pubsubclient.h></uipethernet.h></spi.h>

И скрипт

on({id: 'owfs.0.wires.akum_heat_1_1', change: 'any'}, function (obj) {
         setState('mqtt.0.myhome.Boiler_room.Temp_accum_tanks_1_1', parseFloat(obj.newState.val).toFixed(1));
});    
on({id: 'owfs.0.wires.akum_heat_1_2', change: 'any'}, function (obj) {
         setState('mqtt.0.myhome.Boiler_room.Temp_accum_tanks_1_2', parseFloat(obj.newState.val).toFixed(1));
});
on({id: 'owfs.0.wires.akum_heat_1_3', change: 'any'}, function (obj) {
         setState('mqtt.0.myhome.Boiler_room.Temp_accum_tanks_1_3', parseFloat(obj.newState.val).toFixed(1));
});
on({id: 'owfs.0.wires.akum_heat_1_4', change: 'any'}, function (obj) {
         setState('mqtt.0.myhome.Boiler_room.Temp_accum_tanks_1_4', parseFloat(obj.newState.val).toFixed(1));
});

electric69

~~@Haus:~~

2. Довольно часто сервер теряет связь с Arduino, как можно сделать чтобы Arduino реконектнулась (если на Arduino нажать ресет всё работает дальше)? `
С этим тоже намучился, и пока связь потеряна и не восстановлена - данные что передаются в этот промежуток времени безвозвратно потеряны((

По поводу восстановления связи, я в коде задал таймер, который раз в 10 (настраивается) секунд проверяет коннект, если нет - то рвет и переподключается, подписываясь заново…

unsigned long lastTime = 0;
unsigned long timeout = 10; // по-умолчанию таймаут перед восстановлением соединения 10 сек

  //Если соединение не активно в течении таймаута, восстанавливаем
  if(millis() > (lastTime + timeout*1000)) {
    lastTime = millis();
    if (!client.connected()) {
      //Разрываем коннект
      client.disconnect();
      Serial.print("Reconnect to MQTT-boker...  ");
      //пытаемся восстановить
      if (client.connect("PLC35_DoorVaultSecur")) {
        Serial.println("success");
        //Публикуем, подписываемся заново
        client.subscribe("PLC35_DoorVaultSecur/mode");
        client.subscribe("common/PLC38_PLC35_RelayLight2");
        client.subscribe("common/PLC33_PLC35_FlashRFID");
      }  else {
        Serial.println("failed!");
      }
    }
  }

Вот так как то…

Community Forum

NEWS

Драйвер Mqtt + Arduino

Support us

417

32.4k

81.5k

1.3m