Netty Http 客户端连接池

Question

我想了解 netty http 客户端连接池。如果是NIO、异步的话，那么这个连接池还有什么意义呢？

例如：如果服务 A 调用服务 B 并且服务 A 将客户端连接池计数设置为 50，那么这是否意味着我们最多只能发出 50 个并行请求？

更新：

// remote server

@GetMapping("echo")
public Mono<String> echo(){
    return Mono.just("echo")
                .delayElement(Duration.ofSeconds(3));
}

// client 1 conneciton
HttpClient httpClient = HttpClient.create(ConnectionProvider.newConnection());

WebClient client = WebClient.builder()
                          .baseUrl("http://localhost:8080/echo")
                          .clientConnector(new ReactorClientHttpConnector(httpClient))
                          .build();

// run
var start = System.currentTimeMillis();
Flux.range(1, 50)
    .flatMap(i -> client.get().retrieve().bodyToMono(String.class))
    .collectList()
    .doOnNext(System.out::println)
    .doFinally(s -> System.out.println("Total Time Taken : " + (System.currentTimeMillis() - start) + " ms"))
    .block();

我发现所有呼叫都在 3.5 秒内完成。理想情况下，如果有 1 个连接，我应该可以在 150 秒内完成它们。

Answer 1

连接池是维护的连接的缓存，以便在将来需要向远程服务（数据库、微服务等）发出请求时可以重用连接。连接池用于增强性能...请参阅连接池。它不取决于您选择的传输：NIO、epoll、kqueue 等。当您有连接池时，对于每个连接，您只需执行一次 DNS 解析、连接建立等操作，然后您可以为许多请求重用此连接。

那么这个连接池有什么意义呢？

当您没有连接池时，每次您想要向远程服务发出请求时，都会进行 DNS 解析、连接建立等。

连接池仅包含与给定远程服务的连接。因此，当您拥有服务 A 和服务 B 时，您将拥有服务 A 的连接池和服务 B 的连接池（如果这些是不同的远程地址，Reactor Netty 不会为每个 URI 提供配置）。

在 Reactor Netty 中，您可以选择将连接池配置为具有相同的配置，或者您可以为每个池配置不同的配置（取决于您的用例）。

在 Reactor Netty 中，您可以配置max connection，这意味着对于给定的服务，您可以发出最大数量的并行请求（打开的连接）。其他请求将保留在队列中，一旦连接可供重用，就可以执行待处理的请求。

如上所述，连接池的所有可用配置都可以在参考文档中找到