How to use Spring WebClient to make multiple calls simultaneously and get response separately?

Question

I have to execute multiple API calls simultaneously which are independent of each other:

Mono<Response1> response1= this.webClient
               .post()
               .uri(requestURI1)
               .body(Flux.just(request.getRequestBody()), ParameterizedTypeReference<T>)
               .exchangeToMono(response -> {
                   return response.statusCode().equals(HttpStatus.OK)
                            ? response.bodyToMono(ParameterizedTypeReference<T>)
                            : response.createException().flatMap(Mono::error);
                });

Mono<Response2> response2= this.webClient
               .post()
               .uri(requestURI2)
               .body(Flux.just(request.getRequestBody()), ParameterizedTypeReference<T>)
               .exchangeToMono(response -> {
                   return response.statusCode().equals(HttpStatus.OK)
                            ? response.bodyToMono(ParameterizedTypeReference<T>)
                            : response.createException().flatMap(Mono::error);
                });

Mono<Response3> response3= this.webClient
               .post()
               .uri(requestURI3)
               .body(Flux.just(request.getRequestBody()), ParameterizedTypeReference<T>)
               .exchangeToMono(response -> {
                   return response.statusCode().equals(HttpStatus.OK)
                            ? response.bodyToMono(ParameterizedTypeReference<T>)
                            : response.createException().flatMap(Mono::error);
                });

How can I get the response of above api calls in separate Objects and at the same time, they should be executed in parallel? Also, after executing these above calls and putting the data in separate objects, say, Response1, Response2, Response3, I want to execute another API call which consumes these responses Response1, Response2, Response3.

I have tried to use Flux.merge but this will merge the responses in single object which is not correct. Also read about Mono.zip, but these all are used to combine the responses which I don't want.

EDIT: Mono.zip works perfectly. I have a follow up question which I have mentioned in comments but posting it here also. So I have implemented like this:

Mono.zip(rs1, rs2, rs3).flatMap(tuples -> {
//do something with responses
return Mono.just(transformedData)
}).flatMap(transformedData -> {
//here another webclient.post call which consumes transformedData and return actualData in form of Mono<actualData>

Mono<actualData> data= callAPI;
return data;
});

Now this response is propagated to rest layer in form of Mono<actualData> and I am getting this in response: {
    "scanAvailable": true
}

Alex · Accepted Answer · 2022-03-22T16:29:29.900

0

To combine publishers in parallel you can use Mono.zip that will return TupleX<...> and will be resolved when all publishers are resolved.

Mono<Tuple3<Response1, Response2, Response3>> res = Mono.zip(response1, response2, response3)
        .map(tuples -> {
            //do something with responses
            return transformedData;
        })
        .flatMap(transformedData -> {
            //here another webclient.post call which consumes transformedData and return actualData in form of Mono<actualData>
            return callAPI(transformedData);
        });

Depending on the error handling logic you could consider zipDelayError

As I mentioned in comment one of the key things with reactive API is to differentiate sync and async operations. In case of sync transformation, chain it with .map and use .flatMap or similar operator in case you want to chain another async method.

edited Mar 22 '22 at 16:29

answered Mar 15 '22 at 15:42

Alex

4,987
1
8
26

Yes this works. Thanks a lot. I just need to ask 1 follow up question: The above method is invoked inside of a service through an API call. Now, After I got the response from all these publishers in this method, I want to transform the data to some other object, say - TestData and needed to return that object as a response to my API. How can I achieve that in a non blocking way.? Do I have to return Mono object? Or I can return TestData as response directly? – Abhishek Wadhwa Mar 22 '22 at 15:03
In case this is just transformation, chain it with `.map` getting `Tuple3` as an input and returning `TestData`. – Alex Mar 22 '22 at 15:31
So I have implemented like this: Mono.zip(rs1, rs2, rs3).flatMap(tuples -> { //do something with responses return Mono.just(transformedData) }).flatMap(transformedData -> { //here another webclient.post call which consumes transformedData and return actualData in form of Mono Mono data= callAPI; return data; }); Now this response is propagated to rest layer in form of Mono and I am getting this in response: { "scanAvailable": true } – Abhishek Wadhwa Mar 22 '22 at 15:34
It’s hard to read the code here. I would suggest to update the original question. – Alex Mar 22 '22 at 15:43
One of the key things with reactive API is to differentiate sync and async operations. As I mentioned in prev comment in case of sync transformation, chain it with `.map` and use `.flatMap` in case you want to chain another async operation similar to your origin as l requests – Alex Mar 22 '22 at 15:48
@Abhishek Wadhwa check updated answer. – Alex Mar 22 '22 at 16:30

How to use Spring WebClient to make multiple calls simultaneously and get response separately?

1 Answers1

Linked