mirror of
https://gitee.com/farsunset/cim.git
synced 2025-07-05 16:31:26 +08:00
commit
cada6b890e
Binary file not shown.
@ -102,6 +102,13 @@
|
||||
<artifactId>netty-transport</artifactId>
|
||||
<version>${netty.version}</version>
|
||||
</dependency>
|
||||
<!-- linux下有效. 其他linux平台自行修改对应的classifier -->
|
||||
<dependency>
|
||||
<groupId>io.netty</groupId>
|
||||
<artifactId>netty-transport-native-epoll</artifactId>
|
||||
<classifier>linux-x86_64</classifier>
|
||||
<version>${netty.version}</version>
|
||||
</dependency>
|
||||
<!--- ##################使用netty本SDK时的配置 end ##################-->
|
||||
|
||||
|
||||
@ -143,4 +150,4 @@
|
||||
</plugin>
|
||||
</plugins>
|
||||
</build>
|
||||
</project>
|
||||
</project>
|
||||
|
@ -55,11 +55,7 @@
|
||||
<artifactId>netty-transport</artifactId>
|
||||
<version>${netty.version}</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>io.netty</groupId>
|
||||
<artifactId>netty-transport</artifactId>
|
||||
<version>${netty.version}</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>io.netty</groupId>
|
||||
<artifactId>netty-transport-native-epoll</artifactId>
|
||||
@ -92,4 +88,4 @@
|
||||
</plugin>
|
||||
</plugins>
|
||||
</build>
|
||||
</project>
|
||||
</project>
|
||||
|
@ -120,7 +120,7 @@ public class CIMNioSocketAcceptor extends SimpleChannelInboundHandler<SentBody>{
|
||||
}
|
||||
|
||||
public void bind() {
|
||||
|
||||
|
||||
if (appPort != null){
|
||||
bindAppPort();
|
||||
}
|
||||
@ -147,8 +147,6 @@ public class CIMNioSocketAcceptor extends SimpleChannelInboundHandler<SentBody>{
|
||||
|
||||
private void bindAppPort(){
|
||||
createAppEventGroup();
|
||||
appBossGroup = new NioEventLoopGroup(bossThreadFactory);
|
||||
appWorkerGroup = new NioEventLoopGroup(workerThreadFactory);
|
||||
ServerBootstrap bootstrap = createServerBootstrap(appBossGroup,appWorkerGroup);
|
||||
bootstrap.childHandler(new ChannelInitializer<SocketChannel>() {
|
||||
@Override
|
||||
@ -178,8 +176,6 @@ public class CIMNioSocketAcceptor extends SimpleChannelInboundHandler<SentBody>{
|
||||
|
||||
private void bindWebPort(){
|
||||
createWebEventGroup();
|
||||
webBossGroup = new NioEventLoopGroup(bossThreadFactory);
|
||||
webWorkerGroup = new NioEventLoopGroup(workerThreadFactory);
|
||||
ServerBootstrap bootstrap = createServerBootstrap(webBossGroup,webWorkerGroup);
|
||||
bootstrap.childHandler(new ChannelInitializer<SocketChannel>() {
|
||||
|
||||
|
Loading…
x
Reference in New Issue
Block a user