บทความ: ESP32 MQTT สำหรับ IoT แบบครบวงจร

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

// ========== ตั้งค่า WiFi ==========
const char* ssid = "YOUR_WIFI_SSID";
const char* wifi_password = "YOUR_WIFI_PASSWORD";

// ========== ตั้งค่า MQTT ==========
const char* mqtt_server = "xxxxxxxxxx.s1.eu.hivemq.cloud";  // HiveMQ Cloud URL
const int mqtt_port = 8883;  // HiveMQ Cloud TLS port
const char* mqtt_user = "YOUR_MQTT_USERNAME";
const char* mqtt_password = "YOUR_MQTT_PASSWORD";

// ========== อุปกรณ์ ==========
WiFiClient espClient;
PubSubClient client(espClient);

// ตั้งเวลา reconnect (5 วินาที)
unsigned long lastReconnectAttempt = 0;

// ========== ฟังก์ชันเชื่อมต่อ WiFi ==========
void setup_wifi() {
  delay(10);
  Serial.println("\\nเชื่อมต่อ WiFi...");

  WiFi.begin(ssid, wifi_password);

  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }

  Serial.println("\\nWiFi เชื่อมต่อสำเร็จ!");
  Serial.print("IP Address: ");
  Serial.println(WiFi.localIP());
}

// ========== ฟังก์ชันรับข้อความจาก MQTT ==========
void callback(char* topic, byte* payload, unsigned int length) {
  Serial.print("มีข้อความใหม่จาก Topic: ");
  Serial.print(topic);
  Serial.print(" | ข้อความ: ");

  String message;
  for (int i = 0; i < length; i++) {
    message += (char)payload[i];
    Serial.print((char)payload[i]);
  }
  Serial.println();

  // ตัวอย่าง: ควบคุม LED ถ้าได้รับข้อความ "ON" หรือ "OFF"
  if (message == "ON") {
    digitalWrite(2, HIGH);  // เปิด LED
    Serial.println("→ เปิด LED");
  } else if (message == "OFF") {
    digitalWrite(2, LOW);   // ปิด LED
    Serial.println("→ ปิด LED");
  }
}

// ========== ฟังก์ชันเชื่อมต่อ MQTT ใหม่ ==========
boolean reconnect() {
  if (client.connect("ESP32Client", mqtt_user, mqtt_password)) {
    Serial.println("เชื่อมต่อ MQTT สำเร็จ!");
    // Subscribe topic ที่ต้องการรับข้อความ
    client.subscribe("home/led/control");
  } else {
    Serial.print("เชื่อมต่อ MQTT ล้มเหลว, rc=");
    Serial.print(client.state());
    Serial.println(" ลองใหม่ใน 5 วินาที");
  }
  return client.connected();
}

// ========== การตั้งค่าเริ่มต้น ==========
void setup() {
  Serial.begin(115200);
  pinMode(2, OUTPUT);  // ตั้งค่า LED pin เป็น output

  setup_wifi();  // เชื่อมต่อ WiFi

  // ตั้งค่า MQTT
  client.setServer(mqtt_server, mqtt_port);
  client.setCallback(callback);
}

// ========== ลูปหลัก ==========
void loop() {
  // ลองเชื่อมต่อ MQTT ใหม่ถ้าหลุด
  if (!client.connected()) {
    unsigned long now = millis();
    if (now - lastReconnectAttempt > 5000) {
      lastReconnectAttempt = now;
      if (reconnect()) {
        lastReconnectAttempt = 0;
      }
    }
  } else {
    client.loop();  // รักษาการเชื่อมต่อ MQTT
  }
}

#include <DHT.h>

// กำหนดขา DHT
#define DHTPIN 4
#define DHTTYPE DHT22

DHT dht(DHTPIN, DHTTYPE);

unsigned long lastSensorRead = 0;
const long sensorInterval = 5000;  // อ่านทุก 5 วินาที

void setup() {
  // ... (โค้ดเดิมจากขั้นตอนที่แล้ว)

  dht.begin();  // เริ่มต้นเซ็นเซอร์ DHT
}

void loop() {
  if (!client.connected()) {
    // ... (โค้ด reconnect เดิม)
  } else {
    client.loop();

    // อ่านเซ็นเซอร์ทุก 5 วินาที
    unsigned long now = millis();
    if (now - lastSensorRead >= sensorInterval) {
      lastSensorRead = now;
      readAndSendSensor();
    }
  }
}

