Navigation

    Logo
    • Register
    • Login
    • Search
    • Recent
    • Tags
    • Unread
    • Categories
    • Unreplied
    • Popular
    • GitHub
    • Docu
    • Hilfe
    1. Home
    2. Русский
    3. ioBroker
    4. ioBroker драйвера
    5. Драйвер Mqtt + Arduino

    NEWS

    • Monatsrückblick - April 2025

    • Minor js-controller 7.0.7 Update in latest repo

    • Save The Date: ioBroker@Smart Living Forum Solingen, 14.06.

    Драйвер Mqtt + Arduino

    This topic has been deleted. Only users with topic management privileges can see it.
    • H
      Haus last edited by

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

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

      ! 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"

      1 Reply Last reply Reply Quote 0
      • I
        instalator last edited by

        @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);
        });
        
        1 Reply Last reply Reply Quote 0
        • H
          Haus last edited by

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

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

          1 Reply Last reply Reply Quote 0
          • I
            instalator last edited by

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

            как то так

            1 Reply Last reply Reply Quote 0
            • H
              Haus last edited by

              Ляпота 😄

              ! 443_2015-12-30-2463.jpg
              Огромное спасибо instalator

              1 Reply Last reply Reply Quote 0
              • H
                Haus last edited by

                Выложу свой код для 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));
                });
                
                1 Reply Last reply Reply Quote 0
                • E
                  electric69 last edited by

                  @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!");
                        }
                      }
                    }
                  
                  

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

                  1 Reply Last reply Reply Quote 0
                  • H
                    Haus last edited by

                    Это в 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>
                    
                    1 Reply Last reply Reply Quote 0
                    • H
                      Haus last edited by

                      Увы результата недал, гдето через 5 часов пропала связь 😞

                      1 Reply Last reply Reply Quote 0
                      • I
                        instalator last edited by

                        @Haus:

                        Увы результата недал, гдето через 5 часов пропала связь 😞 `
                        Когда связь пропадает ардуина пингуется вообще? Езернет шилд какой пользуешь?

                        1 Reply Last reply Reply Quote 0
                        • H
                          Haus last edited by

                          @instalator:

                          @Haus:

                          Увы результата недал, гдето через 5 часов пропала связь 😞 Когда связь пропадает ардуина пингуется вообще? Езернет шилд какой пользуешь?
                          Не пингуется, ENC28J60

                          mqtt-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 не так прописал?

                          1 Reply Last reply Reply Quote 0
                          • E
                            electric69 last edited by

                            @Haus:

                            Не пингуется, ENC28J60 `
                            Если не пингуется, то код вообще не причем…

                            Попробуйте без MQTT, просто по HTTP погонять - будет ли работать.

                            Или просто залить скетч тестовый из библиотеки изернета, пустить пинг тестовый и проверить через часов 5-10 будет ли пинговаться, может "дело не в бобине" ))

                            1 Reply Last reply Reply Quote 0
                            • B
                              bondrogeen last edited by

                              Подскажите пожалуйста в чем может быть проблема.

                              iobroker подключен в качестве клиента к CloudMQTT

                              CloudMQTT поступают данные с планшета, на странице CloudMQTT отображаются корректно.

                              admin/DEXP Ursus 8E2 mini 3G/sensors/battery 100

                              admin/DEXP Ursus 8E2 mini 3G/sensors/bright 166

                              admin/DEXP Ursus 8E2 mini 3G/sensors/temp %TEMP

                              admin/DEXP Ursus 8E2 mini 3G/sensors/time 22.46

                              admin/DEXP Ursus 8E2 mini 3G/sensors/date 22.01.2016

                              admin/DEXP Ursus 8E2 mini 3G/sensors/wifi >>> SCAN <<<

                              admin/DEXP Ursus 8E2 mini 3G/sensors/device DEXP Ursus 8E2 mini 3G

                              admin/DEXP Ursus 8E2 mini 3G/sensors/uptime 353479

                              admin/DEXP Ursus 8E2 mini 3G/sensors/ram 58MB

                              admin/DEXP Ursus 8E2 mini 3G/sensors/statusblue off

                              admin/DEXP Ursus 8E2 mini 3G/sensors/statusscreen on

                              а вот в iobrokere нет значений

                              380_12124.jpg

                              но если публикуешь в корне то отображается правильно

                              test 6576

                              1 Reply Last reply Reply Quote 0
                              • H
                                Haus last edited by

                                @bondrogeen:

                                Подскажите пожалуйста в чем может быть проблема.

                                iobroker подключен в качестве клиента к CloudMQTT

                                CloudMQTT поступают данные с планшета, на странице CloudMQTT отображаются корректно.

                                admin/DEXP Ursus 8E2 mini 3G/sensors/battery 100

                                admin/DEXP Ursus 8E2 mini 3G/sensors/bright 166

                                admin/DEXP Ursus 8E2 mini 3G/sensors/temp %TEMP

                                admin/DEXP Ursus 8E2 mini 3G/sensors/time 22.46

                                admin/DEXP Ursus 8E2 mini 3G/sensors/date 22.01.2016

                                admin/DEXP Ursus 8E2 mini 3G/sensors/wifi >>> SCAN <<<

                                admin/DEXP Ursus 8E2 mini 3G/sensors/device DEXP Ursus 8E2 mini 3G

                                admin/DEXP Ursus 8E2 mini 3G/sensors/uptime 353479

                                admin/DEXP Ursus 8E2 mini 3G/sensors/ram 58MB

                                admin/DEXP Ursus 8E2 mini 3G/sensors/statusblue off

                                admin/DEXP Ursus 8E2 mini 3G/sensors/statusscreen on

                                а вот в iobrokere нет значений

                                но если публикуешь в корне то отображается правильно

                                test 6576 `
                                Наверно дело в структуре, вот так выглядит у меня
                                443_screencapture-192-168-1-11-8081-1453552081222.png

                                1 Reply Last reply Reply Quote 0
                                • B
                                  bondrogeen last edited by

                                  В режиме брокера именно такая структура и у меня, а вот как клиент получается так.

                                  Как брокер локально по сети нормально все передается.

                                  Решил попробовать через cloudmqtt.com и подключится как клиент и тут такие проблемы.

                                  380_3333.jpg
                                  может что тут нужно поставить?

                                  1 Reply Last reply Reply Quote 0
                                  • H
                                    Haus last edited by

                                    @bondrogeen:

                                    В режиме брокера именно такая структура и у меня, а вот как клиент получается так.

                                    Как брокер локально по сети нормально все передается.

                                    Решил попробовать через cloudmqtt.com и подключится как клиент и тут такие проблемы.

                                    filename="3333.jpg" index="0">~~
                                    может что тут нужно поставить? `
                                    Там внизу есть кнопка "проверить настройки" может она чем поможет, посмотри у немцев там много инфы только google так коряво переводит 🙂

                                    1 Reply Last reply Reply Quote 0
                                    • B
                                      bondrogeen last edited by

                                      нажимал я на нее только не чего не происходит

                                      1 Reply Last reply Reply Quote 0
                                      • H
                                        Haus last edited by

                                        @bondrogeen:

                                        нажимал я на нее только не чего не происходит `
                                        Есть помощь по драйверу. Правда на аглицком. https://github.com/ioBroker/ioBroker.mqtt#configuration

                                        1 Reply Last reply Reply Quote 0
                                        • B
                                          bondrogeen last edited by

                                          читал, но не чего нового для себя не узнал

                                          1 Reply Last reply Reply Quote 0
                                          • I
                                            instalator last edited by

                                            @bondrogeen:

                                            В режиме брокера именно такая структура и у меня, а вот как клиент получается так.

                                            Как брокер локально по сети нормально все передается.

                                            Решил попробовать через cloudmqtt.com и подключится как клиент и тут такие проблемы.

                                            filename="3333.jpg" index="0">~~
                                            может что тут нужно поставить? `
                                            Может из за пробелов в именах переменных?

                                            1 Reply Last reply Reply Quote 0
                                            • First post
                                              Last post

                                            Support us

                                            ioBroker
                                            Community Adapters
                                            Donate

                                            944
                                            Online

                                            31.6k
                                            Users

                                            79.4k
                                            Topics

                                            1.3m
                                            Posts

                                            18
                                            244
                                            63317
                                            Loading More Posts
                                            • Oldest to Newest
                                            • Newest to Oldest
                                            • Most Votes
                                            Reply
                                            • Reply as topic
                                            Log in to reply
                                            Community
                                            Impressum | Datenschutz-Bestimmungen | Nutzungsbedingungen
                                            The ioBroker Community 2014-2023
                                            logo