รู้จักกับ Mosquitto MQTT Broker: หัวใจสำคัญของระบบ IoT ในบ้าน

ในยุคที่บ้านอัจฉริยะ (Smart Home) กำลังเป็นที่นิยม การเชื่อมต่ออุปกรณ์ IoT (Internet of Things) หลากหลายชนิดเข้าด้วยกันกลายเป็นความท้าทายสำคัญ อุปกรณ์จากผู้ผลิตต่างกัน ใช้โปรโตคอลการสื่อสารที่แตกต่างกัน ทำให้การรวมศูนย์ควบคุมเป็นเรื่องยุ่งยาก นี่คือจุดที่ MQTT (Message Queuing Telemetry Transport) เข้ามามีบทบาท โดยเฉพาะ Mosquitto MQTT Broker ซึ่งเป็นซอฟต์แวร์โอเพนซอร์สน้ำหนักเบาที่ได้รับความนิยมสูงสุดในวงการ IoT

MQTT เป็นโปรโตคอลแบบ publish/subscribe ที่ออกแบบมาเพื่อการสื่อสารระหว่างเครื่องจักร (Machine-to-Machine) โดยมี Broker ทำหน้าที่เป็นศูนย์กลางรับส่งข้อความ ข้อดีของ MQTT คือใช้แบนด์วิธต่ำ เหมาะกับอุปกรณ์ที่มีทรัพยากรจำกัด และรองรับการเชื่อมต่อจำนวนมากพร้อมกัน Mosquitto พัฒนาโดย Eclipse Foundation เป็นหนึ่งใน Broker ที่มีประสิทธิภาพ เสถียร และติดตั้งง่ายที่สุดสำหรับการใช้งานในบ้าน

บทความนี้จะพาคุณไปรู้จักกับการติดตั้งและตั้งค่า Mosquitto MQTT Broker สำหรับระบบ IoT ในบ้านอย่างละเอียด ตั้งแต่พื้นฐานไปจนถึงเทคนิคขั้นสูง พร้อมตัวอย่างการใช้งานจริงและแนวปฏิบัติที่ดีที่สุด

การติดตั้ง Mosquitto MQTT Broker บน Raspberry Pi และ Linux

การติดตั้ง Mosquitto สามารถทำได้หลายวิธี ขึ้นอยู่กับระบบปฏิบัติการที่คุณใช้ สำหรับระบบ IoT ในบ้าน Raspberry Pi ที่ใช้ Raspberry Pi OS (เดิมชื่อ Raspbian) เป็นตัวเลือกยอดนิยมเนื่องจากใช้พลังงานต่ำและมีขนาดเล็ก นอกจากนี้ยังสามารถติดตั้งบน Ubuntu, Debian, หรือแม้แต่ Windows Server ก็ได้

การติดตั้งบน Raspberry Pi OS / Debian / Ubuntu

วิธีที่ง่ายที่สุดคือการใช้ package manager ที่มาพร้อมกับระบบปฏิบัติการ คำสั่งต่อไปนี้จะติดตั้ง Mosquitto พร้อมกับ client tools ที่จำเป็น

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

หลังจากติดตั้งเสร็จ Broker จะเริ่มทำงานอัตโนมัติ คุณสามารถตรวจสอบสถานะการทำงานได้ด้วยคำสั่ง:

sudo systemctl status mosquitto

หากต้องการให้ Mosquitto ทำงานทุกครั้งที่บูตเครื่อง ให้ใช้คำสั่ง:

sudo systemctl enable mosquitto

การติดตั้งด้วย Docker (ทางเลือกสำหรับผู้ใช้ขั้นสูง)

สำหรับผู้ที่ต้องการแยกสภาพแวดล้อมหรือต้องการอัปเดตเวอร์ชันล่าสุดได้ง่าย การใช้ Docker เป็นอีกทางเลือกที่ดี:

docker run -d --name mosquitto \
  -p 1883:1883 \
  -p 9001:9001 \
  -v /path/to/mosquitto/config:/mosquitto/config \
  -v /path/to/mosquitto/data:/mosquitto/data \
  -v /path/to/mosquitto/log:/mosquitto/log \
  eclipse-mosquitto:latest

