Драйвер Mqtt + Arduino

revenkopa

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

instalator

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

revenkopa

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

instalator

~~@revenkopa:~~

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

У меня так

client.publish("myhome/NRF/Vodonagrevatel/btn_Temp_Selector", "0");
    client.publish("myhome/NRF/Vodonagrevatel/Status", "0");
    client.subscribe("myhome/NRF/#");

revenkopa

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

mqtt/0/kv7/kitchen/1/rel1

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

instalator

~~@revenkopa:~~

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

mqtt/0/kv7/kitchen/1/rel1

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

revenkopa

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

instalator

~~@revenkopa:~~

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

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

instalator

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

revenkopa

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

"myhome/Mother/DomofonOpen"

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

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

"mqtt/0/myhome/Mother/DomofonOpen"

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

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

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

это глюк при переходе ?
есть возможность отключить ?

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

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

instalator

~~@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

revenkopa

Вот код :

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

revenkopa

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

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

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

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

instalator

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

Я так и не пойму какая разница ` > Раньше такая строка отправлялась от брокера: myhome/Bedroom/Servo

Сейчас: mqtt/0/myhome/Bedroom/Servo `
Что это меняет?

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

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 передаются в ардуину?

instalator

~~@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/" `
а сама функция то далее по коду есть?

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

Haus

Я же написал "в твоём коде заменил библиотеку для 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></uipethernet.h>

Haus

Чего хочу сделать:

Есть 2 аккумулятивных бака, раньше в них стояли простые термометры и показывали температуру. Сейчас вместо них всунуты DS18B20 и на экране компьютера, телефона всё прекрасно отображается. Но когда хочешь докинуть дров чтобы до грузить баки, под рукой может неокозатца телефона чтобы прикинуть сколько дров подбросить. Хочу поставить рядом с котлом LCD монитор чтобы видеть температуру баков 4х2=8 датчиков переданную с сервера. Также можно было бы и снимать температуру с датчиков отображать на дисплей и отправлять серверу.

NEWS

Драйвер Mqtt + Arduino

Support us

897
Online

31.6k
Users

79.4k
Topics

1.3m
Posts

NEWS

Драйвер Mqtt + Arduino

Support us

897Online

31.6kUsers

79.4kTopics

1.3mPosts

897
Online

31.6k
Users

79.4k
Topics

1.3m
Posts