From 3e6b1148c0472564b0f08eb555a696ce973f68e1 Mon Sep 17 00:00:00 2001 From: lijiuwei Date: Mon, 14 Apr 2025 09:41:44 +0800 Subject: [PATCH] update --- src/main/java/com/inspect/tcpserver/tcp/MyDecoder.java | 6 +++--- .../java/com/inspect/tcpserver/tcp/NettyServerHandler.java | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/main/java/com/inspect/tcpserver/tcp/MyDecoder.java b/src/main/java/com/inspect/tcpserver/tcp/MyDecoder.java index 9636bbf..8b28c72 100644 --- a/src/main/java/com/inspect/tcpserver/tcp/MyDecoder.java +++ b/src/main/java/com/inspect/tcpserver/tcp/MyDecoder.java @@ -24,7 +24,7 @@ public class MyDecoder extends ByteToMessageDecoder { try { int length = in.readableBytes(); if (length < BASE_LENGTH) { - log.error("not enough readableBytes: {}", length); +// log.error("not enough readableBytes: {}", length); return; } @@ -58,11 +58,11 @@ public class MyDecoder extends ByteToMessageDecoder { break; } else { in.readerIndex(in.readerIndex() - 23); - log.error("wrong xml length: {}, total length: {}", xmlLength, length); +// log.error("wrong xml length: {}, total length: {}", xmlLength, length); } } else { in.readerIndex(in.readerIndex() - 2); - log.error("wrong start flag: [{},{}]", start[0], start[1]); +// log.error("wrong start flag: [{},{}]", start[0], start[1]); } in.readByte(); diff --git a/src/main/java/com/inspect/tcpserver/tcp/NettyServerHandler.java b/src/main/java/com/inspect/tcpserver/tcp/NettyServerHandler.java index 479de99..c01435a 100644 --- a/src/main/java/com/inspect/tcpserver/tcp/NettyServerHandler.java +++ b/src/main/java/com/inspect/tcpserver/tcp/NettyServerHandler.java @@ -25,7 +25,7 @@ public class NettyServerHandler extends ChannelInboundHandlerAdapter { (ChannelFuture future) -> { if (future.isSuccess()) { if(request) { - logger.info(Color.CYAN + "###### 活动连接:{},向客户端[{}]下发消息成功:{}######" + Color.END, ChannelCache.getInstance().getClients(), clientKey, xml); + logger.info("###### 活动连接:{},向客户端[{}]下发消息成功:{}######", ChannelCache.getInstance().getClients(), clientKey, xml); } else { logger.info(Color.CYAN + "###### 活动连接:{},向客户端[{}]响应成功######" + Color.END, ChannelCache.getInstance().getClients(), clientKey); }