Netty上作为Tcp客户端的单例bootstrap和pipelineFactory

Question

我正在使用Netty实现TCP协议的服务器和客户端。在服务器端，我为它侦听的每个端口创建了一个bootStrap和pipelineFactory类的实例，它的工作非常迅速。

然而，在客户端，我还没有一个关于如何构造它的清晰的想法。我需要打开数千个连接到数千个不同的目的地。我正在Spring框架上开发这个项目，这样我就可以轻松地创建单例bean并将它们作为属性注入。我正在评估三种选择：

>

使用ClientBootstrap和PipelineFactory的单个实例。每个连接都使用一些像这样的代码来获得一个通道：

public Channel connect(final InetSocketAddress serverAddress, final ChannelPipelineFactory pipelineFactory, int timeout, TimeUnit unit) throws InterruptedException {
ChannelFuture future;
synchronized (bootstrap){
    bootstrap.setPipelineFactory(pipelineFactory);
    future = bootstrap.connect(serverAddress);
    future.addListener(new ChannelFutureListener() {
        @Override
        public void operationComplete(ChannelFuture future) throws Exception {
            if (future.isSuccess()) {
                //TODO set here some channelLocal properties I need to configure the session (eg: user, password etc...)
            }
            else{
                throw new RuntimeException(future.getCause()
                        .getMessage());
            }
        }
    });
}
return future.getChannel();

}

我的解决方案还必须能够配置管道以启用或禁用SSL或日志处理程序，可能使用这个Abe解决方案来配置getPipeline（）

>

我的第二个选项是使用ClientBootstrap的单个实例，但在每个传出的客户端连接上创建一个新的PipelineFactory。这有助于我配置我拥有的管道，因为我可以在pipelineFactory实例上设置属性。

第三个选项是在每个传出连接上创建新的引导对象和pipelineFactory。这允许我在每个连接上配置tcp.delay或tcp.keepalive等属性，并允许我删除connect方法上的synchronized块，这可以加快客户端连接。

我认为第一个是最快的，使用最低的内存，但第三个是最可配置的，也许容易开发。

你能给我一些关于这种方法的利弊的建议吗？也许其中一个错了？

非常感谢！

Answer 1

ClientBootstrap实例很便宜。我只需要为每个连接创建一个新的连接，并为所有连接重用NioSocketClientChannelFactory。或者，如果可以，您可能希望对ssl连接使用一个引导程序，对非ssl使用一个引导程序。这将使您免受内存开销的影响。