ทำ Smart Home ด้วย MQTT บน ESP32 และ Home Assistant

sudo apt update
sudo apt install mosquitto mosquitto-clients -y

# เปิด Mosquitto ทำงานอัตโนมัติเมื่อบูต
sudo systemctl enable mosquitto
sudo systemctl start mosquitto

# ตรวจสอบสถานะ
sudo systemctl status mosquitto

# สร้างไฟล์ password
sudo mosquitto_passwd -c /etc/mosquitto/passwd mqttuser

# แก้ไขไฟล์ config
sudo nano /etc/mosquitto/mosquitto.conf

listener 1883
allow_anonymous false
password_file /etc/mosquitto/passwd

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

// Wi-Fi credentials
const char* ssid = "WiFi_ของคุณ";
const char* password = "รหัส_WiFi";

// MQTT Broker
const char* mqtt_server = "192.168.1.100";  // IP ของ Raspberry Pi
const int mqtt_port = 1883;
const char* mqtt_user = "mqttuser";
const char* mqtt_pass = "รหัส_MQTT";

// Topics
const char* topic_temp = "home/living_room/temperature";
const char* topic_led = "home/living_room/led";

WiFiClient espClient;
PubSubClient client(espClient);

// Callback รับข้อความ
void callback(char* topic, byte* payload, unsigned int length) {
  String message = "";
  for (unsigned int i = 0; i < length; i++) {
    message += (char)payload[i];
  }
  
  Serial.printf("ได้รับข้อความจาก %s: %s\n", topic, message.c_str());
  
  // ควบคุม LED จาก MQTT
  if (String(topic) == topic_led) {
    if (message == "ON") {
      digitalWrite(2, HIGH);
    } else if (message == "OFF") {
      digitalWrite(2, LOW);
    }
  }
}

void connectMQTT() {
  while (!client.connected()) {
    Serial.print("กำลังเชื่อมต่อ MQTT...");
    String clientId = "ESP32-" + String(random(0xffff), HEX);
    
    if (client.connect(clientId.c_str(), mqtt_user, mqtt_pass)) {
      Serial.println("เชื่อมต่อสำเร็จ!");
      // Subscribe รับคำสั่ง LED
      client.subscribe(topic_led);
    } else {
      Serial.printf("ล้มเหลว rc=%d รอ 5 วินาที\n", client.state());
      delay(5000);
    }
  }
}

void setup() {
  Serial.begin(115200);
  pinMode(2, OUTPUT);
  
  // เชื่อมต่อ Wi-Fi
  WiFi.begin(ssid, password);
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
  Serial.println("\nWi-Fi เชื่อมต่อแล้ว");
  
  // ตั้งค่า MQTT
  client.setServer(mqtt_server, mqtt_port);
  client.setCallback(callback);
}

void loop() {
  if (!client.connected()) connectMQTT();
  client.loop();
  
  // ส่งค่าอุณหภูมิทุก 10 วินาที (ใช้ค่าจำลอง)
  static unsigned long lastMsg = 0;
  if (millis() - lastMsg > 10000) {
    lastMsg = millis();
    float temp = 25.5 + random(-20, 20) / 10.0;
    String payload = String(temp, 1);
    client.publish(topic_temp, payload.c_str());
    Serial.printf("ส่งอุณหภูมิ: %s°C\n", payload.c_str());
  }
}

mqtt:
  broker: 192.168.1.100
  port: 1883
  username: mqttuser
  password: รหัส_MQTT

sensor:
  - platform: mqtt
    name: "อุณหภูมิห้องนั่งเล่น"
    state_topic: "home/living_room/temperature"
    unit_of_measurement: "°C"
    device_class: temperature

switch:
  - platform: mqtt
    name: "LED ห้องนั่งเล่น"
    command_topic: "home/living_room/led"
    payload_on: "ON"
    payload_off: "OFF"

# Subscribe ดู topic
mosquitto_sub -h 192.168.1.100 -u mqttuser -P รหัส -t "home/#" -v

# Publish ทดสอบ
mosquitto_pub -h 192.168.1.100 -u mqttuser -P รหัส -t "home/living_room/led" -m "ON"