python订阅mqtt

Python提供了多个库可以用于订阅MQTT（Message Queuing Telemetry Transport）消息。其中，paho-mqtt是一个常用的Python MQTT客户端库，可以用于连接和订阅MQTT消息。

下面是使用paho-mqtt库进行MQTT消息订阅的基本步骤：

1. 安装paho-mqtt库：
在终端或命令提示符中运行以下命令来安装paho-mqtt库：

   pip install paho-mqtt

2. 导入paho.mqtt.client模块：
在Python脚本中导入paho.mqtt.client模块，以便使用其中的功能。

3. 创建MQTT客户端实例：
使用paho.mqtt.client模块的Client类创建一个MQTT客户端实例。

4. 设置回调函数：
为客户端实例设置回调函数，以处理接收到的消息。

5. 连接到MQTT代理服务器：
使用客户端实例的connect()方法连接到MQTT代理服务器。

6. 订阅主题：
使用客户端实例的subscribe()方法订阅感兴趣的主题。

7. 循环监听消息：
使用客户端实例的loop_forever()方法开始循环监听消息，直到手动中断程序。

下面是一个简单的示例代码，演示了如何使用paho-mqtt库进行MQTT消息订阅：

import paho.mqtt.client as mqtt

# 回调函数，处理接收到的消息
def on_message(client, userdata, msg):
    print("Received message: " + msg.payload.decode())

# 创建MQTT客户端实例
client = mqtt.Client()

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

# 连接到MQTT代理服务器
client.connect("mqtt.example.com", 1883, 60)

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

# 循环监听消息
client.loop_forever()

请注意，上述示例中的MQTT代理服务器地址和端口号需要根据实际情况进行修改。另外，还可以根据需要设置其他参数，例如用户名、密码等。