From 45bb5af901389e4d4d01913c1eaa97c93b0e24b4 Mon Sep 17 00:00:00 2001 From: zhuangtianxiang <2913129173@qq.com> Date: Tue, 4 Mar 2025 19:23:56 +0800 Subject: [PATCH] =?UTF-8?q?fix:=E6=9B=BF=E6=8D=A2=20MQTT=20=E4=B8=BB?= =?UTF-8?q?=E9=A2=98=E7=A1=AC=E7=BC=96=E7=A0=81=E4=B8=BA=E5=8A=A8=E6=80=81?= =?UTF-8?q?=E7=94=9F=E6=88=90?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit -将硬编码的 MQTT 主题替换为根据设备客户端 ID 动态生成的主题 - 新的主题格式为：/r1/devices/{clientId}/datas - 此修改提高了代码的灵活性和可维护性 --- .../modules/iot/device/service/impl/DeviceServiceImpl.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/zsc/edu/gateway/modules/iot/device/service/impl/DeviceServiceImpl.java b/src/main/java/com/zsc/edu/gateway/modules/iot/device/service/impl/DeviceServiceImpl.java index 979c233..6a9da1f 100644 --- a/src/main/java/com/zsc/edu/gateway/modules/iot/device/service/impl/DeviceServiceImpl.java +++ b/src/main/java/com/zsc/edu/gateway/modules/iot/device/service/impl/DeviceServiceImpl.java @@ -229,9 +229,9 @@ public class DeviceServiceImpl extends ServiceImpl imp payloadJson.put("paras", paras); payloadJson.put("msgType", "cloudReq"); String payload = payloadJson.toString(); - //TODO 占位符用clientID拼接 + String topic = "/r1/devices/" + device.getClientId() + "/datas"; try { - mqttSender.sendMsg(mqttConfig.getTopic(), qos, payload); + mqttSender.sendMsg(topic, qos, payload); } catch (Exception e) { throw new JSONException("发送失败"); }