与Netty和NIO高度并发的HTTP

Question

我正在研究示例Netty
HTTP客户端代码
，以便在并发线程环境中发出http请求。

但是，我的系统以相当低的吞吐量完全崩溃（有很多异常）。

用几乎伪代码：

ClientBootstrap bootstrap = new ClientBootstrap(new NioClientSocketChannelFactory()) 
bootstrap.setPipelineFactory(new HttpClientPipelineFactory());

ChannelFuture future = bootstrap.connect(new InetSocketAddress(host, port));
Channel channel = future.awaitUninterruptibly().getChannel();

HttpRequest request = new DefaultHttpRequest();
channel.write(request);

在示例中，为了发出请求，我创建了一个ClientBootstrap，然后从那里（通过几个箍）创建一个Channel以编写HTTPRequest。

这一切都很好，而且很好。

但是，在同时发生的情况下，是否每个请求都要经过相同的循环？我认为这就是目前对我来说很重要的事情。我应该以完全不同的方式重用连接或构造客户吗？

另外：如果有任何区别，我正在Clojure中进行此操作。

Answer 1

不，您做对了。但是，您必须保留对Channel实例的引用。拥有该通道后，只要打开该通道，就无需创建另一个引导程序。（如果这就是您正在做的。）

这是我在最近的项目中使用的：

ClientConnection类 （构造函数）

// Configure the client.
bootstrap = new ClientBootstrap(
    new NioClientSocketChannelFactory(
        Executors.newCachedThreadPool(),
        Executors.newCachedThreadPool()
    )
);

// Set up the pipeline factory.
bootstrap.setPipelineFactory(
    new ChannelPipelineFactory() {
        public ChannelPipeline getPipeline() throws Exception {
            return Channels.pipeline(
                // put your handlers here
            );
        }
    }
);

类ClientConnection.connect（字符串主机，int端口）

if (isConnected()) {
    throw new IllegalStateException("already connected");
}

// Start the connection attempt.
ChannelFuture future = bootstrap.connect(new InetSocketAddress(host, port));

channel = future.awaitUninterruptibly().getChannel();

// Wait until the connection is closed or the connection attempt fails.
channel.getCloseFuture().addListener(new ChannelFutureListener() {
    @Override
    public void operationComplete(ChannelFuture future) throws Exception {
        new Thread(new Runnable() {
            public void run() {
                // Shut down thread pools to exit
                // (cannot be executed in the same thread pool!
                bootstrap.releaseExternalResources();

                LOG.log(Level.INFO, "Shutting down");
            }
        }).start();
    }
});

因此，基本上，我只引用bootstrap和channel，但是在这些代码行之外几乎没有使用前者。

注意：bootstrap.releaseExternalResources();应用程序退出时，您只应执行一次。在我的情况下，客户端发送一些文件，然后关闭通道并退出。

连接Channel实例后，只需使用该实例，直到再次关闭它。关闭后，您可以调用再次bootstrap创建一个新文件Channel。

就个人而言，我发现Netty最初有点难以理解，但是一旦您掌握了它的工作原理，它就是Java中最好的NIO框架。海事组织。