使用python订阅mqtt
时间: 2023-07-21 13:06:52 浏览: 66
要使用Python订阅MQTT,你可以使用paho-mqtt库。首先,确保你已经安装了paho-mqtt库。可以通过以下命令来安装它:
```shell
pip install paho-mqtt
```
接下来,你可以使用以下代码来订阅MQTT主题:
```python
import paho.mqtt.client as mqtt
def on_connect(client, userdata, flags, rc):
print("Connected with result code " + str(rc))
client.subscribe("your/topic")
def on_message(client, userdata, msg):
print(msg.topic + " " + str(msg.payload))
client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message
client.connect("mqtt.broker.com", 1883, 60)
client.loop_forever()
```
在上面的代码中,你需要修改以下部分:
- 在`on_connect`函数中,你可以执行一些与连接相关的操作。例如,打印连接结果或订阅其他主题。
- 在`on_message`函数中,你可以处理接收到的消息。在这个例子中,我们只是简单地打印主题和消息的内容。
- 在`client.connect`函数中,指定MQTT代理服务器的地址和端口号。
运行上述代码后,它将连接到指定的MQTT代理服务器,并订阅名为"your/topic"的主题。当有消息发布到该主题时,`on_message`函数将被调用并打印出消息的内容。
请记得根据你的实际情况修改代码中的参数,包括主题、MQTT代理服务器地址和端口号。
阅读全文