diff --git a/cim-boot-server/libs/cim-server-sdk-netty-4.0.0.jar b/cim-boot-server/libs/cim-server-sdk-netty-4.0.0.jar index aa1ccc7..772e0bb 100644 Binary files a/cim-boot-server/libs/cim-server-sdk-netty-4.0.0.jar and b/cim-boot-server/libs/cim-server-sdk-netty-4.0.0.jar differ diff --git a/cim-boot-server/pom.xml b/cim-boot-server/pom.xml index 0684879..14047dc 100644 --- a/cim-boot-server/pom.xml +++ b/cim-boot-server/pom.xml @@ -102,6 +102,13 @@ netty-transport ${netty.version} + + + io.netty + netty-transport-native-epoll + linux-x86_64 + ${netty.version} + @@ -143,4 +150,4 @@ - \ No newline at end of file + diff --git a/cim-server-sdk/pom.xml b/cim-server-sdk/pom.xml index 57fd553..22331f9 100644 --- a/cim-server-sdk/pom.xml +++ b/cim-server-sdk/pom.xml @@ -55,11 +55,7 @@ netty-transport ${netty.version} - - io.netty - netty-transport - ${netty.version} - + io.netty netty-transport-native-epoll @@ -92,4 +88,4 @@ - \ No newline at end of file + diff --git a/cim-server-sdk/src/main/java/com/farsunset/cim/sdk/server/handler/CIMNioSocketAcceptor.java b/cim-server-sdk/src/main/java/com/farsunset/cim/sdk/server/handler/CIMNioSocketAcceptor.java index 9db0e04..8e2004f 100644 --- a/cim-server-sdk/src/main/java/com/farsunset/cim/sdk/server/handler/CIMNioSocketAcceptor.java +++ b/cim-server-sdk/src/main/java/com/farsunset/cim/sdk/server/handler/CIMNioSocketAcceptor.java @@ -120,7 +120,7 @@ public class CIMNioSocketAcceptor extends SimpleChannelInboundHandler{ } public void bind() { - + if (appPort != null){ bindAppPort(); } @@ -147,8 +147,6 @@ public class CIMNioSocketAcceptor extends SimpleChannelInboundHandler{ private void bindAppPort(){ createAppEventGroup(); - appBossGroup = new NioEventLoopGroup(bossThreadFactory); - appWorkerGroup = new NioEventLoopGroup(workerThreadFactory); ServerBootstrap bootstrap = createServerBootstrap(appBossGroup,appWorkerGroup); bootstrap.childHandler(new ChannelInitializer() { @Override @@ -178,8 +176,6 @@ public class CIMNioSocketAcceptor extends SimpleChannelInboundHandler{ private void bindWebPort(){ createWebEventGroup(); - webBossGroup = new NioEventLoopGroup(bossThreadFactory); - webWorkerGroup = new NioEventLoopGroup(workerThreadFactory); ServerBootstrap bootstrap = createServerBootstrap(webBossGroup,webWorkerGroup); bootstrap.childHandler(new ChannelInitializer() {