我正在研究Netty应用程序.我想在不同的端口上运行多个服务器,如果没有(阻塞)closeFuture().sync(),它就无法工作.
我使用以下代码在ServerManager类中启动服务器:
gpcmServer = new GpcmServer(port); gpspServer = new GpspServer(port);
在这些类中,我按如下方式启动服务器:
public GpspServer(int port) throws InterruptedException { EventLoopGroup bossGroup = new NioEventLoopGroup(); EventLoopGroup workerGroup = new NioEventLoopGroup(); try { ServerBootstrap bootstrap = new ServerBootstrap(); bootstrap.group(bossGroup,workerGroup) .channel(NioServerSocketChannel.class) .childHandler(new ChannelInitializer<SocketChannel>() { @Override public void initChannel(SocketChannel ch) throws Exception { // Add the server handler and its decoder ch.pipeline().addLast(new GpspDecoder(),new GpspServerHandler()); } }) .option(ChannelOption.SO_BACKLOG,128) .childOption(ChannelOption.SO_KEEPALIVE,true); // Bind and start to accept incoming connections. bindFuture = bootstrap.bind(port).sync(); bindFuture.channel().closeFuture(); } finally { workerGroup.shutdownGracefully(); bossGroup.shutdownGracefully(); } }
但是,当我不调用closeFuture().sync()时,我无法连接到服务器.当我将.sync()添加到bindFuture.channel().closeFuture()时,我可以连接到服务器.我如何继续这样做,仍然使服务器工作?
解决方法
当您调用EventLoopGroup.shutdown *()方法时,事件循环将关闭它正在管理的所有套接字和服务器套接字,然后再终止自身.因此,如果您没有等到服务器套接字关闭,则finally块将完全终止您的服务器.
您实际需要做的是运行多个服务器:
>绑定多次,>在您要关闭服务器之前,请不要调用shutdownGracefully().
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。