From d057f2a3edc859150cea2f7eecb655111ef6653c Mon Sep 17 00:00:00 2001 From: linwl <304115325@qq.com> Date: Fri, 15 Jan 2021 18:39:34 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0OkHttp=E9=85=8D=E7=BD=AE?= =?UTF-8?q?=E6=96=87=E4=BB=B6=E8=AF=BB=E5=8F=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../server/DipperPositionServer.java | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/src/main/java/com/telpo/dipperposition/server/DipperPositionServer.java b/src/main/java/com/telpo/dipperposition/server/DipperPositionServer.java index bbe51d2..e338727 100644 --- a/src/main/java/com/telpo/dipperposition/server/DipperPositionServer.java +++ b/src/main/java/com/telpo/dipperposition/server/DipperPositionServer.java @@ -33,9 +33,9 @@ public class DipperPositionServer { // @Autowired PositionConfigInfo positionConfigInfo; private String serverAddr; - private String timeAsycPort; - private String posAsycPort; - private String starsAsycPort; + private Integer timeAsycPort; + private Integer posAsycPort; + private Integer starsAsycPort; public DipperPositionServer() throws NacosException { //String serverAddr = positionConfigInfo.getServerAddr(); @@ -59,9 +59,9 @@ public class DipperPositionServer { Map m1 = yaml.load(tInputStringStream); Map m2 = (Map) m1.get("position-server"); this.serverAddr = (String)m2.get("serverAddr"); - this.timeAsycPort = (String)m2.get("timeAsycPort"); - this.posAsycPort = (String)m2.get("posAsycPort"); - this.starsAsycPort = (String)m2.get("starsAsycPort"); + this.timeAsycPort = (Integer)m2.get("timeAsycPort"); + this.posAsycPort = (Integer)m2.get("posAsycPort"); + this.starsAsycPort = (Integer)m2.get("starsAsycPort"); //log.info("Map server is:" + m2.get("serverAddr")); } catch (Exception ex) { ex.printStackTrace(); @@ -78,7 +78,7 @@ public class DipperPositionServer { //new 一个工作线程组 EventLoopGroup workThreadGroup = new NioEventLoopGroup(200); InetSocketAddress socketAddress = new InetSocketAddress(serverAddr, - Integer.parseInt(timeAsycPort)); + timeAsycPort); ServerBootstrap bootstrap = new ServerBootstrap() .group(mainThreadGroup, workThreadGroup) .channel(NioServerSocketChannel.class) @@ -117,7 +117,7 @@ public class DipperPositionServer { //new 一个工作线程组 EventLoopGroup workThreadGroup = new NioEventLoopGroup(200); InetSocketAddress socketAddress = new InetSocketAddress(serverAddr, - Integer.parseInt(posAsycPort)); + posAsycPort); ServerBootstrap bootstrap = new ServerBootstrap() .group(mainThreadGroup, workThreadGroup) .channel(NioServerSocketChannel.class) @@ -157,7 +157,7 @@ public class DipperPositionServer { //new 一个工作线程组 EventLoopGroup workThreadGroup = new NioEventLoopGroup(200); InetSocketAddress socketAddress = new InetSocketAddress(serverAddr, - Integer.parseInt(starsAsycPort)); + starsAsycPort); ServerBootstrap bootstrap = new ServerBootstrap() .group(mainThreadGroup, workThreadGroup) .channel(NioServerSocketChannel.class)