Как использовать Spring WebClient для одновременного совершения нескольких звонков? - PullRequest
Новая
       37

Как использовать Spring WebClient для одновременного совершения нескольких звонков?

0 голосов
/ 06 мая 2018

Я хочу выполнить 3 вызова одновременно и обработать результаты, как только они все будут сделаны.

Я знаю, что это может быть достигнуто с помощью AsyncRestTemplate, как упомянуто здесь Как использовать AsyncRestTemplate для одновременного выполнения нескольких вызовов?

Однако AsyncRestTemplate устарела в пользу WebClient. Я должен использовать Spring MVC в проекте, но мне интересно, могу ли я использовать WebClient только для выполнения одновременных вызовов. Может кто-нибудь посоветовать, как это должно быть сделано правильно с WebClient?

Ответы [ 3 ]

0 голосов
/ 26 февраля 2019

Другой способ: 

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;
        });

    }
0 голосов
/ 30 мая 2019

Вы можете совершать HTTP-вызовы одновременно, используя простые RestTemplate и ExecutorService: 

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();
0 голосов
/ 06 мая 2018

Предполагается, что оболочка WebClient (как в справочный документ ): 

@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);

[2] [3]

Спасибо, добро пожаловать, С уважением,

...