Spring Web Flux-WebClient-交换-块-如何释放与连接池的连接？

如何解决Spring Web Flux-WebClient-交换-块-如何释放与连接池的连接？

当前：

我正在使用spring-webflux-5.2.8.RELEASE，它正在运行“ fine ”：

httpStatus = webClient
    .post()
    .uri(someUri)
    .headers(someHeaders)
    .bodyValue(someBody)
    .exchange()
    .map(ClientResponse::statusCode)
    .timeout(someTimeout)
    .doOnError(doSomething())
    .onErrorResume(ex -> Mono.empty())
    .block();

问题：

返回错误时，没有问题，因为连接被破坏并且没有放回连接池中：

DEBUG r.n.resources.PooledConnectionProvider-[id：0xa23f78ad， L：/127.0.0.1：7524！ R：localhost / 127.0.0.1：8443]频道已关闭，现在为0 有效连接和0个无效连接

但是当我收到成功的响应时，下一个 post 将失败/超时：

java.util.concurrent.TimeoutException：没有观察到任何项目或 终端信号在“地图”中的10000毫秒内（并且没有回退 配置）

由于我需要进行故障排除，因此使用了只有1个连接的固定连接池，如下所示：

@Bean
public WebClient.Builder webClientBuilder(){
    
    HttpClient httpClient = HttpClient.create(ConnectionProvider.create("pool",1));
    
    return WebClient.builder()
        .clientConnector(new ReactorClientHttpConnector(httpClient));
}

我正在猜测（我可能是错误的，因为我是webclient和响应世界的新手）问题在于成功获得响应后，未释放该连接，我认为是是由于this。

通过WebClient exchange（）方法使用ClientResponse时， 您必须确保身体被消耗或释放...

尝试过的事情：

我试图像这样做一个releaseBody（）（但是由于下一个 post 仍然失败，所以它不起作用）：

.map(clientResponse -> { 
    HttpStatus statusCode = clientResponse.statusCode();
    clientResponse.releaseBody();
    return statusCode;
})

P.S我需要使用block（）。这无法更改，因为我需要继续进行响应，而我只需要获取状态码即可。我使用的是WebClient，因为我在某处读到该剩余模板将被弃用，而赞成... WebClient。我希望有人能提供帮助。

更新1：

我启用了指标，但实际上并没有释放连接：

reactor_netty_connection_provider_fixedPool_total_connections {id =“ 1591603494”，remote_address =“ localhost：8443”，} 1.0 Reactor_netty_connection_provider_fixedPool_active_connections {id =“ 1591603494”，remote_address =“ localhost：8443”，} 1.0

更新2

发现了这个：https://github.com/spring-projects/spring-framework/issues/20474！

更新3

我尝试使用默认的连接数（即500），并且我可以注意到，每次执行 后，活动连接的数量都会不断增加：-（

[reactor-http-nio-2]调试r.n.resources.PooledConnectionProvider- [id：0x2316e048，L：/127.0.0.1：32787-R：localhost / 127.0.0.1：8443] 通道已连接，现在有7个活动连接和0个非活动连接

解决方法

这对我有用：

HttpStatus httpStatus = null;
Mono<HttpStatus> monoHttpStatus  = null;
:           
WebClient webClient = xxx.getWebClient();
:       
try {
    monoHttpStatus  = webClient
        .post()
        .uri(someUri)
        .headers(someHeaders)
        .bodyValue(someBody)
        .exchange()
        .map(clientResponse -> 
            clientResponse.releaseBody().thenReturn(clientResponse.statusCode()))
        .timeout(someTimeout)
        .doOnError(Exception.class,e -> logger.error("An exception has occurred: ",e))
        .onErrorResume(ex -> Mono.empty())
        .block();
                
        if(monoHttpStatus != null)
            httpStatus = monoHttpStatus.block();            
}
:

//SomeOtherClass
@Autowired
private WebClient.Builder webClientBuilder;
public WebClient getWebClient() {
        
    :
    
    webClient= webClientBuilder.baseUrl(baseUrl)
                   .build();
    :   
    return webClient;
}

在 post 完成后，我现在看到了这一点：

DEBUG Reactor.util.Loggers $ Slf4JLogger.debug [249] [reactor-http-nio-1] [id：0x6b0568a3，L：/127.0.0.1：10168-R：localhost / 127.0.0.1：8443] 发布频道
调试反应堆.util.Loggers $ Slf4JLogger.debug [254] [reactor-http-nio-1] [id：0x6b0568a3，L：/127.0.0.1：10168- R：localhost / 127.0.0.1：8443]通道已清除，现在有0个活动连接 和1个无效的连接