สร้าง MQTT Broker ส่วนตัวด้วย Mosquitto สำหรับโปรเจกต์ ESP32 IoT ของคุณ

# อัปเดตระบบ
sudo apt update

# ติดตั้ง Mosquitto Broker และ Clients
sudo apt install -y mosquitto mosquitto-clients

# ติดตั้ง utilities เพิ่มเติม (optional)
sudo apt install -y mosquitto-dev

# เช็คเวอร์ชัน
mosquitto --version

# เริ่มต้นบริการ
sudo systemctl start mosquitto

# ตั้งค่าให้เปิดบริการอัตโนมัติเมื่อบูตเครื่อง
sudo systemctl enable mosquitto

# เช็คสถานะบริการ
sudo systemctl status mosquitto

# สำรองไฟล์เดิม
sudo cp /etc/mosquitto/mosquitto.conf /etc/mosquitto/mosquitto.conf.backup

# แก้ไขไฟล์ตั้งค่า
sudo nano /etc/mosquitto/mosquitto.conf

# ตั้งค่าพื้นฐาน
# อนุญาตให้เชื่อมต่อแบบไม่มี authentication (เฉพาะทดสอบ)
listener 1883
allow_anonymous true

# เปิดใช้งาน persistence (บันทึก retained messages)
persistence true
persistence_location /var/lib/mosquitto/

# บันทึก log ลงไฟล์
log_dest file /var/log/mosquitto/mosquitto.log

# ระดับ log (debug, info, notice, warning, error)
log_type error
log_type warning
log_type notice
log_type information

# รีสตาร์ท Mosquitto
sudo systemctl restart mosquitto

# เช็ค log ว่าทำงานปกติ
sudo tail -f /var/log/mosquitto/mosquitto.log

# สร้าง password file และเพิ่ม user แรก
sudo mosquitto_passwd -c /etc/mosquitto/passwd esp32_user

# ระบบจะถาม password ให้ตั้งและยืนยัน
# Password: (พิมพ์ password และกด Enter)
# Reenter password: (พิมพ์ซ้ำและกด Enter)

# เพิ่ม user เพิ่มเติม (ถ้าต้องการ)
sudo mosquitto_passwd -b /etc/mosquitto/passwd sensor_node_1
sudo mosquitto_passwd -b /etc/mosquitto/passwd sensor_node_2

# แก้ไขไฟล์ตั้งค่า
sudo nano /etc/mosquitto/mosquitto.conf

# ปิดการเชื่อมต่อแบบไม่มี authentication
allow_anonymous false

# ระบุ password file
password_file /etc/mosquitto/passwd

# อนุญาตให้ user ทุกคนเข้าถึงทุก topic (เปลี่ยนตามต้องการ)
acl_file /etc/mosquitto/acl

# สร้างไฟล์ ACL
sudo nano /etc/mosquitto/acl

# ESP32 User - อ่านเขียนได้ทุก topic
user esp32_user
topic readwrite #

# Sensor Node 1 - เขียนลง sensor/ ได้อย่างเดียว
user sensor_node_1
topic write sensor/#
topic read command/#

sudo systemctl restart mosquitto
sudo systemctl status mosquitto

// เปิด Arduino IDE
// ไปที่ Sketch -> Include Library -> Manage Libraries
// ค้นหา "PubSubClient" และติดตั้ง
// ค้นหา "DHT sensor library" และติดตั้ง (ถ้าใช้ DHT)

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

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

// ===== MQTT Broker Settings =====
const char* mqtt_server = "192.168.1.100";  // IP ของ Raspberry Pi หรือ VPS
const int mqtt_port = 1883;
const char* mqtt_user = "esp32_user";
const char* mqtt_password = "your_secure_password";
const char* mqtt_client_id = "ESP32_Sensor_01";

// ===== Sensor Settings =====
#define DHTPIN 4
#define DHTTYPE DHT22
DHT dht(DHTPIN, DHTTYPE);