// ฟังก์ชันอ่านและส่งค่าเซ็นเซอร์
void readAndSendSensor() {
  // อ่านอุณหภูมิ (เซลเซียส)
  float temperature = dht.readTemperature();

  // อ่านความชื้น (%)
  float humidity = dht.readHumidity();

  // ตรวจสอบว่าอ่านสำเร็จหรือไม่
  if (isnan(temperature) || isnan(humidity)) {
    Serial.println("❌ อ่านเซ็นเซอร์ DHT ล้มเหลว!");
    return;
  }

  // แสดงค่าใน Serial Monitor
  Serial.print("อุณหภูมิ: ");
  Serial.print(temperature);
  Serial.print("°C | ความชื้น: ");
  Serial.print(humidity);
  Serial.println("%");

  // แปลงค่าเป็น String เพื่อส่งผ่าน MQTT
  String tempString = String(temperature);
  String humString = String(humidity);

  // ส่งค่าไปยัง MQTT Topics
  client.publish("home/livingroom/temperature", tempString.c_str());
  client.publish("home/livingroom/humidity", humString.c_str());

  Serial.println("✅ ส่งค่าเซ็นเซอร์ไปยัง MQTT แล้ว!");
}

#define RELAY_PIN 2  // ขาที่ต่อ Relay

void setup() {
  // ... (โค้ดเดิม)

  pinMode(RELAY_PIN, OUTPUT);
  digitalWrite(RELAY_PIN, LOW);  // เริ่มต้นให้ Relay ปิด

  // Subscribe topic สำหรับควบคุม Relay
  client.subscribe("home/livingroom/relay");
}

void callback(char* topic, byte* payload, unsigned int length) {
  Serial.print("มีข้อความใหม่: ");
  Serial.println(topic);

  String message;
  for (int i = 0; i < length; i++) {
    message += (char)payload[i];
  }

  Serial.print("คำสั่ง: ");
  Serial.println(message);

  // ตรวจสอบ Topic
  if (String(topic) == "home/livingroom/relay") {
    if (message == "ON") {
      digitalWrite(RELAY_PIN, HIGH);  // เปิด Relay
      Serial.println("✅ เปิด Relay");

      // ส่งสถานะกลับไปยัง MQTT
      client.publish("home/livingroom/relay/status", "ON");
    }
    else if (message == "OFF") {
      digitalWrite(RELAY_PIN, LOW);   // ปิด Relay
      Serial.println("✅ ปิด Relay");

      // ส่งสถานะกลับไปยัง MQTT
      client.publish("home/livingroom/relay/status", "OFF");
    }
    else if (message == "TOGGLE") {
      // สลับสถานะ
      int currentState = digitalRead(RELAY_PIN);
      digitalWrite(RELAY_PIN, !currentState);

      String newState = !currentState ? "ON" : "OFF";
      Serial.print("✅ สลับสถานะ Relay: ");
      Serial.println(newState);

      // ส่งสถานะกลับไปยัง MQTT
      client.publish("home/livingroom/relay/status", newState.c_str());
    }
  }
}

// ========== ตั้งค่า CynoIoT MQTT ==========
const char* cynoiot_mqtt_server = "mqtt.cynoiot.com";
const int cynoiot_mqtt_port = 1883;
const char* cynoiot_device_id = "YOUR_DEVICE_ID";
const char* cynoiot_device_key = "YOUR_DEVICE_KEY";

// Topic สำหรับ CynoIoT
String cynoiot_topic = "cynoiot/" + String(cynoiot_device_id) + "/data";

void readAndSendSensor() {
  // ... (โค้ดอ่านเซ็นเซอร์เดิม)

  // สร้าง JSON payload สำหรับ CynoIoT
  String payload = "{";
  payload += "\\"temperature\\":" + String(temperature) + ",";
  payload += "\\"humidity\\":" + String(humidity);
  payload += "}";

  // ส่งไปยัง CynoIoT Platform
  client.publish(cynoiot_topic.c_str(), payload.c_str());
  Serial.println("✅ ส่งข้อมูลไปยัง CynoIoT แล้ว!");
}