diff --git a/agri-framework/src/main/java/com/agri/framework/web/dispatcher/MqttMessageDispatcher.java b/agri-framework/src/main/java/com/agri/framework/web/dispatcher/MqttMessageDispatcher.java index 1f83c80..e22d38a 100644 --- a/agri-framework/src/main/java/com/agri/framework/web/dispatcher/MqttMessageDispatcher.java +++ b/agri-framework/src/main/java/com/agri/framework/web/dispatcher/MqttMessageDispatcher.java @@ -60,7 +60,7 @@ public class MqttMessageDispatcher { // log.info("【MQTT接收】topic={}, payload={}", topic, payload); // 设备状态主题:dtu/{deviceId}/up - if (topic.matches("dtu/\\w+/\\w")) { + if (topic.matches("dtu/\\w+/\\w+")) { deviceStatusHandler.handle(topic, payload); } // 处理前端控制指令主题:frontend/{clientId}/control/{deviceId}