如何使用WebFlux和Netty HttpClient访问请求体 [英] How to access to request body using WebFlux and Netty HttpClient

查看:5
本文介绍了如何使用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屋!

查看全文
登录 关闭
扫码关注1秒登录
发送“验证码”获取 | 15天全站免登陆