diff --git a/src/main/java/com/telpo/dipperposition/DipperPositionApplication.java b/src/main/java/com/telpo/dipperposition/DipperPositionApplication.java index 38c509d..055577f 100644 --- a/src/main/java/com/telpo/dipperposition/DipperPositionApplication.java +++ b/src/main/java/com/telpo/dipperposition/DipperPositionApplication.java @@ -45,7 +45,7 @@ public class DipperPositionApplication { //启动服务端 ConfigurableEnvironment environment = applicationContext.getEnvironment(); DipperPositionServer nettyServer = new DipperPositionServer(environment); - nettyServer.start2(); + nettyServer.start(); } catch (Exception e) { log.error(e.getMessage()); } diff --git a/src/main/java/com/telpo/dipperposition/handler/NettyServerHandler.java b/src/main/java/com/telpo/dipperposition/handler/NettyServerHandler.java index 1234f48..0edfe40 100644 --- a/src/main/java/com/telpo/dipperposition/handler/NettyServerHandler.java +++ b/src/main/java/com/telpo/dipperposition/handler/NettyServerHandler.java @@ -64,6 +64,7 @@ public class NettyServerHandler extends ChannelInboundHandlerAdapter { //通知客户端链接建立成功 // 默认返回取得时间成功 String ackAckCheckRef = "233E0101020004020A1D"; + // if (Integer.parseInt(nettyServerConfig.getPosAsycServerPort()) == channel.localAddress().getPort()) { // ackAckCheckRef = "233E010102000401091C"; // }