3

在下面的示例中，我创建了一个 Java 11 httpClient，然后创建了多个并发 HttpRequest。

  1. 这是不好的做法吗？
  2. 每个 HttpRequest 都应该有自己的 HttpClient 吗？
  3. HttpClient 可以拥有的 HttpRequest 数量是否有上限？

代码

    private static void httpClientExample(){
    
    HttpClient httpClient = HttpClient.newHttpClient();

    System.out.println("TP1");

    var task1 = httpClient.sendAsync(HttpRequest.newBuilder()
            .uri(URI.create("https://www.bing.com/"))
            .build(), HttpResponse.BodyHandlers.ofString())
            .thenApply(HttpResponse::uri).thenAccept(System.out::println);

    var task2 = httpClient.sendAsync(HttpRequest.newBuilder()
            .uri(URI.create("https://openjdk.java.net/"))
            .build(), HttpResponse.BodyHandlers.ofString())
            .thenApply(HttpResponse::uri).thenAccept(System.out::println);
    
    var task3 = httpClient.sendAsync(HttpRequest.newBuilder()
            .uri(URI.create("https://www.google.co.uk/"))
            .build(), HttpResponse.BodyHandlers.ofString())
            .thenApply(HttpResponse::uri).thenAccept(System.out::println);


    System.out.println("Requests Sent");

    try {
        Thread.sleep(5000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }

    System.out.println("Main Thread Completed");
    }
4

2 回答 2

7

这没有明确记录在HttpClient. 但预计 HttpClient 旨在处理多个请求。这在某种意义上暗示了 Java HTTP 客户端简介：

构建后，可以使用 HttpClient 发送多个请求。

现在，您的问题可能是关于管理客户端的并发性。这与使用的 executor 服务有很大关系，而不是使用相同的实例HttpClient，这是您可以自定义的（参见此处）：

ExecutorService executorService = Executors.newFixedThreadPool(10);
HttpClient httpClient  = HttpClient.newBuilder()
                               .executor(executorService)
                               ... //more config
                               .build();

这样，您可以管理客户端用于运行异步请求的线程池。

换句话说：

这是不好的做法吗？

不

每个 HttpRequest 都应该有自己的 HttpClient 吗？

不

HttpClient 可以拥有的 HttpRequest 数量是否有上限？

您必须测试应用程序的最佳并发设置，然后使用相应配置的执行器服务。

于 2020-10-11T10:47:06.493 回答
2

我想说这都是关于线程的数量而不是对象的数量，因为每个客户端都可以通过 Executor 的线程池使用许多线程，无论是显式声明的还是默认的。所以真正的问题归结为我们应该使用多少线程？这将取决于同步或异步请求的使用。

  1. 使用 时send，我们从池中使用的线程越多，我们能够并行发出的请求就越多，直到操作系统开始threashing，即增加活动线程的数量实际上会减少完成的工作量。
  2. 在您的示例中使用sendAsync时，事情变得有趣，因为它是一种非阻塞方法，这意味着同一个线程可以在等待响应处理的同时发出多个请求。在这种情况下，我建议保持 Executor 池中的线程数等于处理器的内核数。
于 2020-10-11T13:18:15.420 回答