java – 在没有closeFuture()的情况下在Netty中运行多个服务器.s
发布时间:2020-12-15 04:25:59 所属栏目:Java 来源:网络整理
导读:我正在研究Netty应用程序.我想在不同的端口上运行多个服务器,如果没有(阻塞)closeFuture().sync(),它就无法工作. 我使用以下代码在ServerManager类中启动服务器: gpcmServer = new GpcmServer(port);gpspServer = new GpspServer(port); 在这些类中,我按如
我正在研究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(). (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |