python接收mqtt

在Python中，您可以使用paho-mqtt库来接收MQTT消息。下面是一个简单的例子，演示如何订阅一个主题并接收消息：

import paho.mqtt.client as mqtt

# 定义回调函数，处理收到的消息
def on_message(client, userdata, message):
    print("收到主题为'{}'的消息：{}".format(message.topic, str(message.payload.decode("utf-8"))))

# 创建MQTT客户端对象
client = mqtt.Client()

# 设置回调函数
client.on_message = on_message

# 连接到MQTT代理服务器
client.connect("broker.hivemq.com", 1883)

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

# 开始循环，等待消息
client.loop_forever()

在这个例子中，我们定义了一个回调函数on_message来处理收到的MQTT消息。然后我们创建了一个MQTT客户端对象，并设置了回调函数。接下来，我们连接到MQTT代理服务器，并订阅了一个主题。最后，我们开始循环，等待消息的到来。

当我们运行这个程序后，它将一直运行，等待收到来自test/topic主题的消息。当有消息到来时，它将执行回调函数on_message，并将消息的主题和内容打印出来。