xx

src/main/java/com/ruoyi/device/domain/impl/machine/mqtt/MqttCallbackRegistry.java

@@ -155,7 +155,17 @@ public class MqttCallbackRegistry {
     public void handleMessage(String topic, Object messageBody) {
         // 1. 从存储层获取所有等待该 topic 的回调信息
         List<MqttCallbackInfo> callbacks = callbackStore.getCallbacksByTopic(topic);
+
+        // 如果是 confirm 消息，打印详细日志
+        if (topic.contains("/control/confirm")) {
+            log.info("【MqttCallbackRegistry】处理confirm消息: topic={}, callbackCount={}, messageBody={}",
+                topic, callbacks.size(), messageBody);
+        }
+
         if (callbacks.isEmpty()) {
+            if (topic.contains("/control/confirm")) {
+                log.warn("【MqttCallbackRegistry】没有找到匹配的回调: topic={}", topic);
+            }
             return;
         }