python實(shí)現(xiàn)MQTT客戶端通信的示例代碼

更新時(shí)間：2025年12月08日 10:15:44 作者：GY_1202

本文主要介紹了python實(shí)現(xiàn)MQTT客戶端通信的示例代碼,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

MQTT協(xié)議簡(jiǎn)介

MQTT（Message Queuing Telemetry Transport）是一個(gè)輕量級(jí)的發(fā)布/訂閱消息傳輸協(xié)議，設(shè)計(jì)用于在低帶寬、不可靠的網(wǎng)絡(luò)環(huán)境中進(jìn)行遠(yuǎn)程位置設(shè)備間的通信。它使用發(fā)布/訂閱的消息模式，提供了三種消息服務(wù)質(zhì)量（QoS）級(jí)別，并允許消息代理（broker）進(jìn)行消息的持久化存儲(chǔ)，從而確保消息的可靠傳輸。MQTT協(xié)議廣泛應(yīng)用于物聯(lián)網(wǎng)（IoT）領(lǐng)域，因?yàn)樗哂虚_銷小、協(xié)議簡(jiǎn)單、易于實(shí)現(xiàn)等特點(diǎn)。

下面使用Python和paho-mqtt庫(kù)編寫了一個(gè)MQTT客戶端代碼示例。

MQTT客戶端

import paho.mqtt.client as mqtt  
import time  
  
# MQTT服務(wù)器地址  
broker_address = "localhost"  # 替換為你的MQTT代理地址  
port = 1883  # MQTT代理的端口，默認(rèn)為1883  
client_id = "python_mqtt_client"  # MQTT客戶端的唯一ID  
topic = "test/topic"  # 要發(fā)布和訂閱的主題  
username = "your_username"  # MQTT代理的用戶名  
password = "your_password"  # MQTT代理的密碼  
  
# 當(dāng)連接到MQTT代理時(shí)調(diào)用的回調(diào)函數(shù)  
def on_connect(client, userdata, flags, rc):  
    print(f"Connected with result code {rc}")  
    # 訂閱主題  
    client.subscribe(topic)  
  
# 當(dāng)接收到MQTT消息時(shí)調(diào)用的回調(diào)函數(shù)  
def on_message(client, userdata, msg):  
    print(f"Received message '{msg.payload.decode('utf-8')}' on topic '{msg.topic}' with QoS {msg.qos}")  
  
# 創(chuàng)建MQTT客戶端實(shí)例  
client = mqtt.Client(client_id)  
  
# 設(shè)置用戶名和密碼  
client.username_pw_set(username, password)  
  
# 為客戶端設(shè)置回調(diào)函數(shù)  
client.on_connect = on_connect  
client.on_message = on_message  
  
# 連接到MQTT代理  
client.connect(broker_address, port)  
  
# 開始網(wǎng)絡(luò)循環(huán)，處理接收到的消息和重連  
client.loop_start()  
  
try:  
    print("Publishing message...")  
    # 發(fā)布一條消息  
    client.publish(topic, "Hello, MQTT with username and password!", qos=1)  
      
    # 等待用戶輸入，以保持程序運(yùn)行并接收消息  
    print("Press Enter to exit...")  
    input()  
except KeyboardInterrupt:  
    pass  
finally:  
    # 停止網(wǎng)絡(luò)循環(huán)并斷開連接  
    client.loop_stop()  
    client.disconnect()  
    print("Disconnected from MQTT broker.")

導(dǎo)入所需庫(kù)：導(dǎo)入paho.mqtt.client模塊，以便使用其提供的MQTT客戶端類。
設(shè)置MQTT代理信息：設(shè)置MQTT代理的地址、端口、客戶端ID、主題、用戶名和密碼。
定義回調(diào)函數(shù)：
on_connect：當(dāng)客戶端成功連接到MQTT代理時(shí)調(diào)用。在這個(gè)函數(shù)中，我們訂閱了指定的主題。
on_message：當(dāng)客戶端接收到MQTT消息時(shí)調(diào)用。在這個(gè)函數(shù)中，我們打印出接收到的消息內(nèi)容。
創(chuàng)建MQTT客戶端實(shí)例：使用指定的客戶端ID創(chuàng)建一個(gè)MQTT客戶端實(shí)例。
設(shè)置用戶名和密碼：使用username_pw_set方法設(shè)置用于連接到MQTT代理的用戶名和密碼。
設(shè)置回調(diào)函數(shù)：將之前定義的回調(diào)函數(shù)綁定到客戶端實(shí)例上。
連接到MQTT代理：使用connect方法連接到MQTT代理。
啟動(dòng)網(wǎng)絡(luò)循環(huán)：使用loop_start方法啟動(dòng)一個(gè)獨(dú)立的線程來(lái)處理網(wǎng)絡(luò)連接和消息傳遞。
發(fā)布消息：使用publish方法發(fā)布一條消息到指定的主題。
等待用戶輸入：使用input函數(shù)等待用戶輸入，以保持程序運(yùn)行并接收消息。
清理資源：在用戶輸入或接收到中斷信號(hào)時(shí)，停止網(wǎng)絡(luò)循環(huán)，斷開與MQTT代理的連接，并打印斷開連接的消息。