diff --git a/agri-framework/src/main/java/com/agri/framework/interceptor/MqttMessageHandler.java b/agri-framework/src/main/java/com/agri/framework/interceptor/MqttMessageHandler.java index 0b20ffb..46295d1 100644 --- a/agri-framework/src/main/java/com/agri/framework/interceptor/MqttMessageHandler.java +++ b/agri-framework/src/main/java/com/agri/framework/interceptor/MqttMessageHandler.java @@ -177,6 +177,7 @@ public class MqttMessageHandler implements SmartLifecycle { /** * 消息分发处理:根据主题类型路由到不同处理方法\仅处理设备状态、前端控制指令 + * 可以监听到设备传过来的业务数据 以及前端传过来的控制设备指令 * @param topic 消息主题 * @param payload 消息内容(JSON字符串) */ @@ -307,16 +308,16 @@ public class MqttMessageHandler implements SmartLifecycle { log.info("【订阅管理】前端{}订阅设备{}成功", clientId, deviceId); // 推送设备最新状态(可选) - String latestStatus = stringRedisTemplate.opsForValue().get("device:latest:" + deviceId); - if (latestStatus != null) { - String frontendTopic = "frontend/" + clientId + "/dtu/" + deviceId + "/up"; - try { - mqttMessageSender.publish(frontendTopic, latestStatus); - } catch (MqttException e) { - // 优化:替换System.err为log.error - log.error("【订阅推送】设备{}状态推送失败", deviceId, e); - } - } + // String latestStatus = stringRedisTemplate.opsForValue().get("device:latest:" + deviceId); + // if (latestStatus != null) { + // String frontendTopic = "frontend/" + clientId + "/dtu/" + deviceId + "/up"; + // try { + // mqttMessageSender.publish(frontendTopic, latestStatus); + // } catch (MqttException e) { + // // 优化:替换System.err为log.error + // log.error("【订阅推送】设备{}状态推送失败", deviceId, e); + // } + // } } /**