python mqtt代码示例
时间: 2024-03-14 16:41:59 浏览: 72
当然,我可以给你提供一个简单的Python MQTT代码示例。首先,你需要安装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("test/topic")
# 接收消息回调函数
def on_message(client, userdata, msg):
print(msg.topic + " " + str(msg.payload))
# 创建MQTT客户端
client = mqtt.Client()
# 设置连接成功和消息接收的回调函数
client.on_connect = on_connect
client.on_message = on_message
# 连接到MQTT代理
client.connect("mqtt.eclipse.org", 1883, 60)
# 循环监听消息
client.loop_forever()
```
上述代码中,我们使用paho-mqtt库创建了一个MQTT客户端,并设置了连接成功和消息接收的回调函数。在连接成功回调函数中,我们订阅了一个名为"test/topic"的主题。在接收消息回调函数中,我们打印出接收到的主题和消息内容。
你可以根据自己的需求修改主题名称、MQTT代理地址和端口号等参数。希望这个示例对你有所帮助!
阅读全文