update

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();

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);
                             }