|
|
@@ -32,12 +32,14 @@ public class DipperPositionServer { |
|
|
|
*/ |
|
|
|
public void startTimeAsnc() { |
|
|
|
|
|
|
|
log.debug("Server is :", positionConfig.getServerAddr()); |
|
|
|
log.debug("Port is :", positionConfig.getTimeAsycServerPort()); |
|
|
|
//new 一个主线程组 |
|
|
|
EventLoopGroup mainThreadGroup = new NioEventLoopGroup(1); |
|
|
|
//new 一个工作线程组 |
|
|
|
EventLoopGroup workThreadGroup = new NioEventLoopGroup(200); |
|
|
|
InetSocketAddress socketAddress = new InetSocketAddress(positionConfig.getServerAddr(), |
|
|
|
Integer.parseInt(positionConfig.getTimeAsycServerPort())); |
|
|
|
Integer.parseInt("9101")); |
|
|
|
ServerBootstrap bootstrap = new ServerBootstrap() |
|
|
|
.group(mainThreadGroup, workThreadGroup) |
|
|
|
.channel(NioServerSocketChannel.class) |
|
|
|