Sever44
Member
Всем привет!
С дружеской помощью участников форума освоил передачу данных на CloudMQTT в "intopic" и считывание данных из "outtopic".
Возникла задача:
Первый модуль публикует данные в определенный топик.
Второй модуль считывает данные из ЭТОГО ЖЕ топика.
И вот это и не получается.
При ручном вводе названия топика и его содержания на сайт MQTT все исправно выводится в порт.
При подключении "передатчика", "приемник начинает повторять подключения:
Connecting to MQTT server
Connected to MQTT server
1
и в порт ничего не выводит.
Вот топики:
Шестая от конца строка без пробела после::
"void callback(const MQTT:: Publish& pub)"
Почему-то иначе в спойлере появляется какая-то рожица.
Может, я чего-то не понимаю, и это принципиально невозможно?
Или есть ошибки?
Прошу помочь.
Заранее спасибо.
С дружеской помощью участников форума освоил передачу данных на CloudMQTT в "intopic" и считывание данных из "outtopic".
Возникла задача:
Первый модуль публикует данные в определенный топик.
Второй модуль считывает данные из ЭТОГО ЖЕ топика.
И вот это и не получается.
При ручном вводе названия топика и его содержания на сайт MQTT все исправно выводится в порт.
При подключении "передатчика", "приемник начинает повторять подключения:
Connecting to MQTT server
Connected to MQTT server
1
и в порт ничего не выводит.
Вот топики:
#include <ESP8266WiFi.h>
#include <PubSubClient.h>
int N;
const char *ssid = "***";
const char* const staPass = "***";
const char *mqtt_server = "***";
const int mqtt_port = ***;
const char *mqtt_user = "***";
const char *mqtt_pass = "***";
const char *mqtt_client_name = "Neptun";
#define BUFFER_SIZE 100
WiFiClient wclient;
PubSubClient client(wclient, mqtt_server, mqtt_port);
void setup() {
Serial.setTimeout(10);
Serial.begin(9600);
N = 0;
}
void loop() {
// подключаемся к wi-fi
if (WiFi.status() != WL_CONNECTED) {
Serial.println("...");
Serial.print("Connecting to ");
Serial.print(ssid);
Serial.println("...");
WiFi.begin(ssid, staPass);
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("Neptun")
.set_auth(mqtt_user, mqtt_pass))) {
Serial.println("Connected to MQTT server");
Serial.println("1");
} else {
Serial.println("Could not connect to MQTT server");
}
}
if (client.connected()){
client.loop();
}
}
N++;
client.publish("Nept_Mess","Message number = "+ String(N));
delay(3000);
}
#include <PubSubClient.h>
int N;
const char *ssid = "***";
const char* const staPass = "***";
const char *mqtt_server = "***";
const int mqtt_port = ***;
const char *mqtt_user = "***";
const char *mqtt_pass = "***";
const char *mqtt_client_name = "Neptun";
#define BUFFER_SIZE 100
WiFiClient wclient;
PubSubClient client(wclient, mqtt_server, mqtt_port);
void setup() {
Serial.setTimeout(10);
Serial.begin(9600);
N = 0;
}
void loop() {
// подключаемся к wi-fi
if (WiFi.status() != WL_CONNECTED) {
Serial.println("...");
Serial.print("Connecting to ");
Serial.print(ssid);
Serial.println("...");
WiFi.begin(ssid, staPass);
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("Neptun")
.set_auth(mqtt_user, mqtt_pass))) {
Serial.println("Connected to MQTT server");
Serial.println("1");
} else {
Serial.println("Could not connect to MQTT server");
}
}
if (client.connected()){
client.loop();
}
}
N++;
client.publish("Nept_Mess","Message number = "+ String(N));
delay(3000);
}
#include <ESP8266WiFi.h>
#include <PubSubClient.h>
const char *ssid = "***";
const char* const staPass = "***";
const char *mqtt_server = "****";
const int mqtt_port = ***;
const char *mqtt_user = "***";
const char *mqtt_pass = "***";
const char *mqtt_client_name = "Neptun";
#define BUFFER_SIZE 100
WiFiClient wclient;
PubSubClient client(wclient, mqtt_server, mqtt_port);
void setup() {
Serial.setTimeout(10);
Serial.begin(9600);
}
void loop() {
// подключаемся к wi-fi
if (WiFi.status() != WL_CONNECTED) {
Serial.println("...");
Serial.print("Connecting to ");
Serial.print(ssid);
Serial.println("...");
WiFi.begin(ssid, staPass);
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("Neptun")
.set_auth(mqtt_user, mqtt_pass))) {
Serial.println("Connected to MQTT server");
client.set_callback(callback);
client.subscribe("Nept_Mess");
Serial.println("1");
} else {
Serial.println("Could not connect to MQTT server");
}
}
if (client.connected()){
client.loop();
}
}
}
void callback(const MQTT:
ublish& pub)
{
Serial.println("2");
Serial.println(pub.topic());
Serial.println(pub.payload_string());
}
#include <PubSubClient.h>
const char *ssid = "***";
const char* const staPass = "***";
const char *mqtt_server = "****";
const int mqtt_port = ***;
const char *mqtt_user = "***";
const char *mqtt_pass = "***";
const char *mqtt_client_name = "Neptun";
#define BUFFER_SIZE 100
WiFiClient wclient;
PubSubClient client(wclient, mqtt_server, mqtt_port);
void setup() {
Serial.setTimeout(10);
Serial.begin(9600);
}
void loop() {
// подключаемся к wi-fi
if (WiFi.status() != WL_CONNECTED) {
Serial.println("...");
Serial.print("Connecting to ");
Serial.print(ssid);
Serial.println("...");
WiFi.begin(ssid, staPass);
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("Neptun")
.set_auth(mqtt_user, mqtt_pass))) {
Serial.println("Connected to MQTT server");
client.set_callback(callback);
client.subscribe("Nept_Mess");
Serial.println("1");
} else {
Serial.println("Could not connect to MQTT server");
}
}
if (client.connected()){
client.loop();
}
}
}
void callback(const MQTT:
ublish& pub){
Serial.println("2");
Serial.println(pub.topic());
Serial.println(pub.payload_string());
}
"void callback(const MQTT:: Publish& pub)"
Почему-то иначе в спойлере появляется какая-то рожица.
Может, я чего-то не понимаю, и это принципиально невозможно?
Или есть ошибки?
Прошу помочь.
Заранее спасибо.
