Browse Source

update

master
lijiuwei 7 months ago
parent
commit
dc7bfdf74c
3 changed files with 14 additions and 4 deletions
  1. +5
    -2
      src/main/java/com/inspect/tcpserver/tcp/MyDecoder.java
  2. +4
    -1
      src/main/java/com/inspect/tcpserver/tcp/NettyClient.java
  3. +5
    -1
      src/main/java/com/inspect/tcpserver/tcp/NettyServer.java

+ 5
- 2
src/main/java/com/inspect/tcpserver/tcp/MyDecoder.java View File

@ -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<Object> out) throws Exception {


+ 4
- 1
src/main/java/com/inspect/tcpserver/tcp/NettyClient.java View File

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


+ 5
- 1
src/main/java/com/inspect/tcpserver/tcp/NettyServer.java View File

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


Loading…
Cancel
Save