paho-mqtt实现python订阅mqtt的信息
时间: 2023-08-17 14:04:45 浏览: 129
要使用paho-mqtt库来订阅MQTT消息,首先需要安装它。可以使用以下命令使用pip安装paho-mqtt:
```
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("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 address", 1883, 60) # 连接到MQTT代理
client.loop_forever() # 持续监听消息
```
在代码中,首先定义了`on_connect`和`on_message`回调函数来处理连接和接收消息的事件。在`on_connect`回调中,可以指定订阅的主题。在`on_message`回调中,可以处理接收到的消息。
然后创建了一个MQTT客户端对象,并将回调函数与其关联。接下来,使用`connect`方法连接到MQTT代理,并调用`loop_forever`方法来持续监听消息。
请注意,你需要将"mqtt broker address"替换为实际的MQTT代理地址。另外,你还可以根据需要在代码中进行其他自定义配置。
阅读全文