MQTT代码编写
时间: 2023-07-01 18:19:10 浏览: 30
下面是一个简单的Python MQTT代码示例:
```python
import paho.mqtt.client as mqtt
# 定义回调函数
def on_connect(client, userdata, flags, rc):
print("Connected with result code "+str(rc))
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.subscribe("test/topic")
# 发布消息
client.publish("test/topic", "Hello World!")
# 保持客户端运行
client.loop_forever()
```
这个示例使用Paho MQTT客户端库连接到一个公共MQTT代理服务器,并订阅了主题“test/topic”。当有消息发布到该主题时,会调用`on_message`回调函数来处理消息。同时,代码还使用`client.publish`方法来发布一条消息到该主题。最后,`client.loop_forever`方法保持客户端运行以等待消息的到来。