引言

MQTT（消息隊列遙測傳輸）是一種輕量級消息協(xié)議，專為低帶寬、高延遲和不可靠的網(wǎng)絡環(huán)境設計。它廣泛應用于物聯(lián)網(wǎng)（IoT）應用、消息系統(tǒng)以及實時數(shù)據(jù)通信領域。

本指南深入探討了 MQTT 的工作原理，解釋了其關鍵組件，并演示了如何使用 Python 實現(xiàn) MQTT 客戶端。

MQTT 代理

MQTT 系統(tǒng)的核心是代理，它負責管理客戶端之間的消息交換。

MQTT 中的客戶端

發(fā)布者（Publishers）：向特定主題發(fā)送消息的設備或應用程序。

訂閱者（Subscribers）：監(jiān)聽這些主題上的消息的設備或應用程序。

代理確保發(fā)布者的消息能夠可靠地傳遞給相應的訂閱者。

運行本地 MQTT 代理

在本示例中，代理托管在本地（127.0.0.1），這意味著它與 MQTT 客戶端運行在同一臺機器上。

代理在 Docker 容器中運行，使用 Mosquitto MQTT 代理，并映射到 1883 端口。mosquitto.conf 文件用于配置，允許消息保留和持久化。

MQTT 代理的工作原理

1.代理在 1883 端口監(jiān)聽傳入消息。

2.客戶端連接到代理。

3.客戶端向特定主題發(fā)布消息。

4.代理接收并處理消息。

5.代理將消息轉發(fā)給所有訂閱該主題的客戶端。

發(fā)布者和訂閱者

發(fā)布者

發(fā)布者向特定主題發(fā)送消息，代理隨后將這些消息分發(fā)給感興趣的客戶端。

訂閱者

訂閱者監(jiān)聽特定主題上的消息，并在收到消息時進行處理。

在 Python 中創(chuàng)建 MQTT 客戶端

Python 中的 Paho MQTT 庫允許創(chuàng)建可以發(fā)布和訂閱消息的 MQTT 客戶端。

創(chuàng)建 MQTT 客戶端

importpaho.mqtt.clientasmqttmqtt_client_1 = mqtt.Client( callback_api_version=mqtt.CallbackAPIVersion.VERSION2, client_id="myClient1", clean_session=True, userdata="Client 1", protocol=mqtt.MQTTv311, transport="tcp")

參數(shù)解釋

client_id="myClient1" → 為客戶端分配一個唯一標識符。

clean_session=True → 如果為 True，客戶端斷開連接時不會存儲會話數(shù)據(jù)。

protocol=mqtt.MQTTv311 → 指定 MQTT 版本為 3.1.1。

transport="tcp" → 使用 TCP 連接（也可以使用 WebSocket）。

連接到代理

mqtt_client_1.connect("127.0.0.1", port=1883, keepalive=240)

向主題發(fā)布消息

mqtt_client_1.publish("robotcell1/temperature", payload=25)

這將向主題 robotcell1/temperature 發(fā)送一條消息（25）。任何訂閱該主題的客戶端將立即收到此消息。

保留消息與非保留消息

保留消息（retain=True）

保留消息會持久化存儲在代理上，確保新訂閱者能立即收到最后一條消息。

mqtt_client_1.publish("robotcell1/temperature", payload=666, retain=True)

非保留消息（retain=False）

非保留消息僅在發(fā)送時被活動訂閱者接收。

服務質量（QoS）級別

MQTT 支持三種消息傳遞保證級別：

+-----------+-----------------------------------+| QOS | Guarantee |+-----------+-----------------------------------+| 0 | At most once (fire and forget) || 1 | At least once (may be duplicated) || 2 | Exactly once (highest reliability)|+-----------+-----------------------------------+

訂閱主題

all_messages = []defon_message(client, userdata, msg): print(f"Client:{userdata}| Topic:{msg.topic}| Message:{msg.payload}| Retained:{msg.retain}") all_messages.append(msg)mqtt_client_2 = mqtt.Client()mqtt_client_2.on_message = on_messagemqtt_client_2.connect("127.0.0.1", port=1883, keepalive=240)mqtt_client_2.subscribe("robotcell1/temperature", qos=0)mqtt_client_2.loop_start()

持久會話

默認情況下，當 MQTT 客戶端斷開連接時，它會丟失所有訂閱。如果 clean_session=False，代理會記住：

客戶端的訂閱。

客戶端錯過的任何 QoS 1 或 2 消息。

mqtt_client_1= mqtt.Client(client_id="myClient1", clean_session=False)

結論

MQTT 是一種強大且輕量級的實時消息協(xié)議。通過利用發(fā)布者、訂閱者、代理、QoS 級別和保留消息，您可以構建一個適用于物聯(lián)網(wǎng)及其他領域的健壯消息系統(tǒng)。

原文地址：

https://medium.com/@loughliam/mastering-mqtt-a-guide-to-message-queuing-telemetry-transport-289c74b70777