使用 MQTT 将设备订阅到 Mindsphere IoTExtension答案

【问题标题】：Subscribe device to Mindsphere IoTExtension using MQTT使用 MQTT 将设备订阅到 Mindsphere IoTExtension
【发布时间】：2019-01-22 07:33:29
【问题描述】：

我正在做一个用于演示的小项目。

我正在使用ESP8266 使用MQTT 功能将数据发布到物联网扩展，如here 所述。我正在发布到 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();
}

【问题讨论】：

你能告诉我们你有连接和订阅主题的arduino代码吗？

标签： mqtt publish-subscribe esp8266 mindsphere

【解决方案1】：

现在我想要另一个 ESP8266 订阅同一个频道。

这可能吗？

是的 - 您可以通过连接在您的 PC 上运行的独立 MQTT 客户端来确认您已正确配置发布客户端和代理。然后让 MQTT 客户端订阅频道。

您的订阅代码至少存在一个潜在问题。它仅在与代理的第一次连接时订阅主题。默认的 PubSubClient 连接将使用 Clean Session - 当客户端断开连接并重新连接时，不会保留任何以前的订阅。

因此，如果订阅者失去了与代理的初始连接，那么它将不会在后续连接中订阅主题。

您可以通过将订阅代码移动到重新连接函数中来解决此问题，如下面的 sn-p 所示。

  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();

【讨论】：