Хочу перейти с cloudmqtt.com на mosquitto broker

Sergey2003
Offline
Зарегистрирован: 25.11.2020

В 2017ом году покупали три ESP8266 для управления умным домом через приложение на Android MQTT Dashboard. В свое время блогер все доступно расписал, что справится даже ребенок и даже выложил настроенный скетч. Но спустя 2,5года сайт решил перейти на платную основу и начал вставлять палки в колеса бесплатникам. Появилась идея сделать свой сервер со своим брокером. Это не сложно. Проблема в другом, на сайте все три ESP8266 были как-то разделены по своим инстансам и не мешали друг другу, а теперь я их загнал на один сервер и при запуске второй ESP8266 не работает первая. Я так понимаю что нужно дать ESP8266 имена или что-то подобное и развести их по топикам что-бы они могли кинать инфу на телефон не мешая друг другу, но все мои попытки потерпели фиаско. Например сделать test/temp->test/temp2 и test/led->test/led2 к хорошему не привели. Нужно что-то еще кроме того что бы пририсовать к топику два и три.

И еще думал пойти простым путем, но так и не придумал. можно ли на mosquitto сервере сделать два а лучше три независимых брокера и подключить к ним ESP8266, а потом телефоном собирать данные и отправлять запрос на управление реле. Далее выкладываю сам скетч:

// Светодиод подлкючен к 5 пину
// Датчик температуры ds18b20 к 2 пину
 
#include <ESP8266WiFi.h>
#include <PubSubClient.h>
#include <OneWire.h>
#include <DallasTemperature.h>
 
#define ONE_WIRE_BUS 2
OneWire oneWire(ONE_WIRE_BUS);
DallasTemperature sensors(&oneWire);
 
const char *ssid =  "AIRPORT";  // Имя вайфай точки доступа
const char *pass =  "PASSWORD"; // Пароль от точки доступа
 
const char *mqtt_server = "server"; // Имя сервера MQTT
const int mqtt_port = 11140; // Порт для подключения к серверу MQTT
const char *mqtt_user = "Login"; // Логи от сервер
const char *mqtt_pass = "Pass"; // Пароль от сервера
 
#define BUFFER_SIZE 100
 
bool LedState = false;
int tm=300;
float temp=0;
 
// Функция получения данных от сервера
 
void callback(const MQTT::Publish& pub)
{
  Serial.print(pub.topic());   // выводим в сериал порт название топика
  Serial.print(" => ");
  Serial.print(pub.payload_string()); // выводим в сериал порт значение полученных данных
  
  String payload = pub.payload_string();
  
  if(String(pub.topic()) == "test/led") // проверяем из нужного ли нам топика пришли данные 
  {
  int stled = payload.toInt(); // преобразуем полученные данные в тип integer
  digitalWrite(5,stled);  //  включаем или выключаем светодиод в зависимоти от полученных значений данных
  }
}
 
 
 
WiFiClient wclient;      
PubSubClient client(wclient, mqtt_server, mqtt_port);
 
void setup() {
  
  sensors.begin();
  Serial.begin(115200);
  delay(10);
  Serial.println();
  Serial.println();
  pinMode(5, OUTPUT);
}
 
void loop() {
  // подключаемся к wi-fi
  if (WiFi.status() != WL_CONNECTED) {
    Serial.print("Connecting to ");
    Serial.print(ssid);
    Serial.println("...");
    WiFi.begin(ssid, pass);
 
    if (WiFi.waitForConnectResult() != WL_CONNECTED)
      return;
    Serial.println("WiFi connected");
  }
 
  // подключаемся к MQTT серверу
  if (WiFi.status() == WL_CONNECTED) {
    if (!client.connected()) {
      Serial.println("Connecting to MQTT server");
      if (client.connect(MQTT::Connect("arduinoClient2")
                         .set_auth(mqtt_user, mqtt_pass))) {
        Serial.println("Connected to MQTT server");
        client.set_callback(callback);
        client.subscribe("test/led"); // подписывааемся по топик с данными для светодиода
      } else {
        Serial.println("Could not connect to MQTT server");   
      }
    }
 
    if (client.connected()){
      client.loop();
      TempSend();
  }
  
}
} // конец основного цикла
 
 
// Функция отправки показаний с термодатчика
void TempSend(){
  if (tm==0)
  {
  sensors.requestTemperatures();   // от датчика получаем значение температуры
  float temp = sensors.getTempCByIndex(0);
  client.publish("test/temp",String(temp)); // отправляем в топик для термодатчика значение температуры
  Serial.println(temp);
  tm = 300;  // пауза меду отправками значений температуры  коло 3 секунд
  }
  tm--; 
  delay(10);  
}
andycat
andycat аватар
Offline
Зарегистрирован: 07.09.2017

1. Скетч некорректно выложен
2. это один скетч на все устройства? если да - в жизни не заработает, должны быть разные имена устройств при подключении
3. чтоб понять что пропускает и как можно ли совмещать топики, обратитесь к официальной документации на  mosquitto . Если я правильно помню по стандартам неограниченное количество клиентов могут писать/читать одинаковые топики. Там же ищите информацию можно ли разные брокеры на сервере делать.

Sergey2003
Offline
Зарегистрирован: 25.11.2020

1. Можно по подробнее, что значит некорректно выложен скетч? Все что было в скетче выделил и закопировал сюда.

2. Потому и обращаюсь за помощью. Тыкните носом, где прописываются прописываются имена устройств и как разделить топики. Хватит им просто добавить циферки или еще нужно прописать чего. Где-то видел прописывали Smartphone/room/ESP8266, потом Smartphone/room2/ESP8266.

3. ОК глянем. Найти бы видеогайд было бы супер, но с другой стороны если можно с одним брокером все замутить то тоже пойдет. Это я так уже с отчаяния предлагаю три брокера сделать. На сайте cloudmqtt.com было предложено три инстанса и все работало без проблем.

AndreyD
AndreyD аватар
Offline
Зарегистрирован: 07.10.2018

Sergey2003 пишет:

1. Можно по подробнее, что значит некорректно выложен скетч? Все что было в скетче выделил и закопировал сюда.

Тут

От себя рекомендую перейти на одноплатники для сервера "умного дома", cubietruck, например, и под linux конечно, а к нему уже присоединять ESP8266 или Ардуино.