Getting Started with MQTT on ESP32實驗

  Getting Started with MQTT on ESP32 實驗

參考來源 https://randomnerdtutorials.com/micropython-mqtt-esp32-esp8266/

[{"id":"6a82eae8e458e7cb","type":"ui_button","z":"972e6260e6a3d8bd","name":"","group":"6c9116b.b62d4e8","order":47,"width":"3","height":"1","passthru":false,"label":"publish : hello","tooltip":"","color":"","bgcolor":"","className":"","icon":"","payload":"hello","payloadType":"str","topic":"topic","topicType":"msg","x":240,"y":420,"wires":[["afa8db051fe63d6f","4a2d4166521cfd63"]]},{"id":"afa8db051fe63d6f","type":"mqtt out","z":"972e6260e6a3d8bd","name":"hello","topic":"alex9ufo/esp32/hello","qos":"1","retain":"true","respTopic":"","contentType":"","userProps":"","correl":"","expiry":"","broker":"841df58d.ee5e98","x":430,"y":400,"wires":[]},{"id":"70bf58b349b6433f","type":"mqtt in","z":"972e6260e6a3d8bd","name":"notification","topic":"alex9ufo/esp32/notification","qos":"2","datatype":"auto-detect","broker":"841df58d.ee5e98","nl":false,"rap":true,"rh":0,"inputs":0,"x":220,"y":500,"wires":[["b01ece174947bed5","2e38f776bb20ffc8","9f1d4a98cbfbb761"]]},{"id":"b01ece174947bed5","type":"ui_text","z":"972e6260e6a3d8bd","group":"6c9116b.b62d4e8","order":48,"width":"6","height":"1","name":"","label":"subscribe","format":"<font color={{red}}>{{msg.payload}}","layout":"row-right","className":"","x":640,"y":500,"wires":[]},{"id":"4a2d4166521cfd63","type":"debug","z":"972e6260e6a3d8bd","name":"debug ","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"payload","targetType":"msg","statusVal":"","statusType":"auto","x":430,"y":460,"wires":[]},{"id":"2e38f776bb20ffc8","type":"debug","z":"972e6260e6a3d8bd","name":"debug ","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"payload","targetType":"msg","statusVal":"","statusType":"auto","x":410,"y":540,"wires":[]},{"id":"9f1d4a98cbfbb761","type":"delay","z":"972e6260e6a3d8bd","name":"","pauseType":"delay","timeout":"5","timeoutUnits":"seconds","rate":"1","nbRateUnits":"1","rateUnits":"second","randomFirst":"1","randomLast":"5","randomUnits":"seconds","drop":false,"allowrate":false,"outputs":1,"x":420,"y":580,"wires":[["1bc3de990cbcb7ff"]]},{"id":"1bc3de990cbcb7ff","type":"function","z":"972e6260e6a3d8bd","name":"function 83","func":"msg.payload=''\nreturn msg;","outputs":1,"noerr":0,"initialize":"","finalize":"","libs":[],"x":570,"y":580,"wires":[["b01ece174947bed5"]]},{"id":"6c9116b.b62d4e8","type":"ui_group","name":"2023 Storing IOT Data ","tab":"6249073d2714bfd4","order":1,"disp":true,"width":"16","collapse":true,"className":""},{"id":"841df58d.ee5e98","type":"mqtt-broker","name":"","broker":"broker.mqtt-dashboard.com","port":"1883","clientid":"","autoConnect":true,"usetls":false,"compatmode":false,"protocolVersion":4,"keepalive":"15","cleansession":true,"birthTopic":"","birthQos":"0","birthPayload":"","closeTopic":"","closePayload":"","willTopic":"","willQos":"0","willPayload":""},{"id":"6249073d2714bfd4","type":"ui_tab","name":"RFID Home","icon":"dashboard","disabled":false,"hidden":false}]

//Wifi  + MQTT

#include <WiFi.h>

#include <PubSubClient.h>

// WiFi

//const char *ssid = "alex9ufo"; // Enter your Wi-Fi name

//const char *password = "alex9981";  // Enter Wi-Fi password

const char *ssid = "TOTOLINK_A3002MU"; // Enter your Wi-Fi name

const char *password = "24063173";  // Enter Wi-Fi password

// MQTT Broker

const char *mqtt_broker = "broker.mqtt-dashboard.com";

const char *topic1 = "alex9ufo/esp32/hello";           //subscribe

const char *topic2 = "alex9ufo/esp32/notification";    //publish

const char *mqtt_username = "alex9ufo";

const char *mqtt_password = "public";

const int mqtt_port = 1883;

WiFiClient espClient;

PubSubClient client(espClient);

