我正在开展一个小型项目用于演示目的。
我正在使用ESP8266
使用MQTT
描述的here功能向IoT扩展发布数据。我发布到s / us主题,它工作正常。
现在我想要另一个ESP8266
订阅同一个频道。
这可能吗?如果是,那么这样做的正确方法是什么?我已经尝试订阅s / us主题(使用arduino pubsubclient lib
),但这不起作用,我无法找到任何相关信息。
这是所要求的代码:
#include <ESP8266WiFi.h>
#include <PubSubClient.h>
const char* ssid = "ssid";
const char* password = "Password";
const char* mqtt_Server = "mciotextension.eu-central.mindsphere.io";
const int mqtt_Port = 1883;
const char* mqtt_user = "User";
const char* mqtt_password = "Password";
WiFiClient espClient;
PubSubClient client(espClient);
void callback(char* topic, byte* payload, unsigned int length) {
Serial.print("Message arrived in topic: ");
Serial.println(topic);
Serial.print("Message:");
for (int i = 0; i < length; i++) {
Serial.print((char)payload[i]);
}
Serial.println();
Serial.println("-----------------------");
}
void reconnect() {
// Loop until reconnected
while (!client.connected()) {
Serial.print("Attempting MQTT connection...");
String clientId = "0da4cfbb-4ea2-488d-8a89-739ec04acf1e";
// Attempt to connect
if (client.connect(clientId.c_str(), mqtt_user, mqtt_password)) {
Serial.println("connected");
} else {
Serial.print("failed, rc= ");
Serial.print(client.state());
Serial.println(" try again in 5 seconds");
delay(5000);
}
}
}
void setup() {
Serial.begin(115200);
WiFi.begin(ssid, password);
while (WiFi.status() != WL_CONNECTED) {
delay(500);
Serial.println("Connecting to WiFi..");
}
Serial.println("Connected to WiFi network");
client.setServer(mqtt_Server, mqtt_Port);
reconnect();
client.setCallback(callback);
client.subscribe("s/us"); //I also tryed s/ds
}
void loop() {
client.loop();
delay(1000);
reconnect();
}
现在我想要另一个ESP8266订阅同一个频道。
这可能吗?
是 - 您可以通过连接PC上运行的独立MQTT客户端来确认您已正确配置发布客户端和代理。然后让MQTT客户端订阅该频道。
您的订阅代码至少有一个潜在问题。它仅在与代理的第一个连接上订阅主题。默认的PubSubClient连接将使用Clean Session - 当客户端断开连接并重新连接时,任何以前的订阅都不会保留。
因此,如果订户失去与代理的初始连接,那么它将不会在后续连接上订阅该主题。
您可以通过将订阅代码移动到重新连接功能来解决此问题,如下面的代码段所示。
if (client.connect(clientId.c_str(), mqtt_user, mqtt_password)) {
Serial.println("connected");
client.subscribe("s/us");
} else {
我还建议你在第一次连接安装之前调用setCallback()
。例如在setup()
client.setServer(mqtt_Server, mqtt_Port);
client.setCallback(callback);
reconnect();