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

Question

通过弹簧进行api调用的正确方法是什么WebClient,但忽略结果？该ClientResponse对象明确指出我必须对结果做一些事情......

文档:

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

我可以进行WebClient调用并忽略结果吗？或者是否有一个通用的捕获我可以使用然后忽略的所有"body或toEntity方法"？

Answer 1

非常好的问题!在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()

现在让我们假装响应体非常大,你不想用一个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; 最后一个选项是安全和优化的(但它并不是非常简洁),但只要响应体不是超大,前一个选项就完全没问题了.