สอนใช้งาน ESP32 กับ MQTT: เชื่อมต่อ IoT แบบ Real-time

# สำหรับ Arduino IDE 2.x
# จะติดตั้งอัตโนมัติเมื่อ include ในโค้ด

#include <WiFi.h>
#include <PubSubClient.h>

void setup() {
  // ถ้าไม่มี error แปลว่าติดตั้งสำเร็จ
}

void loop() {
}

#include <WiFi.h>
#include <PubSubClient.h>

// ===== WiFi Credentials =====
const char* ssid = "YOUR_WIFI_SSID";
const char* password = "YOUR_WIFI_PASSWORD";

// ===== MQTT Broker Settings =====
const char* mqtt_server = "broker.hivemq.com";  // หรือ IP ของ broker คุณเอง
const int mqtt_port = 1883;

// ===== Topics =====
const char* mqtt_topic = "cynoiot/esp32/test";

// ===== Objects =====
WiFiClient espClient;
PubSubClient client(espClient);

// ===== Variables =====
unsigned long lastMsg = 0;
const long interval = 5000;  // ส่งทุก 5 วินาที

// ===== WiFi Setup =====
void setup_wifi() {
  delay(10);
  Serial.println("\nเชื่อมต่อ WiFi...");
  
  WiFi.begin(ssid, password);
  
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
  
  Serial.println("\nWiFi เชื่อมต่อสำเร็จ!");
  Serial.print("IP Address: ");
  Serial.println(WiFi.localIP());
}

// ===== MQTT Callback =====
void callback(char* topic, byte* message, unsigned int length) {
  Serial.print("มีข้อความมาจาก topic: ");
  Serial.print(topic);
  Serial.print(". ข้อความ: ");
  
  String messageTemp;
  
  for (int i = 0; i < length; i++) {
    Serial.print((char)message[i]);
    messageTemp += (char)message[i];
  }
  Serial.println();
  
  // ประมวลผลข้อความที่ได้รับ
  if (String(topic) == mqtt_topic) {
    if (messageTemp == "on") {
      Serial.println("เปิดอุปกรณ์!");
      // digitalWrite(ledPin, HIGH);
    } else if (messageTemp == "off") {
      Serial.println("ปิดอุปกรณ์!");
      // digitalWrite(ledPin, LOW);
    }
  }
}

// ===== Reconnect to MQTT =====
void reconnect() {
  // ลองเชื่อมต่อจนกว่าจะสำเร็จ
  while (!client.connected()) {
    Serial.print("กำลังเชื่อมต่อ MQTT...");
    
    // สร้าง Client ID แบบสุ่ม
    String clientId = "ESP32Client-";
    clientId += String(random(0xffff), HEX);
    
    // พยายามเชื่อมต่อ
    if (client.connect(clientId.c_str())) {
      Serial.println("เชื่อมต่อสำเร็จ!");
      
      // Subscribe topic
      client.subscribe(mqtt_topic);
      Serial.print("Subscribe topic: ");
      Serial.println(mqtt_topic);
    } else {
      Serial.print("เชื่อมต่อไม่สำเร็จ, rc=");
      Serial.print(client.state());
      Serial.println(" ลองใหม่ใน 5 วินาที");
      
      delay(5000);
    }
  }
}

// ===== Setup =====
void setup() {
  Serial.begin(115200);
  
  // เชื่อมต่อ WiFi
  setup_wifi();
  
  // ตั้งค่า MQTT
  client.setServer(mqtt_server, mqtt_port);
  client.setCallback(callback);
}

// ===== Loop =====
void loop() {
  // ตรวจสอบการเชื่อมต่อ MQTT
  if (!client.connected()) {
    reconnect();
  }
  client.loop();  // ต้องมีเพื่อให้ callback ทำงาน
  
  // ส่งข้อความทุก 5 วินาที
  unsigned long now = millis();
  if (now - lastMsg > interval) {
    lastMsg = now;
    
    // สร้างข้อความ
    String msg = "Hello from ESP32! Uptime: " + String(millis() / 1000) + "s";
    
    // ส่งข้อความ
    Serial.println("ส่งข้อความ: " + msg);
    client.publish(mqtt_topic, msg.c_str());
  }
}

#include <WiFi.h>
#include <PubSubClient.h>
#include <DHT.h>

// ===== WiFi & MQTT =====
const char* ssid = "YOUR_WIFI_SSID";
const char* password = "YOUR_WIFI_PASSWORD";
const char* mqtt_server = "broker.hivemq.com";

// ===== DHT Sensor =====
#define DHTPIN 4        // GPIO 4
#define DHTTYPE DHT11   // DHT11 หรือ DHT22
DHT dht(DHTPIN, DHTTYPE);

// ===== Topics =====
const char* temp_topic = "cynoiot/sensor/temperature";
const char* hum_topic = "cynoiot/sensor/humidity";