หมายเหตุ: ต้องสร้างโฟลเดอร์ config, data, log ก่อนรัน Docker และต้องมีไฟล์ mosquitto.conf ในโฟลเดอร์ config

การตรวจสอบการทำงานเบื้องต้น

เมื่อติดตั้งเสร็จ คุณสามารถทดสอบการทำงานด้วย mosquitto_sub และ mosquitto_pul ซึ่งเป็นเครื่องมือ client ที่มาพร้อมกับแพ็กเกจ:

เปิดเทอร์มินัลแรกเพื่อ subscribe topic:

mosquitto_sub -h localhost -t "test/topic" -v

เปิดเทอร์มินัลที่สองเพื่อ publish ข้อความ:

mosquitto_pub -h localhost -t "test/topic" -m "Hello IoT Home"

ถ้าทุกอย่างทำงานถูกต้อง เทอร์มินัลแรกจะแสดงข้อความ “test/topic Hello IoT Home” ทันที

การตั้งค่า Mosquitto.conf พื้นฐานสำหรับบ้านอัจฉริยะ

ไฟล์การตั้งค่าหลักของ Mosquitto คือ mosquitto.conf ซึ่งโดยปกติจะอยู่ที่ /etc/mosquitto/mosquitto.conf การปรับแต่งไฟล์นี้จะช่วยให้ Broker ทำงานได้เหมาะสมกับสภาพแวดล้อม IoT ในบ้านของคุณ

โครงสร้างไฟล์การตั้งค่าพื้นฐาน

นี่คือตัวอย่างการตั้งค่าที่เหมาะสมสำหรับระบบ IoT ในบ้าน:

# พื้นฐานการรับฟัง
listener 1883
protocol mqtt

# WebSocket (สำหรับเชื่อมต่อจากเว็บเบราว์เซอร์)
listener 9001
protocol websockets

# การตั้งค่าความปลอดภัยพื้นฐาน
allow_anonymous false
password_file /etc/mosquitto/passwd

# จำกัดการเชื่อมต่อ
max_connections 100

# การบันทึก log
log_dest file /var/log/mosquitto/mosquitto.log
log_type all
connection_messages true

# การตั้งค่า persistence
persistence true
persistence_location /var/lib/mosquitto/

# การตั้งค่า QoS และ Retain
max_inflight_messages 20
max_queued_messages 100
retain_available true

คำอธิบายพารามิเตอร์สำคัญ:

• listener 1883 – พอร์ตมาตรฐานของ MQTT สำหรับการเชื่อมต่อ TCP ปกติ
• listener 9001 protocol websockets – พอร์ตสำหรับ WebSocket ช่วยให้เว็บแอปพลิเคชันเชื่อมต่อได้
• allow_anonymous false – ปิดการเชื่อมต่อแบบไม่ระบุตัวตน เพิ่มความปลอดภัย
• password_file – ระบุไฟล์ที่เก็บรหัสผ่านของผู้ใช้
• max_connections – จำกัดจำนวนการเชื่อมต่อสูงสุด ป้องกันการโอเวอร์โหลด
• persistence true – บันทึกข้อความค้างไว้เมื่อ Broker รีสตาร์ท

การสร้างผู้ใช้และรหัสผ่าน

เมื่อตั้งค่า allow_anonymous false แล้ว คุณต้องสร้างผู้ใช้เพื่อให้อุปกรณ์ต่างๆ สามารถเชื่อมต่อได้:

sudo mosquitto_passwd -c /etc/mosquitto/passwd username1

ระบบจะถามรหัสผ่าน ให้ป้อนตามต้องการ หากต้องการเพิ่มผู้ใช้เพิ่มเติม ไม่ต้องใช้ -c (เพราะจะลบผู้ใช้เดิม):

sudo mosquitto_passwd /etc/mosquitto/passwd username2

หลังจากแก้ไขไฟล์คอนฟิกและสร้างผู้ใช้แล้ว ให้รีสตาร์ท Mosquitto:

sudo systemctl restart mosquitto

การรักษาความปลอดภัยขั้นสูง: TLS/SSL และ Access Control

ความปลอดภัยเป็นสิ่งสำคัญมากสำหรับระบบ IoT ในบ้าน เพราะอุปกรณ์เหล่านี้เชื่อมต่อกับเครือข่ายอินเทอร์เน็ตและอาจถูกโจมตีได้ การใช้ TLS/SSL จะเข้ารหัสข้อมูลทั้งหมดที่ส่งผ่าน MQTT ป้องกันการดักจับข้อมูล

การตั้งค่า TLS ด้วย Self-Signed Certificate

สำหรับการใช้งานในบ้าน การสร้าง certificate เอง (self-signed) ก็เพียงพอแล้ว โดยไม่ต้องเสียเงินซื้อ certificate จาก CA:

ขั้นตอนที่ 1: สร้าง Certificate Authority (CA)

openssl req -new -x509 -days 3650 -extensions v3_ca -keyout ca.key -out ca.crt

ขั้นตอนที่ 2: สร้าง Server Certificate

openssl genrsa -out server.key 2048
openssl req -new -key server.key -out server.csr
openssl x509 -req -in server.csr -CA ca.crt -CAkey ca.key -CAcreateserial -out server.crt -days 3650

ขั้นตอนที่ 3: วางไฟล์ certificate ในตำแหน่งที่เหมาะสมและตั้งค่า mosquitto.conf:

# TLS/SSL Configuration
listener 8883
protocol mqtt
cafile /etc/mosquitto/certs/ca.crt
certfile /etc/mosquitto/certs/server.crt
keyfile /etc/mosquitto/certs/server.key
tls_version tlsv1.2
require_certificate false

การตั้งค่า require_certificate false หมายความว่าผู้ใช้ยังคงใช้รหัสผ่านในการล็อกอินได้ (ไม่ต้องมี client certificate) ซึ่งสะดวกสำหรับอุปกรณ์ IoT ทั่วไป

การควบคุมการเข้าถึงด้วย ACL (Access Control List)

ACL ช่วยให้คุณกำหนดสิทธิ์ว่าแต่ละผู้ใช้สามารถ publish หรือ subscribe topic ใดได้บ้าง สร้างไฟล์ /etc/mosquitto/acl และเพิ่มบรรทัดต่อไปนี้ใน mosquitto.conf:

acl_file /etc/mosquitto/acl

ตัวอย่างไฟล์ ACL:

# ผู้ใช้ทุกคนสามารถอ่าน topic เกี่ยวกับสถานะบ้าน
pattern read house/+/status

# ผู้ใช้ sensor สามารถเขียนไปยัง topic sensor เท่านั้น
user sensor_user
topic write sensor/#

# ผู้ใช้ควบคุมสามารถเขียนไปยัง topic actuator ได้
user control_user
topic write actuator/#

# ผู้ใช้ admin มีสิทธิ์ทุกอย่าง
user admin_user
topic readwrite #

หลักการเขียน ACL:

• user [username] – ระบุชื่อผู้ใช้
• topic [read|write|readwrite] [topic] – กำหนดสิทธิ์
• pattern [read|write|readwrite] [topic] – ใช้กับผู้ใช้ที่ไม่ระบุชื่อ (anonymous)
• สัญลักษณ์ + แทน wildcard ระดับเดียว, # แทนหลายระดับ

การออกแบบ Topic Structure สำหรับระบบ IoT ในบ้าน

การออกแบบโครงสร้าง topic ที่ดีเป็นหัวใจสำคัญของระบบ MQTT ที่มีประสิทธิภาพ โครงสร้างที่ดีจะช่วยให้การจัดการ การค้นหา และการขยายระบบทำได้ง่ายขึ้น

หลักการ命名 Topic

ควรใช้โครงสร้างแบบลำดับชั้น (hierarchical) โดยแยกส่วนต่างๆ ด้วยเครื่องหมาย / ตัวอย่างเช่น:

• บ้าน/ชั้น1/ห้องนั่งเล่น/อุณหภูมิ
• บ้าน/ชั้น1/ห้องนั่งเล่น/หลอดไฟ/1/สถานะ
• บ้าน/ชั้น2/ห้องนอน/เซ็นเซอร์/ประตู

ข้อดีของโครงสร้างแบบนี้:

• สามารถ subscribe เป็นกลุ่มได้ เช่น subscribe “บ้าน/ชั้น1/#” เพื่อรับข้อมูลทั้งชั้น
• ง่ายต่อการเพิ่มอุปกรณ์ใหม่โดยไม่ต้องเปลี่ยนโครงสร้างเดิม
• รองรับการใช้งาน ACL ได้อย่างมีประสิทธิภาพ

รูปแบบ Topic ที่แนะนำสำหรับบ้านอัจฉริยะ

ประเภท	รูปแบบ Topic	ตัวอย่าง	QoS ที่แนะนำ
เซ็นเซอร์	sensor/[device_id]/[type]	sensor/temp_living/temperature	1
อุปกรณ์ควบคุม	device/[device_id]/[command]	device/light_living/set	1
สถานะ	status/[device_id]/[attribute]	status/light_living/power	2
การแจ้งเตือน	alert/[zone]/[type]	alert/kitchen/motion	2
ระบบ	system/[component]/[action]	system/broker/uptime	0

การใช้ Retained Messages และ Last Will Testament (LWT)

Retained Messages คือข้อความที่ Broker เก็บไว้แม้ไม่มี subscriber ปัจจุบัน เมื่อมี subscriber ใหม่มา subscribe topic นี้ จะได้รับข้อความล่าสุดทันที ซึ่งมีประโยชน์มากสำหรับเซ็นเซอร์ที่รายงานค่าล่าสุด เช่น อุณหภูมิห้อง

Last Will Testament (LWT) เป็นข้อความที่อุปกรณ์กำหนดไว้ล่วงหน้า หากอุปกรณ์ตัดการเชื่อมต่อโดยไม่คาดคิด (เช่น ไฟดับ) Broker จะ publish ข้อความ LWT ให้โดยอัตโนมัติ ทำให้ระบบทราบว่าอุปกรณ์นั้นออฟไลน์

ตัวอย่างการตั้งค่า LWT ใน client (Python paho-mqtt):

import paho.mqtt.client as mqtt

client = mqtt.Client("sensor1")
client.will_set("status/sensor1/online", "offline", qos=1, retain=True)
client.connect("192.168.1.100", 1883, 60)
client.publish("status/sensor1/online", "online", qos=1, retain=True)

การเชื่อมต่ออุปกรณ์ IoT จริงกับ Mosquitto Broker

เมื่อ Broker พร้อมทำงานแล้ว ขั้นตอนต่อไปคือการเชื่อมต่ออุปกรณ์ IoT จริงเข้ากับระบบ ด้านล่างเป็นตัวอย่างการใช้งานกับอุปกรณ์ยอดนิยม

ESP8266/ESP32 กับเซ็นเซอร์อุณหภูมิ DHT22

ESP8266 และ ESP32 เป็นไมโครคอนโทรลเลอร์ยอดนิยมที่ใช้ในโปรเจกต์ IoT เนื่องจากมี WiFi ในตัวและราคาถูก ตัวอย่างโค้ด Arduino IDE สำหรับอ่านค่า DHT22 และ publish ไปยัง Mosquitto:

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

#define DHTPIN 4
#define DHTTYPE DHT22

const char* ssid = "YourWiFi";
const char* password = "YourPassword";
const char* mqtt_server = "192.168.1.100";
const char* mqtt_user = "sensor_user";
const char* mqtt_pass = "sensor_pass";

WiFiClient espClient;
PubSubClient client(espClient);
DHT dht(DHTPIN, DHTTYPE);

void setup() {
  Serial.begin(115200);
  WiFi.begin(ssid, password);
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
  client.setServer(mqtt_server, 1883);
  dht.begin();
}

void loop() {
  if (!client.connected()) {
    while (!client.connected()) {
      client.connect("ESP32_DHT22", mqtt_user, mqtt_pass);
      delay(1000);
    }
  }
  client.loop();
  
  float h = dht.readHumidity();
  float t = dht.readTemperature();
  
  if (!isnan(h) && !isnan(t)) {
    client.publish("sensor/livingroom/temperature", String(t).c_str(), true);
    client.publish("sensor/livingroom/humidity", String(h).c_str(), true);
  }
  delay(30000); // รายงานทุก 30 วินาที
}

