首页 > 解决方案 > 如何为 WebClient 设置基本 url 和查询参数?

问题描述

在我的服务中,我必须从一些带有参数的不同 url 获得响应。

  1. http://a.com:8080/path1?param1=v1获取
  2. http://b.com:8080/path2?param2=v2获取
  3. http://c.com:8080/path3?param3=v3获取

我正在使用 WebClient 来完成以下工作。

public class WebClientTest {
    private WebClient webClient = WebClient.builder().build();

    @Test
    public void webClientTest() {
        Mono<String> a = webClient.get()
            .uri(uriBuilder -> uriBuilder.scheme("http").host("a.com").port(8080).path("/path1")
                    .queryParam("param1", "v1")
                    .build())
            .retrieve()
            .bodyToMono(String.class);

        Mono<String> b = webClient.get()
            .uri(uriBuilder -> uriBuilder.scheme("http").host("b.com").port(8080).path("/path2")
                    .queryParam("param2", "v2")
                    .build())
            .retrieve()
            .bodyToMono(String.class);

        Mono<String> c = webClient.get()
            .uri(uriBuilder -> uriBuilder.scheme("http").host("c.com").port(8080).path("/path3")
                    .queryParam("param3", "v3")
                    .build())
            .retrieve()
            .bodyToMono(String.class);

        //zip the result
    }
}

如您所见,我必须一次又一次地分别设置方案、主机、端口。
所以我的问题是:
1. 我是否以正确的方式使用 WebClient?
2. 一个方法中是否可以同时设置scheme、host、port?我知道这webClient.get().uri("http://a.com:8080/path1?param1=v1").retrieve()行得通,但我期待的是:

    webClient.get()
            .uri(uriBuilder -> uriBuilder/*.url("http://a.com:8080/path1")*/
                    .queryParam("param1", "v1")
                    .build())
            .retrieve()
            .bodyToMono(String.class);

标签: springspring-webflux

解决方案


从 Spring Framework 5.2 开始,还有一个额外的方法可以帮助您解决特定情况:

Mono<String> response = this.webClient
    .get()
    .uri("http://a.com:8080/path1", uri -> uri.queryParam("param1", "v1").build())
    .retrieve()
    .bodyToMono(String.class);

WebClient作为一般规则,我不建议为每个主机创建一个。这实际上取决于您的用例。在这里,您的客户端似乎可能会向许多主机发送请求,并且在这里创建许多 HTTP 客户端可能有点浪费。


推荐阅读