ICode9

精准搜索请尝试: 精确搜索
首页 > 其他分享> 文章详细

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

2019-07-22 07:19:22  阅读:164  来源: 互联网

标签:spring spring-webflux


通过Spring WebClient进行api调用的正确方法是什么,但忽略了结果? ClientResponse对象专门调用我必须对结果做一些事情……

Docs:

NOTE: When given access to a ClientResponse, through the WebClient exchange() method, you must always use one of the body or toEntity methods to ensure resources are released and avoid potential issues with HTTP connection pooling. You can use bodyToMono(Void.class) if no response content is expected. However keep in mind that if the response does have content, the connection will be closed and will not be placed back in the pool.

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

解决方法:

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

标签:spring,spring-webflux
来源: https://codeday.me/bug/20190722/1500183.html

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有