java – 在没有closeFuture()的情况下在Netty中运行多个服务器.sync()

前端之家收集整理的这篇文章主要介绍了java – 在没有closeFuture()的情况下在Netty中运行多个服务器.sync()前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。
我正在研究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().

猜你在找的netty相关文章