การเชื่อมต่อกับ Home Assistant

Home Assistant เป็นแพลตฟอร์มบ้านอัจฉริยะยอดนิยมที่รองรับ MQTT โดยตรง การตั้งค่าใน configuration.yaml:

mqtt:
  broker: 192.168.1.100
  port: 1883
  username: hass_user
  password: hass_pass
  discovery: true
  discovery_prefix: homeassistant

sensor:
  - platform: mqtt
    name: "Living Room Temperature"
    state_topic: "sensor/livingroom/temperature"
    unit_of_measurement: "°C"
    device_class: temperature

  - platform: mqtt
    name: "Living Room Humidity"
    state_topic: "sensor/livingroom/humidity"
    unit_of_measurement: "%"
    device_class: humidity

เมื่อตั้งค่าเสร็จ Home Assistant จะสร้าง entity sensor ใหม่ให้โดยอัตโนมัติ และคุณสามารถนำไปใช้ใน dashboard หรือ automation ได้

การเปรียบเทียบ Mosquitto กับ MQTT Broker อื่น

แม้ว่า Mosquitto จะเป็นตัวเลือกยอดนิยม แต่ก็มี Broker อื่นๆ ที่น่าสนใจ การเลือกใช้ขึ้นอยู่กับความต้องการเฉพาะของระบบ

คุณสมบัติ	Mosquitto	EMQX	VerneMQ
ภาษาโปรแกรม	C	Erlang/OTP	Erlang/OTP
น้ำหนัก	เบามาก (~500KB)	ปานกลาง (~50MB)	ปานกลาง (~40MB)
การเชื่อมต่อสูงสุด	~10,000 (ในทางปฏิบัติ)	ล้าน+	ล้าน+
WebSocket	รองรับ (ต้องตั้งค่า)	รองรับในตัว	รองรับในตัว
Cluster	ไม่รองรับ	รองรับ	รองรับ
Bridge	รองรับ	รองรับ	รองรับ
ความง่ายในการติดตั้ง	ง่ายมาก	ปานกลาง	ปานกลาง
เหมาะสำหรับ	บ้าน, โปรเจกต์เล็ก-กลาง	องค์กร, IoT ขนาดใหญ่	ระบบที่ต้องการความทนทานสูง

สำหรับการใช้งานในบ้าน Mosquitto เป็นตัวเลือกที่เหมาะสมที่สุดเพราะติดตั้งง่าย ใช้ทรัพยากรน้อย และมีฟังก์ชันครบถ้วนสำหรับการใช้งานทั่วไป

แนวปฏิบัติที่ดีที่สุด (Best Practices) สำหรับ Mosquitto ในบ้าน

เพื่อให้ระบบ IoT ในบ้านทำงานได้อย่างมีประสิทธิภาพและปลอดภัย ควรปฏิบัติตามคำแนะนำต่อไปนี้

1. การจัดการ QoS (Quality of Service)

MQTT มี QoS 3 ระดับ:

• QoS 0 – ส่งครั้งเดียว ไม่รับประกัน (At most once) เหมาะกับข้อมูลที่ไม่สำคัญ เช่น อุณหภูมิที่อ่านทุกวินาที
• QoS 1 – ส่งอย่างน้อยหนึ่งครั้ง (At least once) เหมาะกับคำสั่งควบคุม เช่น เปิด/ปิดไฟ
• QoS 2 – ส่งเพียงครั้งเดียวแน่นอน (Exactly once) เหมาะกับข้อมูลสำคัญ เช่น การแจ้งเตือนเหตุฉุกเฉิน

ควรเลือก QoS ให้เหมาะสม เพราะ QoS สูงจะใช้แบนด์วิธและทรัพยากรมากขึ้น

2. การจำกัดขนาดข้อความ

ควรตั้งค่าขนาดข้อความสูงสุดใน mosquitto.conf เพื่อป้องกันการโจมตีแบบ buffer overflow:

# จำกัดขนาดข้อความที่ 1MB
message_size_limit 1048576

สำหรับเซ็นเซอร์ทั่วไป ข้อความควรมีขนาดไม่เกิน 1KB

