diff --git a/src/main/java/com/inspect/tcpserver/tcp/MyDecoder.java b/src/main/java/com/inspect/tcpserver/tcp/MyDecoder.java index 4dddd24..4d5ec39 100644 --- a/src/main/java/com/inspect/tcpserver/tcp/MyDecoder.java +++ b/src/main/java/com/inspect/tcpserver/tcp/MyDecoder.java @@ -20,8 +20,11 @@ public class MyDecoder extends ByteToMessageDecoder { private final int BASE_LENGTH = 2 + 8 + 8 + 1 + 4 + 2; - @Value("${print_recv_data:0}") - Integer printRecvData; + private Integer printRecvData = 0; + + public MyDecoder(Integer printRecvData) { + this.printRecvData = printRecvData; + } @Override protected void decode(ChannelHandlerContext ctx, ByteBuf in, List out) throws Exception { diff --git a/src/main/java/com/inspect/tcpserver/tcp/NettyClient.java b/src/main/java/com/inspect/tcpserver/tcp/NettyClient.java index f24616c..8837c8a 100644 --- a/src/main/java/com/inspect/tcpserver/tcp/NettyClient.java +++ b/src/main/java/com/inspect/tcpserver/tcp/NettyClient.java @@ -74,6 +74,9 @@ public class NettyClient { @Value("${up_time_interval_setting}") String upTimeIntervalSetting; + @Value("${print_recv_data:0}") + Integer printRecvData; + /** * 接收/发送报文xml外层别名 */ @@ -117,7 +120,7 @@ public class NettyClient { @Override protected void initChannel(SocketChannel ch) throws Exception { client = new NettyClientHandler(NettyClient.this); - ch.pipeline().addLast(new MyDecoder()); + ch.pipeline().addLast(new MyDecoder(printRecvData)); ch.pipeline().addLast(client); } }); diff --git a/src/main/java/com/inspect/tcpserver/tcp/NettyServer.java b/src/main/java/com/inspect/tcpserver/tcp/NettyServer.java index 76f90f2..42ad799 100644 --- a/src/main/java/com/inspect/tcpserver/tcp/NettyServer.java +++ b/src/main/java/com/inspect/tcpserver/tcp/NettyServer.java @@ -77,12 +77,16 @@ public class NettyServer { @Value("${iip_server.authDevice.url}") String iipAuthDeviceUrl; + @Value("${print_recv_data:0}") + Integer printRecvData; + @Value("${seperating_packages:0}") Integer seperatingPackages; private int serverPort; public void init() { + logger.info("print_recv_data config: {}", printRecvData); logger.info("seperatingPackages config: {}", seperatingPackages); this.serverPort = deviceServerProperties.port; @@ -108,7 +112,7 @@ public class NettyServer { if(seperatingPackages > 0) { ch.pipeline().addLast(new LengthFieldBasedFrameDecoder(ByteOrder.LITTLE_ENDIAN, Integer.MAX_VALUE, 19, 4, 2, 0, true)); } - ch.pipeline().addLast(new MyDecoder()); + ch.pipeline().addLast(new MyDecoder(printRecvData)); nettyServerHandler = new NettyServerHandler(NettyServer.this); ch.pipeline().addLast(nettyServerHandler); }