首页 文章

通过spring`WebClient`进行api调用的正确方法是什么,但忽略了结果?

提问于
浏览
3

通过spring WebClient 进行api调用的正确方法是什么,但忽略结果? ClientResponse 对象特别指出我必须对结果做些什么......

Docs:

注意:当通过WebClient exchange()方法授予对ClientResponse的访问权限时,必须始终使用body或toEntity方法之一来确保释放资源并避免HTTP连接池的潜在问题 . 如果没有预期的响应内容,您可以使用bodyToMono(Void.class) . 但请记住,如果响应确实包含内容,则连接将关闭,并且不会放回池中 .

我可以进行WebClient调用并忽略结果吗?或者是否存在我可以使用然后忽略的通用捕获"body or toEntity method"?

1 回答

  • 7

    非常好的问题!在Javadoc中解释这一点有点棘手 - 如果你有关于如何改进它的想法,请随时在https://jira.spring.io上创建一个问题或发送拉取请求 .

    有几种方法可以做到这一点,但最好的解决方案取决于您的用例

    服务器未发送响应正文

    如果您确定服务器没有发送响应正文或者您希望尽快完成该请求,那么使用 bodyToMono(Void.class) 可能是一个不错的选择 .

    Mono<Void> result = webClient.post()
                    .contentType(MediaType.TEXT_PLAIN)
                    .syncBody("Spring WebFlux")
                    .retrieve().bodyToMono(Void.class);
    
    // you can then chain the result with result.then(otherMono)
    

    缺点是 - 如果服务器发送响应正文,Spring WebFlux将停止读取它并取消底层发布者 - 这将立即关闭HTTP连接,并且不会返回到客户端使用的连接池 .

    为什么?因为要正确地将连接返回到连接池,它必须保持干净状态;在这一点上,由于我们在阅读整个身体之前就已经关闭,我们无法回收这种联系 .

    TL; DR;如果您100%确定服务器不会发送正文,或者您宁愿浪费连接并支付创建新连接的价格而不是等待并阅读整个响应主体,尤其是如果它非常大,请使用此方法 .

    服务器正在发送响应正文

    现在,如果服务器确实发送了一个响应体并且您根本不关心它,那么您仍然可以获取正文但不对其执行任何操作并在完成时获取信号:

    Mono<String> result = webClient.post()
                    .contentType(MediaType.TEXT_PLAIN)
                    .syncBody("Spring WebFlux")
                    .retrieve().bodyToMono(String.class);
    
    // you can then chain the result with result.then(otherMono) or result.then()
    

    现在让's pretend the response body is really large and you don' t想用 String 或Java对象缓冲整个内存 . 在这种情况下,您可以降低到 DataBuffer 的级别(字节缓冲区的Spring抽象,可以汇集内存效率) .

    Mono<Void> result = webClient.post()
                    .contentType(MediaType.TEXT_PLAIN)
                    .syncBody("Spring WebFlux")
                    .retrieve()
                    // we're getting a Flux<DataBuffer>
                    .bodyToFlux(DataBuffer.class)
                    // they might be pooled so we need to release them to avoid memory leaks
                    .map(DataBufferUtils::release)
                    .then();
    

    TL; DR;最后一个选项是安全和优化的(但它并不简洁),但只要响应体不是超大,前一个选项就完全没问题了 .

相关问题