3. การใช้ Bridge สำหรับระบบหลายบ้าน

หากคุณมีบ้านหลายหลังหรือต้องการเชื่อมต่อกับระบบคลาวด์ Mosquitto รองรับการทำ bridge เชื่อมต่อ Broker หลายตัว:

# ใน mosquitto.conf
connection bridge-to-cloud
address cloud.mqtt.com:8883
bridge_cafile /etc/mosquitto/certs/ca.crt
bridge_certfile /etc/mosquitto/certs/client.crt
bridge_keyfile /etc/mosquitto/certs/client.key
topic sensor/# out 2
topic command/# in 2

คำอธิบาย: topic sensor/# out 2 หมายถึงส่งข้อมูลจาก topic sensor/ ไปยัง cloud ด้วย QoS 2

4. การ Monitoring และ Logging

ควรเปิดใช้งาน logging และตรวจสอบ log เป็นประจำเพื่อหาปัญหา:

# เปิด log เฉพาะที่จำเป็น
log_dest file /var/log/mosquitto/mosquitto.log
log_type error
log_type warning
log_type notice
log_type subscribe
log_type unsubscribe

นอกจากนี้ยังสามารถใช้ $SYS topic เพื่อตรวจสอบสถานะ Broker แบบ real-time:

mosquitto_sub -h localhost -t '$SYS/#' -v

$SYS topic จะแสดงข้อมูลเช่น จำนวน client ที่เชื่อมต่อ, จำนวนข้อความที่ส่ง, เวลาที่ Broker ทำงาน ฯลฯ

5. การสำรองข้อมูลและการอัปเดต

ควรสำรองไฟล์คอนฟิกและ password file เป็นประจำ รวมถึงอัปเดต Mosquitto เป็นเวอร์ชันล่าสุดเพื่อรับแพตช์ความปลอดภัย:

sudo apt update
sudo apt upgrade mosquitto

กรณีศึกษาการใช้งานจริง (Real-World Use Cases)

เพื่อให้เห็นภาพการประยุกต์ใช้ Mosquitto ในบ้านอัจฉริยะมากขึ้น ต่อไปนี้เป็นตัวอย่างสถานการณ์จริง

กรณีศึกษา 1: ระบบตรวจสอบและควบคุมบ้านแบบครบวงจร

คุณสมชายติดตั้งระบบ IoT ในบ้านเดี่ยว 2 ชั้น ประกอบด้วย:

• เซ็นเซอร์อุณหภูมิและความชื้น 6 ตัว (ทุกห้อง)
• เซ็นเซอร์เปิด/ปิดประตู 4 ตัว
• เซ็นเซอร์ตรวจจับความเคลื่อนไหว 3 ตัว
• หลอดไฟอัจฉริยะ 12 ดวง
• ปลั๊กอัจฉริยะ 5 ตัว
• กล้อง IP 2 ตัว

เขาติดตั้ง Mosquitto บน Raspberry Pi 4 และใช้ Home Assistant เป็นศูนย์ควบคุม โดยออกแบบ topic structure ดังนี้:

# เซ็นเซอร์
home/ground/living/temp
home/ground/living/humidity
home/ground/kitchen/door
home/first/bedroom/motion

# อุปกรณ์ควบคุม
home/ground/living/light/1/set
home/ground/living/light/2/set
home/first/bedroom/plug/1/set

# สถานะ
home/ground/living/light/1/status
home/ground/living/light/2/status

ผลลัพธ์: ระบบทำงานเสถียรเป็นเวลา 6 เดือนโดยไม่มีปัญหา สามารถควบคุมไฟและตรวจสอบอุณหภูมิจากสมาร์ทโฟนได้ทุกที่

กรณีศึกษา 2: ระบบแจ้งเตือนเหตุฉุกเฉิน

คุณนภาพรติดตั้งระบบแจ้งเตือนในคอนโดมิเนียม โดยใช้ Mosquitto ร่วมกับ ESP32 และเซ็นเซอร์:

• เซ็นเซอร์ควันและแก๊สรั่วในห้องครัว
• เซ็นเซอร์น้ำรั่วใต้เครื่องซักผ้า
• เซ็นเซอร์อุณหภูมิสูงเกินไปในห้องเซิร์ฟเวอร์

