如何在Netty中使用多个ServerBootstrap对象

Question

try {
    b.bind().sync().channel().closeFuture().sync();
}
finally {
    b.shutdown();
}

另外，我不明白当我们只调用bind（）而不调用sync（）时会发生什么。服务器是否以某种方式继续运行？我们如何优雅地关闭它？

很明显，我对这一切的工作原理感到非常困惑，可悲的是，在这方面缺乏完整的文档。任何帮助都将不胜感激。

Answer 1

下面是您引用的示例，并添加了关于sync()方法的问题，下面是一个示例代码：

EventLoopGroup bossGroup = new NioEventLoopGroup(numBossThreads);
EventLoopGroup workerGroup = new NioEventLoopGroup(numWorkerThreads);
ServerBootstrap sb1 = null;
ServerBootstrap sb2 = null;
ServerBootstrap sb3 = null;
Channel ch1 = null;
Channel ch2 = null;
Channel ch3 = null;
try {
    sb1 = new ServerBootstrap();
    sb1.group(bossGroup, workerGroup);
    ...
    ch1 = sb1.bind().sync().channel();

    sb2 = new ServerBootstrap();
    sb2.group(bossGroup, workerGroup);
    ...
    ch2 = sb2.bind().sync().channel();

    sb3 = new ServerBootstrap();
    sb3.group(bossGroup, workerGroup);
    ...
    ch3 = sb3.bind().sync().channel();
} finally {
    // Now waiting for the parent channels (the binded ones) to be closed
    if (ch1 != null) {
        ch1.closeFuture().sync();
    }
    if (b1 != null) {
        b1.shutdownGracefully();
    }
    if (ch2 != null) {
        ch2.closeFuture().sync();
    }
    if (b2 != null) {
        b2.shutdownGracefully();
    }
    if (ch3 != null) {
        ch3.closeFuture().sync();
    }
    if (b3 != null) {
        b3.shutdownGracefully();
    }

所以现在解释一下（我试着）：

• bind()命令创建侦听相应的套接字。它立即返回（不阻塞），因此父通道可能尚未可用。
• 第一个sync()命令(bind().sync())等待绑定完成（如果引发异常，则直接转到最后部分）。在此阶段，通道已准备就绪，并且肯定会侦听新的连接。
• channel()命令获取这个侦听通道（父通道，尚未连接到任何人）。所有客户端都将生成此父信道的“子”信道。
• 在处理程序中，在某个事件之后，您决定关闭父通道（不是子通道，而是正在监听和等待新套接字的通道）。要完成此关闭，只需调用parentchannel.close()（或从子通道child.parent().close()).
• closefuture()命令将获取此关闭事件的未来值。
• 当这个未来结束（完成）时，将执行最后一个sync()命令(closefuture().sync())。
• 父通道关闭后，您可以请求正常关闭绑定通道。

当然，你可以改变一些东西。例如，不是首先获取通道，而是在您想要在优雅地关闭之前阻止时才获取通道。

EventLoopGroup bossGroup = new NioEventLoopGroup(numBossThreads);
EventLoopGroup workerGroup = new NioEventLoopGroup(numWorkerThreads);
ServerBootstrap sb1 = null;
ServerBootstrap sb2 = null;
ServerBootstrap sb3 = null;
ChannelFuture cf1 = null;
ChannelFuture cf2 = null;
ChannelFuture cf3 = null;
try {
    sb1 = new ServerBootstrap();
    sb1.group(bossGroup, workerGroup);
    ...
    cf1 = sb1.bind();

    sb2 = new ServerBootstrap();
    sb2.group(bossGroup, workerGroup);
    ...
    cf2 = sb2.bind();

    sb3 = new ServerBootstrap();
    sb3.group(bossGroup, workerGroup);
    ...
    cf3 = sb3.bind();
} finally {
    // Now waiting for the parent channels (the binded ones) to be closed
    if (cf1 != null) {
        cf1.sync().channel().closeFuture().sync();
    }
    if (cf2 != null) {
        c2.sync().channel().closeFuture().sync();
    }
    if (cf3 != null) {
        cf3.sync().channel().closeFuture().sync();
    }
    if (b1 != null) {
        b1.shutdownGracefully();
    }
    if (b2 != null) {
        b2.shutdownGracefully();
    }
    if (b3 != null) {
        b3.shutdownGracefully();
    }

这样你就不会在打开所有3个频道时阻塞，但在关闭它们之前等待所有3个频道都完成。

最后，如果在bind()事件上不阻塞，那么在closefuture()事件上不阻塞，则由您定义在sbx.bind()命令之后和关闭服务器引导程序之前如何等待。