Spring WebFlux，提取请求体

Question

我正在编写一个小型 WebFlux 客户端代理，它将接受 POST 请求，提取 JSON 内容，然后通过另一个 POST 将其传递给第三方 Web 服务器的进一步调用。我想在我的原始 POST 请求中获取 json 正文。

curl --header "Content-Type: application/json" \
  --request POST \
  --data '{"username":"xyz", "preference":"123"}' \
  http://localhost:3000/mih/search

这是我处理上述 POST 的路线：

@Bean
open fun route(searchService: SearchService): RouterFunction<ServerResponse> {
    return RouterFunctions.route(
            RequestPredicates.POST("/search").and(RequestPredicates.accept(MediaType.APPLICATION_JSON)),
            HandlerFunction {
                    request: ServerRequest -> searchService.search(request.body(BodyExtractors.toMono(String::class.java)))
            } )
    }

open class SearchService(private val myWebClient: MyWebClient): ISearchService {

    override fun search(json: String): Mono<ServerResponse> {
        return myWebClient.myPost(json)
    }
}

import org.springframework.web.reactive.function.client.WebClient

open class MyWebClient(
    private val springWebClient: WebClient,
    private val properties: properties ) : IMyWebClient {

    override fun myPost(json: String): Mono<ServerResponse> {
        return springWebClient.post()
            .uri("/{base}/queries", properties.getBase)
            .body(
                BodyInserters.fromPublisher(Mono.just(json), String::class.java)
            ).retrieve().bodyToMono(
                ServerResponse::class.java
            )
    }
}

当我转到 .subscribe() 到 Mono<String> 时，我得到了

Type mismatch.
  Required: String
  Found: Disposable

如何成功提取请求正文？

Answer 1

根据文档： https://docs.spring.io/spring/docs/current/javadoc-api/org/springframework/web/reactive/function/client/WebClient.html#post--

post() 返回 WebClient.RequestBodyUriSpec 而不是 ServerResponse

您对 API 的使用不正确。您应该在search() 方法调用之后使用.retrieve()。

在您的情况下，.body() 应用于 POST 请求正文。

您应该继续：

.search().retrieve().bodyToMono(String.class)