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.
    • I
      instalator last edited by

      @evgen69:

      У меня проводка протянута только к датчикам температуры по квартире и на коллекторах,а так же к герконам на окнах (витая пара FTP). К радиаторам к сожалению нет проводки. Да, читал про резисторы на ethernet шилдах. Спасибо за информацию. Тогда сначала освоюсь с установкой ioBroker, а потом уже буду изучать mqtt. `
      У меня к радиаторам есть проводка, пока только датчики температуры стоят ds'ки. Планирую покупать клапана eQ-3, отопление центральное, так что только регулировать на самих радиаторах. Теплых полов нет и не нужны они, единственный будет на балконе, пока не думал как им управлять но скорее всего заводским контроллером к которому пригамырить arduinkу).

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

        @instalator:

        Так вот: Китайцы видимо не понимают разницы в маркировке чип резисторов между 510 и 511 либо не нашлось под рукой 510 и подумали что 511 это одно и тоже ведь 1 на конце добавляет 0 т.е. получается те же 510. Если внимательно посмотреть справочники, то там четко указано, что 510 это 51 Ом, а 511 это уже 510 Ом. `

        Только что получил на почте W5100. Тоже стоит резистор 511 🙂

        1 Reply Last reply Reply Quote 0
        • F
          ford7 last edited by

          Подскажите, что-то я запутался между ардуино и брокером… Если я планирую измерять температуру (5-10 мест), давление, освещенность... мне лучше заводить датчики на ардуино и потом стыковать к брокеру, или (если установить брокер на odroid/кубик) завести все датчики на odroid/кубик и в ардуино вообще отпадает необходимость?

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

            @ford7:

            Подскажите, что-то я запутался между ардуино и брокером… Если я планирую измерять температуру (5-10 мест), давление, освещенность... мне лучше заводить датчики на ардуино и потом стыковать к брокеру, или (если установить брокер на odroid/кубик) завести все датчики на odroid/кубик и в ардуино вообще отпадает необходимость? `
            Оба варианта работоспособны…

            С помощью ардуины можно делать более распределенные системы. Т.е. у меня к примеру одна ардуина отвечает за охрану/пожарку и передает данные на сервер. Вторая ардуина стоит на балконе и отправляет данные о погоде на сервер, включая датчики внутри квартиры. Была еще третья - занималась освещением, но я её "выдернул" под другой проект. И кстати - можно даже несколько плат с ioBroker объединить в пул - для обмена данными и работе на общую визуализацию...

            Можно и на саму плату с помощью тех же GPIO повесить все датчики и исполнительные механизмы. Только если зависнет сервер - то пропадет все... У меня если зависнет сервак - то ардуины продолжат обрабатывать данные (хоть и не будут передавать на сервер) и работать по заложенному алгоритму.

            1 Reply Last reply Reply Quote 0
            • F
              ford7 last edited by

              Спасибо!

              Стало меньше мусора в голове 🙂

              1 Reply Last reply Reply Quote 0
              • R
                revenkopa last edited by

                Можно ли организовать работу с одной переменной (без IN и OUT) ? У меня контролер ловит свои же сообщения и отрабатывает …. это глюк или все как положено ?

                как в iobroker организовать работу когда лампочка в vis отображает значение пришедшее в OUT а упровляющий надо посылать в IN ?
                5076_2018_09_21_19_35_19_window.png

                1 Reply Last reply Reply Quote 0
                • R
                  revenkopa last edited by

                  кстати как убрать приставку из топика "mqtt.0." которую обязательно стал добавлять mqqt driver iobroker

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

                    @revenkopa:

                    кстати как убрать приставку из топика "mqtt.0." которую обязательно стал добавлять mqqt driver iobroker `
                    А зачем? а если у тебя будет два драйвера MQTT? (второй получится mqtt.1.) и в объектах проще искать.

                    1 Reply Last reply Reply Quote 0
                    • R
                      revenkopa last edited by

                      чтобы меньше в ардуино писать 😄

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

                        @revenkopa:

                        чтобы меньше в ардуино писать 😄 `
                        :shock: А что ты туда пишешь?

                        У меня так

                        client.publish("myhome/NRF/Vodonagrevatel/btn_Temp_Selector", "0");
                            client.publish("myhome/NRF/Vodonagrevatel/Status", "0");
                            client.subscribe("myhome/NRF/#");
                        
                        
                        1 Reply Last reply Reply Quote 0
                        • R
                          revenkopa last edited by

                          а сообщения из иоброкера выглядят так

                          mqtt/0/kv7/kitchen/1/rel1

                          и mqtt/0 малину портит

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

                            @revenkopa:

                            а сообщения из иоброкера выглядят так

                            mqtt/0/kv7/kitchen/1/rel1

                            и mqtt/0 малину портит `
                            Что значит из брокера? В скриптах?

                            1 Reply Last reply Reply Quote 0
                            • R
                              revenkopa last edited by

                              по протоколу MQTT топики выглядят так mqtt/0/kv7/kitchen/1/rel1

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

                                @revenkopa:

                                по протоколу MQTT топики выглядят так mqtt/0/kv7/kitchen/1/rel1 `
                                А смысл их смотреть? Подписываешся на них и все какая разница что там в протоколе

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

                                  @instalator:

                                  @revenkopa:

                                  по протоколу MQTT топики выглядят так mqtt/0/kv7/kitchen/1/rel1 А смысл их смотреть? Подписываешся на них и все какая разница что там в протоколе
                                  Может автор имеет ввиду тяжело парсить что прилетело от сервера?

                                  У меня callback примерно такой:

                                  ! //Функция обработки входящих соединений - прием данных по подписке void callback(char* topic, byte* payload, unsigned int length) { Serial.println (""); Serial.println ("-------"); Serial.println ("New callback of MQTT-broker"); //преобразуем тему(topic) и значение (payload) в строку payload[length] = '\0'; String strTopic = String(topic); String strPayload = String((char*)payload); //Исследуем что "прилетело" от сервера по подписке: //Изменение режима работы контроллера if (strTopic == "PLC31_OnLight/mode") { if (strPayload == "standby") PLC_mode=MODE_STANDBY; else if (strPayload == "active") PLC_mode=MODE_ACTIVE; else if (strPayload == "deactivation") PLC_mode=MODE_DEACTIVATION; } //Изменение времени таймаута if (strTopic == "PLC31_OnLight/timeout") { timeout = strPayload.toInt(); } //Управление реле стробоскопа if (strTopic == "common/PLC38_PLC31_stroboRelay") { if (strPayload == "off" || strPayload == "0" || strPayload == "false") digitalWrite(stroboRelay_pin, HIGH); else if (strPayload == "on" || strPayload == "1" || strPayload == "true") digitalWrite(stroboRelay_pin, LOW); } Serial.print (strTopic); Serial.print (" "); Serial.println (strPayload); Serial.println ("-------"); Serial.println (""); } !

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

                                    @electric69:

                                    @instalator:

                                    @revenkopa:

                                    по протоколу MQTT топики выглядят так mqtt/0/kv7/kitchen/1/rel1 А смысл их смотреть? Подписываешся на них и все какая разница что там в протоколе
                                    Может автор имеет ввиду тяжело парсить что прилетело от сервера?

                                    У меня callback примерно такой:

                                    ! //Функция обработки входящих соединений - прием данных по подписке void callback(char* topic, byte* payload, unsigned int length) { Serial.println (""); Serial.println ("-------"); Serial.println ("New callback of MQTT-broker"); //преобразуем тему(topic) и значение (payload) в строку payload[length] = '\0'; String strTopic = String(topic); String strPayload = String((char*)payload); //Исследуем что "прилетело" от сервера по подписке: //Изменение режима работы контроллера if (strTopic == "PLC31_OnLight/mode") { if (strPayload == "standby") PLC_mode=MODE_STANDBY; else if (strPayload == "active") PLC_mode=MODE_ACTIVE; else if (strPayload == "deactivation") PLC_mode=MODE_DEACTIVATION; } //Изменение времени таймаута if (strTopic == "PLC31_OnLight/timeout") { timeout = strPayload.toInt(); } //Управление реле стробоскопа if (strTopic == "common/PLC38_PLC31_stroboRelay") { if (strPayload == "off" || strPayload == "0" || strPayload == "false") digitalWrite(stroboRelay_pin, HIGH); else if (strPayload == "on" || strPayload == "1" || strPayload == "true") digitalWrite(stroboRelay_pin, LOW); } Serial.print (strTopic); Serial.print (" "); Serial.println (strPayload); Serial.println ("-------"); Serial.println (""); } ! `
                                    Ну собственно аналогично:

                                    ////////////////////////////////////////////////////////////////////////////
                                    void callback(char* topic, byte* payload, unsigned int length) {
                                        payload[length] = '\0';
                                        String strTopic = String(topic);
                                        String strPayload = String((char*)payload);
                                        callback_iobroker(strTopic, strPayload);
                                    }
                                    
                                    void callback_iobroker(String strTopic, String strPayload){
                                     if (strTopic == "myhome/Mother/DomofonOpen") { //Открыть домофон
                                        if (strPayload == "0")     digitalWrite(6, 0);
                                          else if (strPayload == "1") {
                                             digitalWrite(7, HIGH);
                                             delay(1000);
                                             digitalWrite(6, HIGH);
                                             delay(1500);
                                             digitalWrite(6, LOW);
                                             delay(500);
                                             digitalWrite(7, LOW);
                                             client.publish("myhome/Mother/DomofonOpen", "0");
                                          }
                                     } 
                                      if (strTopic == "myhome/Mother/DomofonUptube") { //Снять турбку домофона
                                        if (strPayload == "0")     digitalWrite(7, 0);
                                        else if (strPayload == "1") digitalWrite(7, 1);
                                      } 
                                      if (strTopic == "myhome/Mother/Change_Electro_counter"){
                                            Serial.print("CHG");
                                            Serial.print(strPayload);
                                            delay(10);
                                        }
                                       if (strTopic == "myhome/Mother/Dimmer_Button") { //Подсветка выключателей
                                           dimm = strPayload.toInt();
                                           if (dimm >= 0 && dimm <= 255){
                                               analogWrite(5, dimm);
                                           } 
                                       }
                                    }
                                    
                                    1 Reply Last reply Reply Quote 0
                                    • R
                                      revenkopa last edited by

                                      я имею ввиду что до версии драйвера MQTT Adapter 2.15 паблики исходящих сообщений имели вид

                                      "myhome/Mother/DomofonOpen"

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

                                      после версии драйвера MQTT Adapter 2.15 паблики исходящих сообщений стали

                                      "mqtt/0/myhome/Mother/DomofonOpen"

                                      и это меня не устраивает а отключить не нашел как

                                      обходные пути я вижу но они меня не устраивают

                                      поэтому вопросы :

                                      • это глюк при переходе ?

                                      • есть возможность отключить ?

                                      ну и старые никем не отвеченные :

                                      • Можно ли организовать работу с одной переменной (без IN и OUT) ?

                                      • У меня контролер ловит свои же сообщения и отрабатывает …. это глюк или все как положено?

                                      • как в iobroker организовать работу когда лампочка в vis отображает значение пришедшее в OUT а управляющий надо посылать в IN ?

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

                                        @revenkopa:

                                        я имею ввиду что до версии драйвера MQTT Adapter 2.15 паблики исходящих сообщений имели вид

                                        "myhome/Mother/DomofonOpen"

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

                                        после версии драйвера MQTT Adapter 2.15 паблики исходящих сообщений стали

                                        "mqtt/0/myhome/Mother/DomofonOpen"

                                        и это меня не устраивает а отключить не нашел как

                                        обходные пути я вижу но они меня не устраивают

                                        поэтому вопросы :

                                        • это глюк при переходе ?

                                        • есть возможность отключить ?

                                        ну и старые никем не отвеченные :

                                        • Можно ли организовать работу с одной переменной (без IN и OUT) ?

                                        • У меня контролер ловит свои же сообщения и отрабатывает …. это глюк или все как положено?

                                        • как в iobroker организовать работу когда лампочка в vis отображает значение пришедшее в OUT а управляющий надо посылать в IN ? `
                                          Выложи код с ардуины, подозреваю что то ты намудрил. Не пойму про IN и OUT, зачем они тебе?
                                          4447_adapterneustart-und-volume_gesetzt.log

                                        1 Reply Last reply Reply Quote 0
                                        • R
                                          revenkopa last edited by

                                          Вот код :

                                          ! #include <dht.h>#include <esp8266wifi.h>#include <pubsubclient.h>#define DHTPIN 5
                                          ! //#define DHTTYPE DHT11 // DHT 11
                                          ! #define DHTTYPE DHT22 // DHT 22 (AM2302)
                                          ! //#define DHTTYPE DHT21 // DHT 21 (AM2301)
                                          ! float dht_h ; // Reading temperature or humidity takes about 250 milliseconds!
                                          ! float dht_t ; // Read temperature as Celsius (the default)
                                          ! DHT dht(DHTPIN, DHTTYPE);
                                          ! #define Rel1pin 12
                                          ! #define Rel2pin 13
                                          ! #define But1pin 4
                                          ! #define But2pin 6
                                          ! // Update these with values suitable for your network.
                                          ! const char* ssid = "kv7";
                                          ! const char* password = "*****";
                                          ! //const char
                                          mqtt_server = "broker.mqtt-dashboard.com";
                                          ! IPAddress MQTTserver(192, 168, 1, 120);
                                          ! String MQTT_CN = "kv7/Kitchen/1";
                                          ! IPAddress IPAdrr (192, 168, 1, 201);
                                          ! IPAddress IPGW (192, 168, 1, 1);
                                          ! IPAddress Mask (255, 255, 255, 0);
                                          ! unsigned long TimerSendTH = 0;
                                          ! unsigned long TimerSendTHOFF = 2000;
                                          ! unsigned long TimerRel1 = 0;
                                          ! unsigned long TimerRel1OFF = 5000;
                                          ! unsigned long TimerRel2 = 0;
                                          ! unsigned long TimerRel2OFF = 6000;
                                          ! WiFiClient espClient;
                                          ! PubSubClient client(espClient);
                                          ! long lastMsg = 0;
                                          ! char msg[50];
                                          ! int value = 0;
                                          ! void setup() {
                                          ! pinMode(BUILTIN_LED, OUTPUT); // Initialize the BUILTIN_LED pin as an output
                                          ! pinMode(12, OUTPUT);
                                          ! pinMode(13, OUTPUT);
                                          ! pinMode( 4, INPUT);
                                          ! dht.begin();
                                          ! Serial.begin(115200);
                                          ! WiFi.begin(ssid, password);
                                          ! WiFi.config(IPAdrr, IPGW, Mask ); //Comment for DHCP
                                          ! setup_wifi();
                                          ! client.setServer(MQTTserver, 1883);
                                          ! client.setCallback(callback);
                                          ! }
                                          ! void setup_wifi() {
                                          ! delay(10);
                                          ! // We start by connecting to a WiFi network
                                          ! Serial.println();
                                          ! Serial.print("Connecting to ");
                                          ! Serial.println(ssid);
                                          ! // WiFi.begin(ssid, password);
                                          ! while (WiFi.status() != WL_CONNECTED) {
                                          ! delay(500);
                                          ! Serial.print(".");
                                          ! }
                                          ! Serial.println("");
                                          ! Serial.println("WiFi connected");
                                          ! Serial.println("IP address: ");
                                          ! Serial.println(WiFi.localIP());
                                          ! }
                                          ! void callback(char
                                          topic, byte
                                          payload, unsigned int length) {
                                          ! payload[length] = '\0';
                                          ! String strTopic = String(topic);
                                          ! strTopic.replace(MQTT_CN,"");
                                          ! String strPayload = String((char
                                          )payload);
                                          ! Serial.print("Message arrived [");
                                          ! Serial.print(strTopic+" | ");
                                          ! Serial.print(strPayload);
                                          ! Serial.print("]");
                                          ! Serial.println("");
                                          ! if (strTopic == "/Rel1") {
                                          ! if (strPayload == "0") digitalWrite(Rel1pin, !LOW);
                                          ! else if (strPayload == "1") digitalWrite(Rel1pin, !HIGH);
                                          ! }
                                          ! else if (strTopic == "/Rel2") {
                                          ! if (strPayload == "0") digitalWrite(Rel2pin, !LOW);
                                          ! else if (strPayload == "1") digitalWrite(Rel2pin, !HIGH);
                                          ! }
                                          ! }
                                          ! boolean reconnect() {
                                          ! Serial.print("Attempting MQTT connection…");
                                          ! // if (client.connect(("Controller "+MQTT_CN).c_str() ))
                                          ! if (client.connect("Controller 1"))
                                          ! {
                                          ! // Once connected, publish an announcement...
                                          ! client.publish(MQTT_CN.c_str() ," online");
                                          ! // ... and resubscribe
                                          ! Serial.print("Subscribe...ok "+MQTT_CN);
                                          ! client.subscribe((MQTT_CN+"/#").c_str() );
                                          ! }
                                          ! else Serial.print("Fail...");
                                          ! return client.connected();
                                          ! }
                                          ! boolean measurements() {
                                          ! Serial.print("measurements... ");
                                          ! dht_h = dht.readHumidity();
                                          ! dht_t = dht.readTemperature();
                                          ! if (isnan(dht_h) || isnan(dht_t) || isnan(dht.readTemperature(true))) return false;
                                          ! return true;
                                          ! }
                                          ! void loop() {
                                          ! if (!client.connected()) reconnect();
                                          ! client.loop();
                                          ! // digitalWrite(12, !digitalRead(4) );
                                          ! // digitalWrite(13, !digitalRead(4) );
                                          ! // TimerSendTH = 0;
                                          ! //TimerSendTHOFF = 2000;
                                          ! // TimerRel1 = 0;
                                          ! // TimerRel1OFF = 5000;
                                          ! // TimerRel2 = 0;
                                          ! // TimerRel2OFF = 6000;
                                          ! //measurements();
                                          ! //snprintf (msg, 75, "%2d", DHT.humidity);
                                          ! dtostrf (dht_h,0,2,msg );
                                          ! // client.publish((MQTT_CN+ "/humidity").c_str(), msg);
                                          ! // Serial.println(dht_h);
                                          ! dtostrf ( dht_t,0,2,msg );
                                          ! // client.publish((MQTT_CN+"/temperature").c_str(), msg);
                                          ! // Serial.println(dht_t);
                                          ! client.publish((MQTT_CN+"/Rel1").c_str(),String( !digitalRead(12)).c_str());
                                          ! Serial.println((MQTT_CN+"/Rel1"+String( !digitalRead(12))).c_str() );
                                          ! delay(500);
                                          ! client.publish((MQTT_CN+"/Rel2").c_str(),String( !digitalRead(13)).c_str());
                                          ! Serial.println((MQTT_CN+"/Rel2"+String( !digitalRead(13))).c_str() );
                                          ! delay(500);
                                          ! }</pubsubclient.h></esp8266wifi.h></dht.h>

                                          1 Reply Last reply Reply Quote 0
                                          • R
                                            revenkopa last edited by

                                            Вот точно такая же фигня была :

                                            Раньше такая строка отправлялась от брокера: myhome/Bedroom/Servo

                                            Сейчас: mqtt/0/myhome/Bedroom/Servo

                                            только не помогает ранее найденое лекарство - строка префикса и так пустая

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

                                            Support us

                                            ioBroker
                                            Community Adapters
                                            Donate

                                            896
                                            Online

                                            31.6k
                                            Users

                                            79.4k
                                            Topics

                                            1.3m
                                            Posts

                                            18
                                            244
                                            63153
                                            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