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