// ===== Objects =====
WiFiClient espClient;
PubSubClient client(espClient);

// ===== Variables =====
unsigned long lastSensorRead = 0;
const long sensorInterval = 10000;  // อ่านทุก 10 วินาที

void setup_wifi() {
  delay(10);
  Serial.println("\nเชื่อมต่อ WiFi...");
  WiFi.begin(ssid, password);
  
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
  
  Serial.println("\nWiFi เชื่อมต่อสำเร็จ!");
}

void reconnect() {
  while (!client.connected()) {
    Serial.print("เชื่อมต่อ MQTT...");
    String clientId = "ESP32-";
    clientId += String(random(0xffff), HEX);
    
    if (client.connect(clientId.c_str())) {
      Serial.println("สำเร็จ!");
    } else {
      Serial.print("ล้มเหลว, rc=");
      Serial.println(client.state());
      delay(5000);
    }
  }
}

void setup() {
  Serial.begin(115200);
  
  // เริ่มใช้งาน DHT
  dht.begin();
  
  // เชื่อมต่อ WiFi
  setup_wifi();
  
  // ตั้งค่า MQTT
  client.setServer(mqtt_server, 1883);
}

void loop() {
  if (!client.connected()) {
    reconnect();
  }
  client.loop();
  
  // อ่านเซ็นเซอร์ทุก 10 วินาที
  unsigned long now = millis();
  if (now - lastSensorRead > sensorInterval) {
    lastSensorRead = now;
    
    // อ่านค่าอุณหภูมิ (เซลเซียส)
    float temperature = dht.readTemperature();
    
    // อ่านค่าความชื้น (%)
    float humidity = dht.readHumidity();
    
    // ตรวจสอบว่าอ่านได้หรือไม่
    if (isnan(temperature) || isnan(humidity)) {
      Serial.println("อ่านค่าจาก DHT ไม่สำเร็จ!");
      return;
    }
    
    // แปลงค่าเป็น String
    char tempStr[8];
    char humStr[8];
    dtostrf(temperature, 1, 2, tempStr);  // ทศนิยม 2 ตำแหน่ง
    dtostrf(humidity, 1, 2, humStr);
    
    // ส่งค่าไปยัง MQTT
    client.publish(temp_topic, tempStr);
    client.publish(hum_topic, humStr);
    
    // แสดงผลใน Serial Monitor
    Serial.print("อุณหภูมิ: ");
    Serial.print(temperature);
    Serial.print("°C | ความชื้น: ");
    Serial.print(humidity);
    Serial.println("%");
  }
}

#include <WiFi.h>
#include <PubSubClient.h>

// ===== WiFi & MQTT =====
const char* ssid = "YOUR_WIFI_SSID";
const char* password = "YOUR_WIFI_PASSWORD";
const char* mqtt_server = "broker.hivemq.com";

// ===== Relay =====
#define RELAY_PIN 2  // GPIO 2
const char* relay_topic = "cynoiot/relay/1";

// ===== State =====
bool relayState = false;

WiFiClient espClient;
PubSubClient client(espClient);

void setup_wifi() {
  // ... เหมือนตัวอย่างที่แล้ว ...
}

// ===== MQTT Callback - รับคำสั่ง =====
void callback(char* topic, byte* payload, unsigned int length) {
  Serial.print("มีข้อความจาก ");
  Serial.println(topic);
  
  // แปลง payload เป็น string
  String message = "";
  for (int i = 0; i < length; i++) {
    message += (char)payload[i];
  }
  
  Serial.print("คำสั่ง: ");
  Serial.println(message);
  
  // ตรวจสอบคำสั่ง
  if (message == "ON" || message == "on" || message == "1") {
    digitalWrite(RELAY_PIN, HIGH);  // เปิด Relay
    relayState = true;
    Serial.println("เปิด Relay!");
    
    // ส่งสถานะกลับ
    client.publish(relay_topic, "ON");
  } 
  else if (message == "OFF" || message == "off" || message == "0") {
    digitalWrite(RELAY_PIN, LOW);   // ปิด Relay
    relayState = false;
    Serial.println("ปิด Relay!");
    
    // ส่งสถานะกลับ
    client.publish(relay_topic, "OFF");
  }
}

void reconnect() {
  // ... เหมือนตัวอย่างที่แล้ว ...
}

void setup() {
  Serial.begin(115200);
  
  // ตั้งค่า Relay pin
  pinMode(RELAY_PIN, OUTPUT);
  digitalWrite(RELAY_PIN, LOW);  // เริ่มต้นปิด
  
  setup_wifi();
  
  client.setServer(mqtt_server, 1883);
  client.setCallback(callback);  // ตั้งค่า callback
}

void loop() {
  if (!client.connected()) {
    reconnect();
    
    // Subscribe topic หลังเชื่อมต่อสำเร็จ
    client.subscribe(relay_topic);
    Serial.println("Subscribe: " + String(relay_topic));
  }
  client.loop();
}