Webclient Öffnen und schließen Sie die Verbindung bei jedem Elementaufruf im Stream ⇐ Java

[Anonymous]

Versuchen Sie zu verstehen, wie Spring Webclient die Verbindungen zwischen den Peers verarbeitet.

Ich habe mir überrascht, dass bei der Verwendung von http1.1 die Reaktor-Netty-Wiederverwendung die Verbindungen wiederverwendet.
[D6B705E1] Antwort 200 OK

[D6B705E1] Abbrechenssignal (um die Verbindung zu schließen) < /p>

Code: Select all

public WebClient webClient(WebClient.Builder builder) {
return builder
.baseUrl(config.getBaseurl())
.clientConnector(new ReactorClientHttpConnector(
HttpClient.create()
.tcpConfiguration(tcpClient -> tcpClient.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, timeout))
.secure(spec -> spec.sslContext(SslContextBuilder.forClient()))
))
.build();
}

Flux getIds() { ... }

Flux getResponses() {
// here as many open and close connection as the return stream getIds
return getIds().flatMap(... // client.retrieve().bodyToMono(Reponse.class));
}