Spring Webflux WebClient

user_4731385 0
Viewed 2498

I don't really know how to translate the following call to the spring webflux webclient correctly.

userIds is the List and I was able to call the service using the following syntax but I could not get that working with the Spring WebFlux WebClient. Please help me if there is any of you know how to do it.

String url = "http://profile.service.com/v1/profiles/bulk";
RestTemplate restTemplate = new RestTemplate();
HttpHeaders headers = new HttpHeaders();
headers.setContentType(MediaType.APPLICATION_JSON);
headers.setAccept(Arrays.asList(MediaType.APPLICATION_JSON));

ResponseEntity<List<MiniProfile>> responseEntity;
try {
    responseEntity = restTemplate.exchange(url, HttpMethod.POST, new 
    HttpEntity(userIds, headers), new 
    ParameterizedTypeReference<List<MiniProfile>>() {});
} catch (RestClientException e) {
    responseEntity = new ResponseEntity<List<MiniProfile>>(HttpStatus.OK);
}

return responseEntity.getBody();

This is the way I got it translate to the Webflux WebClient:

Flux<String> flux = Flux.fromIterable(userIds);
return readWebClient.post().uri("/v1/profiles/bulk")
      .body(BodyInserters.fromPublisher(flux, String.class))
      .retrieve().bodyToFlux(MiniProfile.class);
spring-webflux spring-boot
4 Answers

You should not change your list to flux, you should send it as list like this

return readWebClient.post()
  .uri("/v1/profiles/bulk")
  .syncBody(userIds)
  .retrieve()
  .bodyToFlux(new ParameterizedTypeReference<List<MiniProfile>>() {})
  .flatMapIterable(Function.identity());

this code is not tested but the principe is the same

user_79224290

Use .bodyValue(userIds) or .syncBody(userIds) (Deprecated) instead of body with Body inserter

user_28160190

**you can refer below mentioned code snippets **

WebClient.post().uri(endPointUrl)
           .contentType(MediaType.APPLICATION_XML)
          .body(Mono.just(xmlEntity), String.class)
          .retrieve()
user_59289790

It's good to use WebClient for reactive call such this.

@Autowired
private WebClient.Builder webClientBuilder;

webClientBuilder.build().post()
                .uri("http://profile.service.com/v1/profiles/bulk")
                .body(BodyInserters.fromPublisher(Mono.just(new YourBodyClass()),YourBodyClass.class))
                .headers(httpHeaders -> {
                    httpHeaders.setContentType(MediaType.APPLICATION_JSON);
                    httpHeaders.setAccept(Arrays.asList(MediaType.APPLICATION_JSON));
                })
                .retrieve().bodyToFlux(MiniProfile.class);
user_177254650
Related