项目初始化

src/main/java/com/qyft/ms/system/core/client/DeviceTcpClient.java

@@ -109,7 +109,7 @@ public class DeviceTcpClient {
      */
     public boolean send(String request) {
         if (channel != null && channel.isActive()) {
-            log.info("发送设备TCP指令：{}", request);
+            log.info("向设备发送TCP指令：{}", request);
             channel.writeAndFlush(Unpooled.copiedBuffer(request, CharsetUtil.UTF_8));
             return true;
         } else {
@@ -123,7 +123,7 @@ public class DeviceTcpClient {
      */
     @PreDestroy
     private void shutdown() {
-        log.info("正在关闭 TCP 客户端...");
+        log.info("正在关闭设备TCP客户端...");
         group.shutdownGracefully();
     }
 }

src/main/java/com/qyft/ms/system/core/handler/DeviceMessageHandler.java

@@ -14,7 +14,7 @@ public class DeviceMessageHandler extends ChannelInboundHandlerAdapter {
     @Override
     public void channelRead(ChannelHandlerContext ctx, Object msg) {
         if (!(msg instanceof ByteBuf buf)) {
-            log.warn("收到未知类型的消息：{}", msg.getClass());
+            log.warn("设备TCP链接收到未知类型的消息：{}", msg.getClass());
             return;
         }
         try {
@@ -26,7 +26,7 @@ public class DeviceMessageHandler extends ChannelInboundHandlerAdapter {
             Integer cmdId = payload.getInt("cmdId");
 
         } catch (Exception e) {
-            log.error("TCP服务消息处理错误: {}, error: {}", buf.toString(CharsetUtil.UTF_8), e.getMessage(), e);
+            log.error("设备TCP链接消息处理错误: {}, error: {}", buf.toString(CharsetUtil.UTF_8), e.getMessage(), e);
         } finally {
             buf.release();
         }