使用python订阅mqtt
时间: 2023-07-21 12:06:52 浏览: 107
Biblioteca de Processamento e Visualização de Dados IoT em Tempo
你可以使用 Paho MQTT 库来订阅 MQTT 消息。首先,你需要安装 Paho MQTT 库,可以使用以下命令:
```
pip install paho-mqtt
```
下面是一个简单的例子,展示了如何使用 Python 订阅 MQTT 消息:
```python
import paho.mqtt.client as mqtt
# 定义回调函数,在接收到消息时执行
def on_message(client, userdata, msg):
print(f"收到消息: {msg.topic} {msg.payload.decode()}")
# 创建 MQTT 客户端对象
client = mqtt.Client()
# 设置回调函数
client.on_message = on_message
# 连接到 MQTT 代理服务器
broker = "mqtt.eclipse.org" # 代理服务器地址
port = 1883 # 代理服务器端口
client.connect(broker, port)
# 订阅主题
topic = "your/topic" # 指定你要订阅的主题
client.subscribe(topic)
# 开始循环,保持连接
client.loop_forever()
```
在代码中,你需要替换 `broker` 变量的值为你实际使用的 MQTT 代理服务器地址。然后,指定你要订阅的主题,将其赋值给 `topic` 变量。
当运行这段代码时,它将连接到 MQTT 代理服务器并订阅指定的主题。当有消息发布到该主题时,`on_message` 回调函数将被触发,并打印收到的消息。
希望这可以帮助到你!如果你有任何问题,可以继续问我。
阅读全文