如何使用 Spring WebClient 同时进行多个调用？

Posted 2023-02-27

【中文标题】如何使用 Spring WebClient 同时进行多个调用？

【英文标题】：How to use Spring WebClient to make multiple calls simultaneously?

【发布时间】：2018-10-16 15:36:10

【问题描述】：

我想同时执行 3 个调用，并在它们全部完成后处理结果。

我知道这可以使用 AsyncRestTemplate 来实现，正如这里提到的 How to use AsyncRestTemplate to make multiple calls simultaneously?

但是，AsyncRestTemplate 已被弃用，取而代之的是 WebClient。我必须在项目中使用 Spring MVC，但如果我可以使用 WebClient 来执行同时调用，我很感兴趣。有人可以建议如何使用 WebClient 正确完成此操作吗？

【参考方案1】：

假设一个 WebClient 包装器（如在 reference doc 中）：

@Service
public class MyService 

    private final WebClient webClient;

    public MyService(WebClient.Builder webClientBuilder) 
        this.webClient = webClientBuilder.baseUrl("http://example.org").build();
    

    public Mono<Details> someRestCall(String name) 
        return this.webClient.get().url("/name/details", name)
                        .retrieve().bodyToMono(Details.class);
    

...，您可以通过以下方式异步调用它：

// ... 
  @Autowired
  MyService myService
  // ...

   Mono<Details> foo = myService.someRestCall("foo");
   Mono<Details> bar = myService.someRestCall("bar");
   Mono<Details> baz = myService.someRestCall("baz");
   
   // ..and use the results (thx to: [2] & [3]!):

   // Subscribes sequentially:

   // System.out.println("=== Flux.concat(foo, bar, baz) ===");
   // Flux.concat(foo, bar, baz).subscribe(System.out::print);
    
   // System.out.println("\n=== combine the value of foo then bar then baz ===");
   // foo.concatWith(bar).concatWith(baz).subscribe(System.out::print);
  
   // ----------------------------------------------------------------------
   // Subscribe eagerly (& simultaneously):
   System.out.println("\n=== Flux.merge(foo, bar, baz) ===");
   Flux.merge(foo, bar, baz).subscribe(System.out::print);

Mono javadoc

Flux javadoc

Spring WebClient reference doc

Spring Boot WebClient reference doc

Projectreactor reference doc

Which (reactive) operator to use!

谢谢，欢迎和亲切的问候，

【讨论】：

在这种情况下，应该有一个线程池用于所有应该完成的异步服务调用。但是是否可以使用 Webclient Nio 功能，触发所有请求，然后获取所有 Mono 来组合结果。在我的理解中，Mono 与 ListenableFuture 相同，get() 与 block() 相同，因此它应该与 WebClient 一起工作，就像它与 AsyncRestTemplate 一样

@xerx593 请用Flux.merge 更新您的答案，因为Flux.concat 按顺序订阅（REST 调用不会同时发生）-Flux.merge 急切地订阅所有发布者。

@ddzz Mono 和 ListenableFuture 在这里没有可比性，WebClient 和 AsyncRestTemplate 也没有可比性，所以我不确定你的意思。除了运营商的选择，这个答案对我来说是正确的。如果您对WebClient 背后的运行时模型有任何疑问，请提出另一个问题。

【参考方案2】：

另一种方式：

public Mono<Boolean> areVersionsOK()
        final Mono<Boolean> isPCFVersionOK = getPCFInfo2();
        final Mono<Boolean> isBlueMixVersionOK = getBluemixInfo2();

        return isPCFVersionOK.mergeWith(isBlueMixVersionOK)
            .filter(aBoolean -> 
                return aBoolean;
            )
            .collectList().map(booleans -> 
                return booleans.size() == 2;
        );

    

【参考方案3】：

您可以使用简单的RestTemplate 和ExecutorService 同时进行 HTTP 调用：

RestTemplate restTemplate = new RestTemplate();
ExecutorService executorService = Executors.newCachedThreadPool();

Future<String> firstCallFuture = executorService.submit(() -> restTemplate.getForObject("http://first-call-example.com", String.class));
Future<String> secondCallFuture = executorService.submit(() -> restTemplate.getForObject("http://second-call-example.com", String.class));

String firstResponse = firstCallFuture.get();
String secondResponse = secondCallFuture.get();

executorService.shutdown();

或者

Future<String> firstCallFuture = CompletableFuture.supplyAsync(() -> restTemplate.getForObject("http://first-call-example.com", String.class));
Future<String> secondCallFuture = CompletableFuture.supplyAsync(() -> restTemplate.getForObject("http://second-call-example.com", String.class));

String firstResponse = firstCallFuture.get();
String secondResponse = secondCallFuture.get();

【讨论】：

值得注意的是，RestTemplate 即将被弃用。

@Deniss M. Source?

唯一的一个：docs.spring.io/spring/docs/current/javadoc-api/index.html?org/…

谢谢，之前没注意。

这现在引起了很多头痛......尤其是重构所有依赖TestRestTemplate的测试......

【参考方案4】：

您可以使用 Spring 响应式客户端 WebClient 发送并行请求。 在这个例子中，

public Mono<UserInfo> getUserInfo(User user) 
        Mono<UserInfo> userInfoMono = getUserInfo(user.getId());
        Mono<OrgInfo> organizationInfoMono = getOrgInfo(user.getOrgId());

        return Mono.zip(userInfoMono, organizationInfoMono).map(tuple -> 
            UserInfo userInfo = tuple.getT1();
            userInfo.setOrganization(tuple.getT2());
            return userInfo;
        );
    

这里：

getUserInfo 进行 HTTP 调用以从另一个服务获取用户信息并返回 Mono getOrgInfo 方法进行 HTTP 调用以从另一个服务获取组织信息并返回 Mono Mono.zip() 等待所有单声道的所有结果并合并到一个新的单声道中并返回它。

然后，调用getOrgUserInfo().block()获取最终结果。