运行 Netty 中的多个服务器没有 closeFuture().sync()

Question

我正在开发 Netty 应用程序。我想运行多个服务器在不同的端口上，如果没有（阻塞）closeFuture().sync().

就无法工作

我使用以下代码在 ServerManager class 中启动服务器：

gpcmServer = new GpcmServer(port);

gpspServer = new GpspServer(port);

在那些 classes 中，我按如下方式启动服务器：

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()时，我可以连接到服务器。我怎样才能继续这样做并使服务器正常工作？

Answer 1

当您调用 EventLoopGroup.shutdown*() 方法时，事件循环将在终止自身之前关闭它正在管理的所有套接字和服务器套接字。因此，如果您没有等到服务器套接字关闭，您的 finally 块将完全终止您的服务器。

对于运行多台服务器，您实际需要做的是：

绑定多次，
不要调用shutdownGracefully()直到你想关闭你的服务器。

运行 Netty 中的多个服务器没有 closeFuture().sync()

Run multiple servers in Netty without closeFuture().sync()

java

netty