bool Send = false;  //true

String json = "";    

char jsonChar1[50];  //client.publish("alex9ufo/Esp32/notification")

//宣告任務Task1

TaskHandle_t Task1;

// Wifi reconnect

unsigned long previousMillis = 0;

unsigned long interval = 30000;

//===========================================================

//任務1副程式Task1_senddata

void Task1_senddata(void * pvParameters ) {

  //無窮迴圈

  for (;;)

  {

   

    Serial.println("Process Publish message");

    if (Send) //偵測上傳旗標是否為true

    { //received hello

      json="ESP received hello message";

      json.toCharArray(jsonChar1, json.length()+1);

   

      if  (client.connected())

      {

        Serial.print("Publish message: ");

        Serial.println(json);

        // Publish JSON character array to MQTT topic

        client.publish(topic2,jsonChar1); //topic2 = "alex9ufo/esp32/notification";  //publish

        Send=false;   //設定旗標為false

      }  

      else

      {

        Serial.print("MQTT not connected ");

      }

     

    }

    else  

    {

      Serial.println("Timed out waiting for a message");

    }      

    //Task1休息，delay(X)不可省略

    delay(1000);

  }

}

//===========================================================

void reconnect() {

  // Loop until we're reconnected

  while (!client.connected()) {

    Serial.print("Attempting MQTT connection...");

    // Attempt to connect

    if (client.connect("esp32-client-")) {

      Serial.println("connected");

      // Subscribe

      client.subscribe("alex9ufo/esp32/hello");

 

    } else {

      Serial.print("failed, rc=");

      Serial.print(client.state());

      Serial.println(" try again in 5 seconds");

      // Wait 5 seconds before retrying

      delay(5000);

      if (WiFi.status() != WL_CONNECTED)  {

        Serial.println("Reconnecting to WiFi...");

        WiFi.disconnect();

        WiFi.reconnect();

      }

    }

  }

}

//===========================================================

void callback(char *topic, byte *payload, unsigned int length) {

    Serial.print("Message arrived in topic: ");

    Serial.println(topic);

    Serial.print("Message: ");

    String message;

    for (int i = 0; i < length; i++) {

        message += (char) payload[i];  // Convert *byte to string

    }

    Serial.print(message);

    if (message == "hello") {

      Send=true;

    }

    Serial.println();

    Serial.println("-----------------------");

}

//===========================================================

void initWiFi() {

  WiFi.mode(WIFI_STA);

  WiFi.begin(ssid, password);

  Serial.print("Connecting to WiFi ..");

  while (WiFi.status() != WL_CONNECTED) {

    Serial.print('.');

    delay(1000);

  }

  Serial.println(WiFi.localIP());

}

//===========================================================

void setup() {

    // Set software serial baud to 115200;

    Serial.begin(115200);

    delay(1000); // Delay for stability

    initWiFi();

    Serial.println("Connected to the WiFi network");

    // Connecting to an MQTT broker

    client.setServer(mqtt_broker, mqtt_port);

    client.setCallback(callback);

    while (!client.connected()) {

        String client_id = "esp32-client-";

        client_id += String(WiFi.macAddress());

        Serial.printf("The client %s connects to the public MQTT broker\n", client_id.c_str());

        if (client.connect(client_id.c_str(), mqtt_username, mqtt_password)) {

            Serial.println("Public HiveMQ MQTT broker (broker.mqtt-dashboard.com) connected");

        } else {

            Serial.print("Failed with state ");

            Serial.print(client.state());

            delay(2000);

        }

    }

    // Publish and subscribe

    client.subscribe(topic1);   //topic1 = "alex9ufo/esp32/hello";subscribe

   

    //在核心0啟動任務1

    xTaskCreatePinnedToCore(

    Task1_senddata, /*任務實際對應的Function*/

      "Task1",        /*任務名稱*/

      10000,          /*堆疊空間*/

      NULL,           /*無輸入值*/

      0,              /*優先序0*/

      &Task1,         /*對應的任務變數位址*/

      0);             /*指定在核心0執行 */

}

//===========================================================

void loop() {

  if (!client.connected()) {

      reconnect();

      Serial.print(" client not connected  reconnect ");

      delay(200);

  }

  client.loop();

  unsigned long currentMillis = millis();

  // if WiFi is down, try reconnecting

  if ((WiFi.status() != WL_CONNECTED) && (currentMillis - previousMillis >=interval)) {

    Serial.print(millis());

    Serial.println("Reconnecting to WiFi...");

    WiFi.disconnect();

    WiFi.reconnect();

    previousMillis = currentMillis;

    client.setCallback(callback);

  }

}

//===========================================================