如何使用webflux Webclient创建带有参数的请求？

java spring spring-webflux

2022-09-02 23:33:02

在后端，我有带有POST方法的REST控制器：

@RequestMapping(value = "/save", method = RequestMethod.POST)
public Integer save(@RequestParam String name) {
   //do save
   return 0;
}

如何使用带有请求参数的WebClient创建请求？

WebClient.create(url).post()
    .uri("/save")
    //?
    .exchange()
    .block()
    .bodyToMono(Integer.class)
    .block();

答案 1

在创建 URI 时，存在许多编码挑战。为了获得更大的灵活性，同时仍然在编码部分，为URI提供了一个基于生成器的变体：WebClient

WebClient.create().get()
    .uri(builder -> builder.scheme("http")
                    .host("example.org").path("save")
                    .queryParam("name", "spring-framework")
                    .build())
    .retrieve()
    .bodyToMono(String.class);

答案 2

寄件人： https://www.callicoder.com/spring-5-reactive-webclient-webtestclient-examples/

在配置类中，您可以定义主机：

@Bean(name = "providerWebClient")
WebClient providerWebClient(@Value("${external-rest.provider.base-url}") String providerBaseUrl) {
return WebClient.builder().baseUrl(providerBaseUrl)
    .clientConnector(clientConnector()).build();
}

然后，您可以使用 WebClient instace：

@Qualifier("providerWebClient")
private final WebClient webClient;

webClient.get()
        .uri(uriBuilder -> uriBuilder.path("/provider/repos")
                .queryParam("sort", "updated")
                .queryParam("direction", "desc")
                .build())
        .header("Authorization", "Basic " + Base64Utils
                .encodeToString((username + ":" + token).getBytes(UTF_8)))
        .retrieve()
        .bodyToFlux(GithubRepo.class);