一、MQTT協議簡介

MQTT（Message Queuing Telemetry Transport）是一種基于發布-訂閱模式的輕量級消息傳輸協議，專為低帶寬、高延遲、不穩定網絡的物聯網場景設計。由IBM于1999年創建，現由OASIS標準組織維護，已成為物聯網設備通信的事實標準。

二、核心概念

1. 通信角色

2. 主題（Topic）

• 格式：層級式字符串，用/分隔（例：home/living_room/temperature）

• 通配符：

• +：單層匹配（home/+/temperature匹配home/kitchen/temperature）

• #：多層匹配（home/#匹配home/living_room/light/status）

3. QoS（服務質量等級）

三、協議工作流程

訂閱者代理發布者訂閱者代理發布者訂閱主題"factory/machine1/temp"發布消息到"factory/machine1/temp" (QoS1)轉發消息 (QoS1確認)發送PUBACK確認發送PUBACK確認

四、核心優勢

五、典型應用場景

1. 智慧農業

• 場景：田間傳感器通過MQTT上報土壤濕度，觸發灌溉系統

• 主題設計：
  farm/zoneA/moisture（數據上報）
  farm/zoneA/pump/control（水泵控制）

2. 車聯網

• 場景：電動汽車實時上報電池狀態，云端下發充電策略

• 消息示例：

  JSON{  "vehicle_id": "CN-2023-EV001",  "soc": 65,  "timestamp": 1689321600}

3. 工業4.0

• 架構：

  TEXT車間PLC → MQTT代理 → 云端SCADA系統 → 手機運維APP

• 優勢：解決OT與IT系統協議不互通問題

六、快速入門指南

1. 環境搭建

BASH# 安裝Mosquitto代理（Linux）sudo apt-get install mosquitto mosquitto-clients# 啟動服務systemctl start mosquitto

2. 命令行測試

BASH# 終端1：訂閱主題mosquitto_sub -t "test/topic" -v# 終端2：發布消息mosquitto_pub -t "test/topic" -m "Hello MQTT!"

3. Python代碼示例

PYTHONimport paho.mqtt.client as mqttdef on_connect(client, userdata, flags, rc):    print("Connected with code:", rc)    client.subscribe("home/#")def on_message(client, userdata, msg):    print(f"Received: {msg.topic} → {msg.payload.decode()}")client = mqtt.Client()client.on_connect = on_connectclient.on_message = on_messageclient.connect("broker.hivemq.com", 1883, 60)client.loop_forever()

七、安全機制

1. 認證授權

• 用戶名/密碼：明文或加密傳輸

• SSL/TLS：加密通信通道（端口8883）

• ACL（訪問控制列表）：限制設備可發布/訂閱的主題

2. 高級特性

• 遺囑消息（LWT）：設備異常離線時自動發布預設消息

• 保留消息（Retained）：新訂閱者立即獲取最后一條有效數據

八、生態工具推薦

MQTT如同物聯網設備的“通用語言”，掌握其核心機制，即可構建高效可靠的物聯系統。從智慧家居到工業4.0，萬物互聯的基石在此刻奠定！