Basic MQTT with ESP32

/*
 * เชื่อมต่อไปยัง MQTT Broker ผ่าน WiFi
 * แสดงผลการทำงาน (Debug Message) ผ่าน Serial Port
 * Subscribe ไปยัง Topic ที่ต้องการและแสดงผลลัพธ์ผ่าน Serial Port
 * Publish ข้อมูล 1 ครั้งเมื่อเชื่อมต่อสำเร็จ
 */


#include "EspMQTTClient.h"


EspMQTTClient client
(
  "",   // SSID, ชื่อ WiFi ที่ต้องการเชื่อมต่อ
  "",   // WiFi Password
  "",   // MQTT Broker Address
  "",   // MQTT Username
  "",   // MQRR Password
  "",   // MQTT Device ID
  1883  // MQTT Port
);


void setup()
{

  // ใช้งาน Serial Port
  Serial.begin(115200);

  Serial.println("\r\nSTART ...");

  // แสดงผลการทำงาน (Debug Message) ผ่าน Serial Port
  client.enableDebuggingMessages();

}


// Function นี้ทำงานเมื่อ WiFi และ MQTT เชื่อมต่อไปยัง MQTT Broker สำเร็จ
void onConnectionEstablished()
{

  // Subscribe
  client.subscribe("fibo/log", [](const String & payload)
  {

    // แสดงข้อความ (Message) เมื่อมีการส่งข้อมูลไปยัง Topic ที่ทำการ Subscribe ไว้
    Serial.println(payload);

  });

  // Publish
  client.publish("fibo/init", "My IoT Device Connected.");

}


void loop()
{

  // MQTT Library Core Function.
  client.loop();

}