Осваиваю wemos. Хочу порулить через cloudmqtt.com.
Что сделано
1. Заведен mqtt брокер с именем home.
2. в телефоне поставлено mqtt dashboard. Оформлена подписка на тему home/temp. Добавлен виджет паблишера svetik.
3. Скетч в порт выдает
НО в дашбоард эта единичка не прилетает. И светодиодом поморгать не могу... уже и видео посмотрел ... что то похоже не сделал .. а вот что хз...
Если при подключеном дашборде сменить состояние светодиода, отключится и снова сменить то при подключении оно восстанавливается.. так что связь телефон cloudmqtt есть... проблемка со стороны wemos`a
а как он вообще должен читать я не пойму... процедура проверки паблика запукается только при подключении к брокеру... я правильно понял ?
Или подкиньте рабочий код. Можно к другому брокеру.
Счетч
Что сделано
1. Заведен mqtt брокер с именем home.
2. в телефоне поставлено mqtt dashboard. Оформлена подписка на тему home/temp. Добавлен виджет паблишера svetik.
3. Скетч в порт выдает
Код:
Connecting to xxxxx...
WiFi connected
IP192.168.4.105
Connecting to MQTT server
Connected to MQTT server
1
1
1
Если при подключеном дашборде сменить состояние светодиода, отключится и снова сменить то при подключении оно восстанавливается.. так что связь телефон cloudmqtt есть... проблемка со стороны wemos`a
а как он вообще должен читать я не пойму... процедура проверки паблика запукается только при подключении к брокеру... я правильно понял ?
Или подкиньте рабочий код. Можно к другому брокеру.
Счетч
Код:
#include <MQTT.h>
#include <PubSubClient.h>
#include <ESP8266WiFi.h>
const char *ssid = "xxxxx"; // Имя вайфай точки доступа
const char *pass = "xxxxxx"; // Пароль от точки доступа
const char *mqtt_server = "m11.cloudmqtt.com"; // Имя сервера MQTT
const int mqtt_port = 17427; // Порт для подключения к серверу MQTT
const char *mqtt_user = "xxxxxxx"; // Логи от сервер
const char *mqtt_pass = "xxxxxxx"; // Пароль от сервера
WiFiClient wclient;
PubSubClient client(wclient, mqtt_server, mqtt_port);
int tm, temp;
void setup() {
// put your setup code here, to run once:
pinMode (D1, OUTPUT);
Serial.begin(115200);
}
void loop() {
// put your main code here, to run repeatedly:
if (WiFi.status() != WL_CONNECTED) { // подключаемся к WIFI
Serial.print("Connecting to ");
Serial.print(ssid);
Serial.println("...");
WiFi.begin(ssid, pass);
if (WiFi.waitForConnectResult() != WL_CONNECTED)
return;
Serial.println("WiFi connected");
Serial.print ("IP");
Serial.println(WiFi.localIP());
}
// подключаемся к 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("Home/svetik"); // подписывааемся по топик с данными для светодиода
} else {
Serial.println("Could not connect to MQTT server");
}
}
}
if (client.connected()) {
client.loop();
TempSend();
}
}
// Функция отправки показаний с термодатчика
void TempSend() {
if (tm == 0)
{
temp = 1;
client.publish("Home/temp", String(temp)); // отправляем в топик для термодатчика значение температуры
Serial.println(temp);
tm = 300; // пауза меду отправками значений температуры коло 3 секунд
}
tm--;
delay(10);
}
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()) == "Home/svetik") // проверяем из нужного ли нам топика пришли данные
{
int stled = payload.toInt(); // преобразуем полученные данные в тип integer
digitalWrite(D1, stled); // включаем или выключаем светодиод в зависимоти от полученных значений данных
}
}
Последнее редактирование: