From 0ed60db853e1d1829add001e8e84ad8a97644200 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E4=B8=8D=E6=B1=82=E5=9C=A3=E5=89=91?=
 <suyulingxm@hotmail.com>
Date: Tue, 14 Oct 2025 15:06:48 +0800
Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0=20MQTT=20=E4=B8=BB=E9=A2=98?=
 =?UTF-8?q?=E4=B8=BA=20device/data=20=E5=92=8C=20device/data-get=EF=BC=8C?=
 =?UTF-8?q?=E8=B0=83=E6=95=B4=E7=9B=B8=E5=85=B3=E8=AE=A2=E9=98=85=E5=92=8C?=
 =?UTF-8?q?=E6=B6=88=E6=81=AF=E5=A4=84=E7=90=86=E9=80=BB=E8=BE=91=EF=BC=8C?=
 =?UTF-8?q?=E7=A1=AE=E4=BF=9D=E4=B8=80=E8=87=B4=E6=80=A7=E5=92=8C=E6=B8=85?=
 =?UTF-8?q?=E6=99=B0=E5=BA=A6=E3=80=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 data_transmission_example.py | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

diff --git a/data_transmission_example.py b/data_transmission_example.py
index e3dea58..6472287 100644
--- a/data_transmission_example.py
+++ b/data_transmission_example.py
@@ -29,14 +29,14 @@ class DataTransmissionExample:
         if rc == 0:
             print("✅ 连接到 MQTT 代理成功")
             # 订阅数据获取请求主题
-            client.subscribe("/data/data-get")
-            print("✅ 订阅 /data/data-get 主题成功")
+            client.subscribe("device/data-get")
+            print("✅ 订阅 device/data-get 主题成功")
         else:
             print(f"❌ 连接 MQTT 代理失败，错误码: {rc}")
     
     def on_message(self, client, userdata, msg):
         """MQTT 消息接收回调"""
-        if msg.topic == "/data/data-get":
+        if msg.topic == "device/data-get":
             print(f"📨 收到数据请求: {msg.payload.decode()}")
             # 模拟处理时间
             time.sleep(0.1)
@@ -94,12 +94,12 @@ class DataTransmissionExample:
         # 转换为 JSON 格式
         json_data = json.dumps(data, ensure_ascii=False, indent=2)
         
-        # 发布到 /device/data 主题
-        result = self.client.publish("/device/data", json_data)
+        # 发布到 device/data 主题
+        result = self.client.publish("device/data", json_data)
         
         if result.rc == mqtt.MQTT_ERR_SUCCESS:
             print("📤 发送设备数据:")
-            print(f"   主题: /device/data")
+            print(f"   主题: device/data")
             print(f"   数据: {json_data}")
             print()
         else:
@@ -155,8 +155,8 @@ def main():
     print("🏠 Energy Monitor 数据传输示例")
     print("=" * 50)
     print("这个示例演示了以下功能：")
-    print("1. 监听 /data/data-get 请求")
-    print("2. 响应请求并发送设备数据到 /device/data")
+    print("1. 监听 device/data-get 请求")
+    print("2. 响应请求并发送设备数据到 device/data")
     print("3. 模拟真实的能源监控数据")
     print("4. 每秒5次的数据获取频率（由 Home Assistant 集成触发）")
     print()