如果有许多客户端连接，Netty线程模型如何工作？

Question

我打算在即将进行的项目中使用Netty。该项目将同时充当客户端和服务器。特别是它将建立并维护与各种服务器的许多连接，同时为自己的客户端提供服务。

现在，NioServerSocketChannelFactory的文档很好地指定了服务器端的线程模型-
每个绑定的侦听端口在整个过程中都需要一个专用的 老板 线程，而连接的客户端将在 工作
线程上以非阻塞方式进行处理。具体来说，一个工作线程将能够处理多个连接的客户端。

但是，NioClientSocketChannelFactory的文档不太具体。这似乎也利用了
老板 和 工人 线程。但是，文档指出：

一个NioClientSocketChannelFactory有一个老板线程。根据请求进行连接尝试。连接尝试成功后，老板线程将已连接的Channel传递给NioClientSocketChannelFactory管理的工作线程之一。

辅助线程似乎也以与服务器端相同的方式起作用。

我的问题是，这是否意味着从程序到外部服务器的每个连接都会有一个专用的 老板 线程？如果建立数百或数千个此类连接，将如何扩展？

作为旁注。将单个Executor（缓存的线程池） 重新 用作ChannelFactory 的 bossExecutor 和
workerExecutor
是否有不利的副作用？还可以在不同的客户端和/或服务器ChannelFactory实例之间重用呢？这里对此进行了一些讨论，但是我没有找到足够具体的答案。有人可以详细说明吗？

Answer 1

这不是您有关Netty客户端线程模型如何工作的问题的真实答案。但是，您可以使用相同NioClientSocketChannelFactory的对象创建ClientBootstrap带有多个ChannelPipelineFactorys的单个对象，进而建立大量连接。看下面的例子。

public static void main(String[] args)
{
    String host = "localhost";
    int port = 8090;
    ChannelFactory factory = new NioClientSocketChannelFactory(Executors
            .newCachedThreadPool(), Executors.newCachedThreadPool());
    MyHandler handler1 = new MyHandler();
    PipelineFactory factory1 = new PipelineFactory(handler1);
    AnotherHandler handler2 = new AnotherHandler();
    PipelineFactory factory2 = new PipelineFactory(handler2);
    ClientBootstrap bootstrap = new ClientBootstrap(factory);
    // At client side option is tcpNoDelay and at server child.tcpNoDelay
    bootstrap.setOption("tcpNoDelay", true);
    bootstrap.setOption("keepAlive", true);
    for (int i = 1; i<=50;i++){
        if(i%2==0){
            bootstrap.setPipelineFactory(factory1);
        }else{
            bootstrap.setPipelineFactory(factory2);
        }

        ChannelFuture future = bootstrap.connect(new InetSocketAddress(host,
                port));

        future.addListener(new ChannelFutureListener()
        {
            @Override
            public void operationComplete(ChannelFuture future) throws Exception
            {
                future.getChannel().write("SUCCESS");
            }
        });
    }
}

它还显示了如何为不同的连接设置不同的流水线工厂，因此基于连接，您可以调整通道流水线中的编码器/解码器。