【代码收藏夹·Python】使用paho连接MQTT

安装 paho

Paho 是一个开源的 MQTT 客户端库，使用前需要先使用 pip 安装。

pip install paho-mqtt -i https://pypi.tuna.tsinghua.edu.cn/simple/

使用

import paho.mqtt.client as mqtt
import time# MQTT服务器配置
broker = "test.mosquitto.org"  # 公共测试服务器
port = 1883
topic = "test/topic/cloudsir"# 连接回调
def on_connect(client, userdata, flags, reason_code, properties):print("连接结果: " + str(reason_code))client.subscribe(topic)client.publish(topic, "Hello MQTT", qos=1, retain=False)# 接收到消息的回调
def on_message(client, userdata, msg):print(f"收到消息: {msg.topic} -> {msg.payload.decode()}")# 创建客户端实例
client = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2, client_id="test-client")# 设置账户名和密码
# client.username_pw_set("your_username", "your_password")# 绑定回调函数
client.on_connect = on_connect
client.on_message = on_message# 连接
client.connect(broker, port, keepalive=60)# 启动后台消息循环线程
client.loop_start()# 50s后关闭连接
time.sleep(60)
client.loop_stop()
client.disconnect()

参考资料

• paho-mqtt-python官方文档