NEWS
Драйвер Mqtt + Arduino
-
Два файла есть, когда две строчки как писал переставляю в другое место то проект компилируется и работает. Правильно ли это?
Выложить свои библиотеки#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>
-
Два файла есть, когда две строчки как писал переставляю в другое место то проект компилируется и работает. Правильно ли это?
Выложить свои библиотеки#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 ардуина реагирует?
-
А ты выкинул колбэк из кода у тебя при изменении переменной в iob ардуина реагирует? `
Я несколько сообщений назад уже спрашивал, ответа не получил))
@electric69:"Я просто оставлю свой код, который реально работает у меня в данный момент."
Спасибо за примеры опробовал работает.
Вопрос, в твоём коде заменил библиотеку для 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 передаются в ардуину? `
-
Чего то мы не разберёмся. Вот это твой проект который у меня не компилируется. Я в нём сделал изменение в строке 15, 16 (закомментировал) и добавил строку 72, 73(перенёс сюда строку 15, 16) при таком положение всё компилируется. Если тебя не затруднит проверить этот код и ответить на один вопрос, имеет ли какое то значение где расположены по коду эти две строчки? Я в коде дуб :oops:
-
А ты выкинул колбэк из кода у тебя при изменении переменной в iob ардуина реагирует? `
Я несколько сообщений назад уже спрашивал, ответа не получил))
@electric69:"Я просто оставлю свой код, который реально работает у меня в данный момент."
Спасибо за примеры опробовал работает.
Вопрос, в твоём коде заменил библиотеку для 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>
-
Чего то мы не разберёмся. Вот это твой проект который у меня не компилируется. Я в нём сделал изменение в строке 15, 16 (закомментировал) и добавил строку 72, 73(перенёс сюда строку 15, 16) при таком положение всё компилируется. Если тебя не затруднит проверить этот код и ответить на один вопрос, имеет ли какое то значение где расположены по коду эти две строчки? Я в коде дуб :oops:
filename="Kitchen_Mqtt_HAUS.zip" index="0">~~ `
У меня компилится и так и так, вообще не пойму что за ошибка у тебя может быть.А вообще должно все работать так как ты перенес, может в что в новой версии ардуиновкой среды намутили, ща обновлю проверю
-
Ну да точно, намудрили в 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);Хотя можешь оставить как ты сделал, все должно работать норм. -
Я уже даже сделал то что описывал в своих желаниях с LCD но с одним датчиком температуры(считывает с датчика, отображает на дисплей и отсылает iobrokery), больше не лезет в ардуину ( библиотека для ENC28J60 жирная). Может есть какой пример что бы ардуина только принимала значение температуры с с сервера (1wire драйвер) и транслировала их на дисплей? Андрей обещался что MegaD+i2c+LCD поженит мне даже удобней было бы, но с переходом на 2561 чувствую зима закончится :) .
-
С наступающим
Может кто подсказать, ардуина публикует топики
! 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" -
С наступающим
Может кто подсказать, ардуина публикует топики
! 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); }); -
С наступающим
Может кто подсказать, ардуина публикует топики
! 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); } }); ```` `Ругается на последнюю строчку если убрать } работает. Как бы ещё что бы одна цифра после запятой была. За ранние спасибо :)
-
Ругается на последнюю строчку если убрать } работает. Как бы ещё что бы одна цифра после запятой была. За ранние спасибо :) `
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)); });как то так
-
Выложу свой код для 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)); }); -
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!"); } } }Вот так как то…
-
Это в void loop записать? Сейчас ваш пример скачаю. Где то читал что это ещё проблемы ENC28J60, вообще кода почти нет а при компиляции 85% забито. Можно как то библиотеку облегчить но для меня это темный лес

Чего то сделал
#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/" unsigned long lastTime = 0; unsigned long timeout = 10; // по-умолчанию таймаут перед восстановлением соединения 10 сек 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/#"); } } //Если соединение не активно в течении таймаута, восстанавливаем if(millis() > (lastTime + timeout*1000)) { lastTime = millis(); if (!client.connected()) { //Разрываем коннект client.disconnect(); //пытаемся восстановить if (client.connect(id_connect)) { //Публикуем, подписываемся заново client.subscribe("myhome/Boiler_room/#"); } } } }</liquidcrystal_i2c.h></wire.h></pubsubclient.h></uipethernet.h></spi.h> -
Увы результата недал, гдето через 5 часов пропала связь :( `
Когда связь пропадает ардуина пингуется вообще? Езернет шилд какой пользуешь? -
Увы результата недал, гдето через 5 часов пропала связь :(
Когда связь пропадает ардуина пингуется вообще? Езернет шилд какой пользуешь?
Не пингуется, ENC28J60mqtt-0 2016-01-12 19:45:55 info Client [LCD-accumulator_tanks_1] closed mqtt-0 2016-01-12 19:45:55 warn [LCD-accumulator_tanks_1] Error: read ETIMEDOUT sayit-0 2016-01-12 19:30:11 info saying: Дисплей. Пропала связь! sayit-0 2016-01-12 19:30:07 info saying: /opt/iobroker/node_modules/iobroker.sayit/gong.mp3 javascript-0 2016-01-12 19:30:07 info script.js.Ping_0_say: Дисплей. Пропала связь!Если рестартануть драйвер результата 0, если ресетнуть ардуину всё работает
Может я код который предложил electric69 не так прописал?
-
Не пингуется, ENC28J60 `
Если не пингуется, то код вообще не причем…Попробуйте без MQTT, просто по HTTP погонять - будет ли работать.
Или просто залить скетч тестовый из библиотеки изернета, пустить пинг тестовый и проверить через часов 5-10 будет ли пинговаться, может "дело не в бобине" ))
Hey! Du scheinst an dieser Unterhaltung interessiert zu sein, hast aber noch kein Konto.
Hast du es satt, bei jedem Besuch durch die gleichen Beiträge zu scrollen? Wenn du dich für ein Konto anmeldest, kommst du immer genau dorthin zurück, wo du zuvor warst, und kannst dich über neue Antworten benachrichtigen lassen (entweder per E-Mail oder Push-Benachrichtigung). Du kannst auch Lesezeichen speichern und Beiträge positiv bewerten, um anderen Community-Mitgliedern deine Wertschätzung zu zeigen.
Mit deinem Input könnte dieser Beitrag noch besser werden 💗
Registrieren Anmelden
