diff --git a/src/main/java/com/ruoyi/device/domain/impl/machine/mqtt/MqttCallbackRegistry.java b/src/main/java/com/ruoyi/device/domain/impl/machine/mqtt/MqttCallbackRegistry.java index 7cd545c..e3f319c 100644 --- a/src/main/java/com/ruoyi/device/domain/impl/machine/mqtt/MqttCallbackRegistry.java +++ b/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 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; }