请用python编写一个MQTT收发的程序
时间: 2023-10-19 13:07:24 浏览: 81
好的,以下是一个简单的Python程序,可以实现MQTT消息的收发:
```python
import paho.mqtt.client as mqtt
# 连接MQTT服务器
client = mqtt.Client()
client.connect("broker.hivemq.com", 1883, 60)
# 发送消息
client.publish("test/topic", "Hello World!")
# 接收消息
def on_message(client, userdata, msg):
print(msg.topic + " " + str(msg.payload))
client.on_message = on_message
client.subscribe("test/topic")
# 循环接收消息
client.loop_forever()
```
这个程序首先连接到MQTT服务器(这里使用了公共的HiveMQ服务器),然后向`test/topic`主题发送一条消息。接着,程序定义了一个`on_message`回调函数,用于处理收到的消息。最后,程序通过调用`client.loop_forever()`函数开始循环接收消息。当程序接收到`test/topic`主题的消息时,`on_message`函数将被调用,打印出收到的消息。
阅读全文