เธอใช้ Last Will Testament เพื่อตรวจจับเมื่อเซ็นเซอร์เสียหรือแบตหมด:

# แต่ละเซ็นเซอร์ตั้ง LWT
client.will_set("alert/smoke/online", "offline", qos=2, retain=True)

# เมื่อเกิดเหตุฉุกเฉิน
if smoke_detected:
    client.publish("alert/smoke/alarm", "FIRE", qos=2, retain=True)
    # ส่ง LINE Notify ผ่าน Node-RED ที่ subscribe topic นี้

ระบบนี้ช่วยแจ้งเตือนผ่าน LINE ทันทีเมื่อเกิดเหตุ ทำให้เธอสามารถดำเนินการได้อย่างรวดเร็ว

กรณีศึกษา 3: ระบบรดน้ำต้นไม้อัตโนมัติ

คุณวิชัยทำสวนบนดาดฟ้าและต้องการระบบรดน้ำอัตโนมัติโดยใช้ข้อมูลสภาพอากาศ:

• เซ็นเซอร์ความชื้นดิน 4 ตัว
• โซลินอยด์วาล์ว 4 ตัว
• เซ็นเซอร์ฝนตก
• ดึงข้อมูลพยากรณ์อากาศจาก API ผ่าน Node-RED

เขาตั้งค่า Mosquitto ให้รับข้อมูลจากหลายแหล่งและประมวลผลด้วย Node-RED:

# Topic structure
garden/soil/zone1/moisture
garden/soil/zone2/moisture
garden/valve/zone1/set
garden/valve/zone1/status
garden/weather/rain_forecast

Node-RED จะ subscribe topic ความชื้นและพยากรณ์อากาศ แล้วตัดสินใจเปิด/ปิดวาล์วอย่างชาญฉลาด เช่น ถ้าฝนจะตกใน 2 ชั่วโมง ก็จะไม่รดน้ำ

การแก้ไขปัญหาที่พบบ่อย (Troubleshooting)

แม้ Mosquitto จะเสถียร แต่ก็อาจพบปัญหาได้บ้าง ต่อไปนี้เป็นปัญหาที่พบบ่อยและวิธีแก้ไข

ปัญหา: ไม่สามารถเชื่อมต่อจากอุปกรณ์อื่นในเครือข่าย

สาเหตุ: Firewall หรือ Mosquitto ตั้งค่าให้ฟังเฉพาะ localhost

วิธีแก้: ตรวจสอบไฟล์คอนฟิกว่ามี listener 1883 0.0.0.0 หรือไม่ และเปิดพอร์ต 1883 ใน firewall:

sudo ufw allow 1883/tcp

ปัญหา: ข้อความสูญหายหรือไม่ได้รับ

สาเหตุ: QoS ต่ำเกินไป หรือ client ไม่ได้ตั้งค่า clean_session

วิธีแก้: ใช้ QoS 1 หรือ 2 สำหรับข้อมูลสำคัญ และตั้งค่า clean_session=false เพื่อให้ Broker เก็บข้อความค้างไว้

ปัญหา: Broker ใช้ RAM สูงผิดปกติ

สาเหตุ: มี retained messages มากเกินไป หรือมี client ที่ publish ข้อความขนาดใหญ่บ่อยครั้ง

วิธีแก้: ตรวจสอบ retained messages ด้วยคำสั่ง:

mosquitto_sub -h localhost -t '$SYS/broker/retained messages/count' -v

และลบ retained messages ที่ไม่จำเป็นออก

ปัญหา: การเชื่อมต่อหลุดบ่อย

สาเหตุ: WiFi ไม่เสถียร หรือค่า keepalive ต่ำเกินไป

วิธีแก้: เพิ่มค่า keepalive ใน client (เช่น 60 วินาที) และใช้ LWT เพื่อตรวจจับการหลุดเชื่อมต่อ

การปรับปรุงประสิทธิภาพและการขยายระบบ

เมื่อระบบ IoT ในบ้านเติบโตขึ้น อาจต้องปรับปรุงประสิทธิภาพของ Mosquitto ให้รองรับอุปกรณ์มากขึ้น

