安装 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官方文档