Apache HttpAsynClient客户端不异步发送多个请求

Question

按照这里的Apache HttpAsyncClient示例，HTTPGET请求并不是一次性触发的，而是（大部分）同步触发的。

下图显示了请求的发送顺序（除了一个）。当增加请求数量时，这仍然是正确的。

我使用了另一个库(AsynHttpClient ),请求发送得更快，而且是随机的。

有什么办法可以改进这段代码，让它真正异步执行？

我添加了用于参考的代码。

public static void main(final String[] args) throws Exception {
    RequestConfig requestConfig = RequestConfig.custom()
        .setSocketTimeout(3000)
        .setConnectTimeout(3000).build();
    CloseableHttpAsyncClient httpclient = HttpAsyncClients.custom()
        .setDefaultRequestConfig(requestConfig)
        .build();
    try {
        httpclient.start();
        final HttpGet[] requests = new HttpGet[] {
                new HttpGet("http://httpbin.org/ip"),
                new HttpGet("https://httpbin.org/ip"),
                new HttpGet("http://httpbin.org/headers")
        };
        final CountDownLatch latch = new CountDownLatch(requests.length);
        for (final HttpGet request: requests) {
            httpclient.execute(request, new FutureCallback<HttpResponse>() {

                @Override
                public void completed(final HttpResponse response) {
                    latch.countDown();
                    System.out.println(request.getRequestLine() + "->" + response.getStatusLine());
                }

                @Override
                public void failed(final Exception ex) {
                    latch.countDown();
                    System.out.println(request.getRequestLine() + "->" + ex);
                }

                @Override
                public void cancelled() {
                    latch.countDown();
                    System.out.println(request.getRequestLine() + " cancelled");
                }

            });
        }
        latch.await();
        System.out.println("Shutting down");
    } finally {
        httpclient.close();
    }
    System.out.println("Done");
}

Answer 1

我认为颠簸setMaxConnPerRoute和setMaxConn Total可能会有所帮助，因为这将增加使用的最大连接数

    CloseableHttpAsyncClient httpclient = HttpAsyncClients.custom()
        .setDefaultRequestConfig(requestConfig)
        .setMaxConnPerRoute(20)
        .setMaxConnTotal(50)
    .build();