From e878a142a05792b08bce9fbf9767118d76585ed5 Mon Sep 17 00:00:00 2001
From: linwl <304115325@qq.com>
Date: Mon, 18 Jan 2021 20:44:09 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=88=B0docker=E5=A4=96?=
 =?UTF-8?q?=E8=BF=90=E8=A1=8C=E7=8E=AF=E5=A2=83?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../telpo/dipperposition/handler/NettyServerHandler.java | 2 ++
 .../dipperposition/server/DipperPositionServer.java      | 9 +++++----
 2 files changed, 7 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/telpo/dipperposition/handler/NettyServerHandler.java b/src/main/java/com/telpo/dipperposition/handler/NettyServerHandler.java
index 0edfe40..26f0b33 100644
--- a/src/main/java/com/telpo/dipperposition/handler/NettyServerHandler.java
+++ b/src/main/java/com/telpo/dipperposition/handler/NettyServerHandler.java
@@ -124,6 +124,8 @@ public class NettyServerHandler extends ChannelInboundHandlerAdapter {
         // if (Integer.parseInt(posAsycServerPort) == channel.localAddress().getPort()) {
 
         //if (AST_POS_CMD.equals(recvmg)) {
+        log.info("config info is : " + positionConfig.getCenterProvinceFilePath() + positionConfig.getCenterProvince() + positionConfig.getIpPositionRequestPath() +
+                positionConfig.getIpPositionRequestKey());
         if (AST_POS_CMD.equals(msg)) {
 //            channelAns = dipperAstPosAsyncTaskService.pushAstPos(ipAddress,
 //                    positionConfig.getCenterProvinceFilePath(),
diff --git a/src/main/java/com/telpo/dipperposition/server/DipperPositionServer.java b/src/main/java/com/telpo/dipperposition/server/DipperPositionServer.java
index 64855c4..d8e5ebc 100644
--- a/src/main/java/com/telpo/dipperposition/server/DipperPositionServer.java
+++ b/src/main/java/com/telpo/dipperposition/server/DipperPositionServer.java
@@ -158,12 +158,12 @@ public class DipperPositionServer {
         EventLoopGroup mainThreadGroup = new NioEventLoopGroup(1);
         //new 一个工作线程组
         EventLoopGroup workThreadGroup = new NioEventLoopGroup(200);
-        //InetSocketAddress socketAddress = new InetSocketAddress(serverAddr,null);
+        InetSocketAddress socketAddress = new InetSocketAddress(serverAddr,9011);
         ServerBootstrap bootstrap = new ServerBootstrap()
                 .group(mainThreadGroup, workThreadGroup)
                 .channel(NioServerSocketChannel.class)
                 .childHandler(new ServerChannelInitializer())
-                //.localAddress(socketAddress)
+                .localAddress(socketAddress)
                 //设置队列大小
                 .option(ChannelOption.SO_BACKLOG, 1024)
                 // 两小时内没有数据的通信时,TCP会自动发送一个活动探测数据报文
@@ -181,6 +181,7 @@ public class DipperPositionServer {
                     System.out.println("start failed");
                 }
             });
+            channelFuture.channel().closeFuture().sync();
 
             ChannelFuture channelFuture2 = bootstrap.bind(posAsycPort).sync();
             log.info("位置服务器启动开始监听端口: {}", posAsycPort);
@@ -191,6 +192,7 @@ public class DipperPositionServer {
                     System.out.println("start failed");
                 }
             });
+            channelFuture2.channel().closeFuture().sync();
 
 
             ChannelFuture channelFuture3 = bootstrap.bind(starsAsycPort).sync();
@@ -202,8 +204,7 @@ public class DipperPositionServer {
                     System.out.println("start failed");
                 }
             });
-
-            //channelFuture.channel().closeFuture().sync();
+            channelFuture3.channel().closeFuture().sync();
         } catch (InterruptedException e) {
             e.printStackTrace();
         } finally {