spring-webflux - Netty Http 客户端连接池

我想了解 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 秒内完成它们。

最佳答案

连接池是维护的连接缓存,以便在需要对远程服务(数据库、微服务等)的 future 请求时重用这些连接。连接池用于提高性能......见Connection pool .它不取决于您选择的传输方式:NIO、epoll、kqueue 等。 当你有一个连接池时,对于每个连接你只需执行一次 DNS 解析、连接建立等,然后你可以为许多请求重用这个连接。

then what is the significance of this connection pool?

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

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

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

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

如上所述,连接池的所有可用配置都可以在 Reference Documentation 中找到。

https://stackoverflow.com/questions/72352660/

相关文章:

r - 如何在循环中获取标签

c# - 自定义类作为 C# 中字典的键不起作用

python - 如何在 Python 中对列表进行排序和过滤?

javascript - 如何在 redux-toolkit 中输入 'prepare' 函数

html - 对 div 标签内的 span 元素应用边距和在 div 标签内应用边距有什么区别?

python - 我的错误在哪里?在Python中检查密码是否正确

vector - 将具有多个参数的函数应用于 Julia 中的向量

javascript - 我如何在 react 中使用刷新 token

python - Python 何时从实例 __dict__ 返回到类 __dict__?

python - 计算数据框 Pandas 的多列中某个值的出现次数