找不到正确的MQTT代理服务器

1 回答

• 0

  我正在使用arduino IDE与esp8266和mqtt做一些相当不错的工作 . 我已经登录到我自己的mqtt经纪人，我在一个使用x509证书加密的centos 7盒子中设置 .

  我使用mosquitto-auth-plug来管理用户访问，同时在同一台机器上设置mysql数据库

  当你想到它时，操作系统是免费的，mosquitto broker是免费的，而mysql服务器是免费的 .

  拥有自己的设置的唯一费用是固定IP和足够快的连接 . 你可以在azure上的虚拟机中设置相当便宜的 .

  无论如何，当我第一次开始一个朋友（那个卖我第一个nodemcu .9板的人） . 把这个脚本搞定了，我已经用这个作为我的例子来完成所有这些 .

  我喜欢的部分是你从mqtt盒子或其他人那样的客户端监控你的mqtt . 当芯片首次启动时，它会将有效负载“Start”发送到主题“device_name / status” . 通过这种方式，您可以随时了解它何时在线 .

  我复制了他给我的笔记，他们位于下方 .

  祝好运

  /*
  * Skeleton for ESPP based sensors.
  * Supports:
  *  - OTA fw update via HTTP
  *    http://ipaddr/update
  *  - REST access
  *    http://ipaddr:8080/<id>
  *  - MQTT publish and subscribe
  */
  
  #include <ESP8266WiFi.h>
  #include <PubSubClient.h>
  #include <ESP8266mDNS.h>
  #include <WiFiUdp.h>
  #include <ESP8266WebServer.h>
  #include <ESP8266mDNS.h>
  #include <ESP8266HTTPUpdateServer.h>
  #include <aREST.h>
  
  // Define device name
  const char* device_name = "myHostName";
  const char* ssid = "WiFiSSID";
  const char* password = "wiFiPassword";
  const char* mqtt_server = "mqtt_hostname.example.com";
  char host[14];
  
  int rest_test = 7467;
  
  /* WiFi Client */
  WiFiClient espClient;
  
  /* MQTT Client */
  PubSubClient client(espClient);
  
  /* HTTP client, for remote updates */
  ESP8266WebServer httpServer(80);
  ESP8266HTTPUpdateServer httpUpdater;
  
  /* Rest server */
  aREST rest = aREST();
  WiFiServer restServer(8080);
  
  void setup() {
    char topic[80];
  
    Serial.begin(115200);
  
    /* Start WiFi */
    setup_wifi();
  
    /* Setup MQTT client */
    client.setServer(mqtt_server, 1883);
    client.setCallback(mqtt_callback);
  
    /* Start the HTTP update server */
    MDNS.begin(host);
    httpUpdater.setup(&httpServer);
    httpServer.begin();
    MDNS.addService("http", "tcp", 80);
  
    /* Set REST variables */
    rest.set_id("1");
    rest.set_name(host);
    rest.variable("test", &rest_test);
    /*
    rest.variable("temperature", &temp);
    rest.variable("distance", &dist);
    rest.variable("reset_count", &reset_count);
    rest.set_id("1");
    rest.set_name("esp8266");
    */
    restServer.begin();
  
    /* Connect to the MQTT broker */
    reconnect();
    client.subscribe("network/broadcast");
    sprintf(topic, "network/%s", device_name);
    client.subscribe(topic);
    sprintf(topic, "%s/status", device_name);
    client.publish(topic, "start");
  
    Serial.print("Node ");
    Serial.print(device_name);
    Serial.println(" started.");
  
    Serial.print("Hostname ");
    Serial.println(host);
  
    Serial.print("IP Address ");
    Serial.println(WiFi.localIP());
  
  
  }
  
  void setup_wifi() {
    uint8_t mac[6];
  
    delay(10);
  
    WiFi.begin(ssid, password);
    WiFi.macAddress(mac);
    sprintf(host, "esp-%02x%02x%02x", mac[3], mac[4], mac[5]);
    WiFi.hostname(host);
  
    while (WiFi.status() != WL_CONNECTED) {
      delay(500);
    }
  }
  
  /* Handle incoming MQTT messages */
  void mqtt_callback(char* topic, byte* payload, unsigned int length) {
    char payloadStr[80];
  
    if (length > 79) {
      length = 79;
    }
    memcpy(payloadStr, payload, length);
    payloadStr[length] = '\0';
  
  
    if (strcmp(payloadStr, "discover") == 0) {
      delay(random(10, 1000));
      client.publish("network/presence", device_name);
    }
  
    if (strcmp(payloadStr, "refresh") == 0) {
      /* Publish all sensor data */
  
    }
  }
  
  /* Connect (or re-connect) to the MQTT broker */
  void reconnect() {
    // Loop until we're reconnected
    while (!client.connected()) {
      // Attempt to connect
      /* TODO:  Create this based on the MAC address */
      if (client.connect(host)) {
  
      } else {
  
        // Wait 5 seconds before retrying
        delay(5000);
      }
    }
  }
  
  void loop() {
    WiFiClient restClient;
  
    /* Check MQTT connection, reconnect if needed */
    if (!client.connected()) {
      reconnect();
    }
  
    /* Process MQTT tasks */
    client.loop();
  
    /* Process HTTP FW update requests */
    httpServer.handleClient();
  
    /* Process REST requests */
    restClient = restServer.available();
    if (restClient) {
      while (!restClient.available()) {
        delay(1);
      }
      rest.handle(restClient);
    }
  
  
    /* Insert normal sensor code here. */
    /* Publish results with client.publish(topic, value); */
  
  }
  

  我的代码设置了自己的设备名称，订阅了MQTT主题“network / broadcast”，“network /（device name）” .

  当它启动时，它发送“（device_name）/ status”，其有效负载为“start” .

  当它获得具有“发现”有效载荷的“网络/广播”时，它通过发布“网络/存在”及其名称来回复 .

  基本上，您使用client.publish（topic，payload）发送了MQTT事件 .

  您使用client.subscribe（topic）订阅事件 .

  当收到与您的订阅匹配的事件时，它将调用mqtt_callback并为其提供主题，有效负载和长度 .

  希望有所帮助 .

  回复于 2024-05-19T08:04:57+08:00