在Python中实现MQTT订阅,你可以使用`paho-mqtt`库。以下是使用`paho-mqtt`进行MQTT订阅的基本步骤:
1. 安装`paho-mqtt`库:
```bash
pip install paho-mqtt
2. 编写Python代码实现订阅功能:
```python
import paho.mqtt.client as mqtt
定义回调函数,当连接成功时触发
def on_connect(client, userdata, flags, rc):
if rc == 0:
print("Connected to MQTT Broker!")
订阅主题
client.subscribe("your/topic")
创建MQTT客户端实例
client = mqtt.Client()
绑定回调函数
client.on_connect = on_connect
连接到MQTT代理
client.connect("your_broker_ip", 1883, 60)
开始循环,处理网络流量、自动重连等
client.loop_forever()
在上面的代码中,你需要将`your_broker_ip`替换为你的MQTT代理的IP地址,将`your/topic`替换为你想要订阅的主题。
运行这段代码后,你的Python程序将会连接到MQTT代理,并在连接成功后订阅指定的主题。当有消息发布到这个主题时,你的回调函数`on_connect`会被触发,并打印出接收到的消息内容。