如何使用WebFlux和Netty HttpClient访问请求体 [英] How to access to request body using WebFlux and Netty HttpClient
本文介绍了如何使用WebFlux和Netty HttpClient访问请求体的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
我需要使用Webflow的WebClient计算请求正文的某种摘要,并且必须将该摘要设置为一个HTTP标头。使用老的Spring MVCClientHttpRequestInterceptor很容易,因为请求主体是以字节数组的形式提供的。
ExchangeFilterFunction不提供对请求正文的访问。
主体作为json发送,而Spring使用Jackson来序列化Java对象,因此可以选择将我的对象序列化为Json并计算其摘要,但此策略有两个缺点:
- 我的代码将重复Spring在实际发送请求时将执行的操作
- 不能保证Spring作为请求发送的急性字节数等于我传递给摘要函数的字节数
我想我应该使用Netty的一些底层API,但我找不到任何示例。
推荐答案
我实现了@rewolf提出的解决方案,它起作用了,但由于WebFlux的多线程特性,我遇到了一个问题。
事实上,客户端请求可能由一个线程保存到线程本地映射中,但另一个线程尝试获取它,因此返回空值。
例如,如果要签名的请求是在REST控制器方法中创建的,该方法将Mono作为请求主体参数:
@PostMapping
public String execute(@RequestBody Mono<MyBody> body){
Mono<OtherBody> otherBody = body.map(this::transformBodyIntoOtherBody);
...
webClient.post()
.body(otherBody)
.exchange();
...
}
根据反应器规范,应该使用反应器上下文而不是线程本地。
我派生了@rewolf项目,并实现了基于反应堆上下文的解决方案:https://github.com/taxone/blog-hmac-auth-webclient
这篇关于如何使用WebFlux和Netty HttpClient访问请求体的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!
查看全文