是否可以将流量传递到webClient Post的正文？

Question

@PostMapping("/products")
Flux<Product> getProducts(@RequestBody Flux<String> ids) {
    return Flux...
}

在客户端，我想使用这个endpoint，但不确定如何在主体中传递字符串流（我不想将其设置为列表）

Flux<Product> getProducts(Flux<String> ids) {
  return webClient.post().uri("/products")
      .body(/* .. how should I do here? ..*/)
      .retrieve()
      .bodyToFlux(Product.class);
}

Answer 1

实际上，您可以在WebClient上的.body()方法中传递一个流量

Flux<Person> personFlux = ... ;

Mono<Void> result = client.post()
        .uri("/persons/{id}", id)
        .contentType(MediaType.APPLICATION_STREAM_JSON)
        .body(personFlux, Person.class)
        .retrieve()
        .bodyToMono(Void.class);

示例摘自Spring参考文档

您要使用的body()方法的变体是：

<T,P extends org.reactivestreams.Publisher<T>> WebClient.RequestHeadersSpec<?> body(P publisher,
                                                                                    Class<T> elementClass)