mqtt传输json数据代码
时间: 2023-08-06 21:24:24 浏览: 295
mqtt通信协议实现代码
4星 · 用户满意度95%
以下是使用 Python paho-mqtt 库发送 JSON 数据的示例代码:
```python
import paho.mqtt.client as mqtt
import json
# 定义 MQTT 服务器和主题
MQTT_BROKER = "mqtt.eclipseprojects.io"
MQTT_TOPIC = "test/json"
# 定义 JSON 数据
data = {
"name": "Alice",
"age": 25,
"gender": "female"
}
payload = json.dumps(data)
# 连接到 MQTT 服务器
client = mqtt.Client()
client.connect(MQTT_BROKER, 1883)
# 发布 JSON 数据
client.publish(MQTT_TOPIC, payload)
# 断开连接
client.disconnect()
```
在上述代码中,我们首先定义了 MQTT 服务器的地址和主题。然后,我们创建了一个包含 JSON 数据的字典,并将其序列化为 JSON 字符串。接着,我们连接到 MQTT 服务器,通过 `client.publish()` 方法发布 JSON 数据。最后,我们断开了与 MQTT 服务器的连接。
接收 JSON 数据的代码类似,只需要在 MQTT 订阅的回调函数中对接收到的 payload 进行反序列化即可。
阅读全文