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 e4ef9d1..396ae47 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 @@ -575,11 +575,9 @@ public class MqttMessageHandler implements SmartLifecycle { public void start() { log.info("开始监听"); if (isRunning.compareAndSet(false, true)) { - log.info("开始监听111"); try { // 核心修改:无论是否已连接,都执行订阅(设置回调+订阅主题) // 移除原有的if (!mqttClient.isConnected()) 判断 - log.info("开始监听222"); subscribeTopics(); log.info("【MQTT生命周期】客户端启动成功(已设置回调+订阅主题)"); } catch (MqttException e) {