线程池 改写

device-service-infrastructure/src/main/java/com/hfln/device/infrastructure/config/TopicDealExecutor.java

@@ -16,7 +16,7 @@ public class TopicDealExecutor {
     private final KeyAffinityExecutor executor = KeyAffinityExecutor.newSerializingExecutor(
             PARALLELISM,
             QUEUE_SIZE,
-            "TopicSub-%d"
+            "mqtt_sub-"
     );
 
     public void submitTask(Object key, ThrowableRunnable<Exception> task) {

device-service-infrastructure/src/main/java/com/hfln/device/infrastructure/mqtt/handler/DeviceMessageHandler.java

@@ -77,7 +77,7 @@ public class DeviceMessageHandler {
                 return;
             }
 
-//            log.debug("Received device message: topic={}, payload={}", topic, payload);
+            log.debug("Received device message: topic={}, payload={}", topic, payload);
 
             // 根据主题路由到不同的处理方法
             // 提取主题的操作部分（最后一段）

device-service-server/src/main/resources/logback-spring.xml

@@ -71,7 +71,7 @@
     <logger name="sun.rmi" level="ERROR"/>
     <logger name="sun.net" level="ERROR"/>
     <logger name="javax" level="ERROR"/>
-    <logger name="com.hfln" level="DEBUG"/>
+    <logger name="com.hfln" level="info"/>
     <!--<logger name="com.xxl" level="ERROR"/>-->
     <logger name="org.mongodb.driver" level="ERROR"/>