การใช้ Bridge เพื่อกระจายโหลด

แทนที่จะใช้ Broker ตัวเดียว คุณสามารถใช้ Mosquitto bridge เพื่อเชื่อมต่อหลาย Broker เข้าด้วยกัน:

# Broker หลัก (Main)
connection bridge-to-zone1
address 192.168.1.101:1883
topic house/zone1/# both 2

# Broker ย่อย (Zone 1)
connection bridge-to-main
address 192.168.1.100:1883
topic house/zone1/# both 2

วิธีนี้ช่วยลดโหลดบน Broker หลัก และเพิ่มความน่าเชื่อถือของระบบ

การปรับแต่ง Kernel Parameters

สำหรับระบบที่มีอุปกรณ์จำนวนมาก ควรปรับแต่ง Linux kernel เพื่อรองรับการเชื่อมต่อมากขึ้น:

# เพิ่ม file descriptors
sudo sysctl -w fs.file-max=100000
sudo sysctl -w net.core.somaxconn=1024

# ทำให้ถาวรโดยเพิ่มใน /etc/sysctl.conf
echo "fs.file-max=100000" | sudo tee -a /etc/sysctl.conf
echo "net.core.somaxconn=1024" | sudo tee -a /etc/sysctl.conf

การใช้ In-Memory Persistence

สำหรับระบบที่ไม่ต้องการความคงทนของข้อมูล (เช่น ข้อมูลเซ็นเซอร์ที่อัปเดตทุกวินาที) สามารถปิด persistence เพื่อเพิ่มประสิทธิภาพ:

# ใน mosquitto.conf
persistence false
# หรือใช้ memory-only persistence
persistence_file mosquitto.db
persistence_location /dev/shm

การเก็บ persistence ใน /dev/shm (RAM disk) จะช่วยเพิ่มความเร็วในการอ่าน/เขียนอย่างมาก

ข้อควรระวังและข้อจำกัดของ Mosquitto

แม้ Mosquitto จะเป็น Broker ที่ยอดเยี่ยม แต่ก็มีข้อจำกัดบางประการที่ควรทราบ:

• ไม่มี GUI ในตัว – การจัดการทั้งหมดต้องผ่าน command line หรือใช้เครื่องมือภายนอก
• ไม่รองรับ Cluster – สำหรับระบบขนาดใหญ่ที่ต้องการความพร้อมใช้งานสูง ควรใช้ EMQX หรือ VerneMQ
• ไม่มี built-in authentication แบบ LDAP/OAuth – ต้องใช้ plugin หรือ proxy ภายนอก
• การจัดการผู้ใช้ต้อง manual – ไม่มี API สำหรับจัดการผู้ใช้แบบไดนามิก

อย่างไรก็ตาม สำหรับการใช้งานในบ้าน ข้อจำกัดเหล่านี้ไม่ใช่ปัญหาใหญ่ และ Mosquitto ยังคงเป็นตัวเลือกอันดับหนึ่ง

Summary

Mosquitto MQTT Broker เป็นซอฟต์แวร์โอเพนซอร์สที่ทรงพลังและเหมาะสมอย่างยิ่งสำหรับการเป็นศูนย์กลางการสื่อสารในระบบ IoT ในบ้าน ด้วยน้ำหนักที่เบา ติดตั้งง่าย และใช้ทรัพยากรต่ำ ทำให้สามารถรันบน Raspberry Pi หรือแม้แต่เครื่องเก่าที่ไม่ได้ใช้แล้วได้อย่างราบรื่น

จากบทความนี้ เราได้เรียนรู้ตั้งแต่การติดตั้ง การตั้งค่าพื้นฐาน การรักษาความปลอดภัยด้วย TLS/SSL และ ACL การออกแบบ topic structure ที่มีประสิทธิภาพ การเชื่อมต่ออุปกรณ์จริง การเปรียบเทียบกับ Broker อื่น แนวปฏิบัติที่ดีที่สุด และกรณีศึกษาการใช้งานจริง สิ่งสำคัญที่สุดคือการวางแผนระบบให้ดีตั้งแต่เริ่มต้น โดยเฉพาะเรื่อง