python如何使用mqtt

Python使用MQTT需要安装paho-mqtt模块，并且使用MQTT客户端连接到MQTT代理服务器，可以使用如下代码实现：

import paho.mqtt.client as mqtt

# 定义回调函数，实现消息接收和处理
def on_message(client, userdata, message):
    print("Received message: ", str(message.payload.decode("utf-8")))

# 创建MQTT客户端并连接到代理服务器
client = mqtt.Client()
client.connect("broker.hivemq.com", 1883)

# 订阅主题
client.subscribe("topic/test")

# 注册回调函数
client.on_message = on_message

# 循环接收消息
client.loop_forever()

这段代码连接到了HiveMQ代理服务器，订阅了`topic/test`主题，并定义了回调函数`on_message`用于接收和处理消息。可以根据自己的需求来修改代码和配置。