// ===== MQTT Topics =====
const char* temp_topic = "sensor/esp32_01/temperature";
const char* humi_topic = "sensor/esp32_01/humidity";
const char* status_topic = "sensor/esp32_01/status";

// ===== Global Objects =====
WiFiClient espClient;
PubSubClient client(espClient);
unsigned long lastMsg = 0;
const long interval = 5000;  // ส่งข้อมูลทุก 5 วินาที

// ===== Function: เชื่อมต่อ WiFi =====
void setup_wifi() {
  delay(10);
  Serial.println();
  Serial.print("Connecting to ");
  Serial.println(ssid);

  WiFi.begin(ssid, password);

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

  Serial.println("");
  Serial.println("WiFi connected");
  Serial.println("IP address: ");
  Serial.println(WiFi.localIP());
}

// ===== Function: Callback รับข้อความจาก Broker =====
void callback(char* topic, byte* payload, unsigned int length) {
  Serial.print("Message arrived [");
  Serial.print(topic);
  Serial.print("]: ");

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

  // ตัวอย่าง: รับคำสั่งจาก topic command/esp32_01
  if (String(topic) == "command/esp32_01") {
    if (message == "ON") {
      digitalWrite(2, HIGH);  // เปิด LED
      Serial.println("LED turned ON");
    } else if (message == "OFF") {
      digitalWrite(2, LOW);   // ปิด LED
      Serial.println("LED turned OFF");
    }
  }
}

// ===== Function: เชื่อมต่อ MQTT Broker อีกครั้ง =====
void reconnect() {
  while (!client.connected()) {
    Serial.print("Attempting MQTT connection...");

    // พยายามเชื่อมต่อด้วย username/password
    if (client.connect(mqtt_client_id, mqtt_user, mqtt_password)) {
      Serial.println("connected");

      // ส่งสถานะออนไลน์
      client.publish(status_topic, "online");

      // Subscribe หัวข้อที่ต้องการรับคำสั่ง
      client.subscribe("command/esp32_01");
    } else {
      Serial.print("failed, rc=");
      Serial.print(client.state());
      Serial.println(" retrying in 5 seconds");

      // รอ 5 วินาทีแล้วลองใหม่
      delay(5000);
    }
  }
}

// ===== Function: ส่งข้อมูลเซ็นเซอร์ =====
void sendSensorData() {
  float h = dht.readHumidity();
  float t = dht.readTemperature();

  // เช็คว่าอ่านค่าได้หรือไม่
  if (isnan(h) || isnan(t)) {
    Serial.println("Failed to read from DHT sensor!");
    return;
  }

  // แปลงค่าเป็น String
  char tempStr[8];
  char humiStr[8];
  dtostrf(t, 1, 2, tempStr);
  dtostrf(h, 1, 2, humiStr);

  // ส่งข้อมูลไปยัง Broker
  client.publish(temp_topic, tempStr);
  client.publish(humi_topic, humiStr);

  Serial.print("Temperature: ");
  Serial.print(t);
  Serial.print("°C | Humidity: ");
  Serial.print(h);
  Serial.println("%");
}

// ===== Setup =====
void setup() {
  Serial.begin(115200);
  pinMode(2, OUTPUT);  // LED pin

  dht.begin();
  setup_wifi();

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

// ===== Loop =====
void loop() {
  // ตรวจสอบการเชื่อมต่อ MQTT
  if (!client.connected()) {
    reconnect();
  }
  client.loop();

  // ส่งข้อมูลเซ็นเซอร์ทุก 5 วินาที
  unsigned long now = millis();
  if (now - lastMsg > interval) {
    lastMsg = now;
    sendSensorData();
  }
}

# Terminal 1: Subscribe รับข้อมูล
mosquitto_sub -h 192.168.1.100 -u esp32_user -P your_secure_password -t "sensor/#" -v

# Terminal 2: Publish ส่งคำสั่ง
mosquitto_pub -h 192.168.1.100 -u esp32_user -P your_secure_password -t command/esp32_01 -m "ON"