diff --git a/src/main/java/com/qyft/ms/system/core/client/DeviceTcpClient.java b/src/main/java/com/qyft/ms/system/core/client/DeviceTcpClient.java index d84990e..bdc8fc5 100644 --- a/src/main/java/com/qyft/ms/system/core/client/DeviceTcpClient.java +++ b/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(); } } diff --git a/src/main/java/com/qyft/ms/system/core/handler/DeviceMessageHandler.java b/src/main/java/com/qyft/ms/system/core/handler/DeviceMessageHandler.java index 32e5d1f..cd5a929 100644 --- a/src/main/java/com/qyft/ms/system/core/handler/DeviceMessageHandler.java +++ b/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(); }