3

我想创建一个重用通道的连接池，但我想不通

执行这个测试

public void test() {


    ClientBootstrap client = new ClientBootstrap(new NioClientSocketChannelFactory(Executors.newCachedThreadPool(), Executors.newCachedThreadPool()));

    client.setPipelineFactory(new ClientPipelineFactory());

    // Connect to server, wait till connection is established, get channel to write to
    Channel channel = client.connect(new InetSocketAddress("192.168.252.152", 8080)).awaitUninterruptibly().getChannel();
    {
        // Writing request to channel and wait till channel is closed from server
        HttpRequest request = new DefaultHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.POST, "test");

        String xml = "xml document here";
        ChannelBuffer buffer = ChannelBuffers.copiedBuffer(msgXml, Charset.defaultCharset());
        request.addHeader(HttpHeaders.Names.CONTENT_LENGTH, buffer.readableBytes());
        request.addHeader(HttpHeaders.Names.CONTENT_TYPE, "application/xml");
        request.setContent(buffer);

        channel.write(request).awaitUninterruptibly().getChannel().getCloseFuture().awaitUninterruptibly();

        channel.write(request).awaitUninterruptibly().getChannel().getCloseFuture().awaitUninterruptibly();
    }
    client.releaseExternalResources();

}

我在第二个 channel.write(request) 中得到了 ClosedChannelException ....

是否存在重用渠道的方法？还是保持通道畅通？

提前致谢

4

1 回答 1

2

第二次写入失败的原因是服务器关闭了连接。

服务器关闭连接的原因是您未能添加 HTTP 标头

Connection: Keep-Alive

到原来的要求。

这是使通道保持打开状态所必需的（这是您在本方案中想要执行的操作）。

通道关闭后，您必须创建一个新通道。您无法重新打开频道。Channel.getCloseFuture() 返回的 ChannelFuture 对通道来说是最终的（即常量），一旦这个 future 返回的 isDone()true就不能被重置。这就是封闭通道不能被重用的原因。

但是，您可以根据需要多次重复使用开放频道；但是您的应用程序必须正确地使用 HTTP 协议才能完成此操作。

于 2012-11-14T00:42:33.080 回答