root
/
agri
2
0
Fork 0
Code Issues Pull Requests Packages Projects 1 Releases Wiki Activity

mqtt基础功能

feasure
xce 2026-01-17 01:17:19 +08:00
parent 8c2eebbf55
commit 814cad45cd
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
agri-framework/src/main/java/com/agri/framework/interceptor/MqttMessageHandler.java
View File

@ -196,7 +196,7 @@ public class MqttMessageHandler implements SmartLifecycle {
private void handleMessage(String topic, String payload) { private void handleMessage(String topic, String payload) {
try { try {
// 优化：替换System.out为log.info // 优化：替换System.out为log.info
log.info("【MQTT接收】topic={}, payload={}", topic, payload); // log.info("【MQTT接收】topic={}, payload={}", topic, payload);
// 设备状态主题：dtu/{deviceId}/up // 设备状态主题：dtu/{deviceId}/up
if (topic.matches("dtu/\\w+/up")) { if (topic.matches("dtu/\\w+/up")) {
@ -272,11 +272,11 @@ public class MqttMessageHandler implements SmartLifecycle {
// 发布消息 // 发布消息
mqttMessageSender.publish(frontendTopic, payload); mqttMessageSender.publish(frontendTopic, payload);
// 优化：替换System.out为log.info // 优化：替换System.out为log.info
log.info("【设备状态转发】设备{} → 前端{}，主题：{}", deviceId, clientId, frontendTopic); // log.info("【设备状态转发】设备{} → 前端{}，主题：{}", deviceId, clientId, frontendTopic);
} }
} else { } else {
// 优化：替换System.out为log.info // 优化：替换System.out为log.info
log.info("【设备状态转发】设备{}无订阅前端，跳过转发", deviceId); // log.info("【设备状态转发】设备{}无订阅前端，跳过转发", deviceId);
} }
// } // }
} }