MQTT代码
时间: 2023-07-01 22:12:45 浏览: 45
好的,以下是一个使用 Python 实现 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("broker.hivemq.com", 1883, 60)
# 循环处理网络流量和回调函数
client.loop_forever()
```
这段代码中使用了 Paho MQTT 客户端库,它是一个流行的 MQTT 客户端实现。在代码中,首先定义了连接成功和接收消息的回调函数,然后创建了一个 MQTT 客户端并设置回调函数。接着,使用 `connect()` 方法连接到 MQTT 代理服务器,最后使用 `loop_forever()` 方法循环处理网络流量和回调函数。当客户端接收到指定主题的消息时,会调用 `on_message()` 回调函数并打印接收到的消息。