Estoy usando WebClient para llamar a Rest API que están protegidas por el token JWT. // Para obtener Token

JwtToken token = client.post()
                .uri("")
                .body(BodyInserters.fromFormData("username", "XXX")
                        .with("password", "XXXXX"))
                .retrieve()
                .bodyToFlux(JwtToken.class)
                .onErrorMap(e -> new Exception("Error While getting Token", e))
                .blockLast(); 

// Llamar a API segura

 WebClient client = consorsWebClientBuilder
                .defaultHeaders(token.bearer())
                .build();

              client
                .get()
                .uri(someURI)
                .retrieve()
                .bodyToMono(String.class)

Estoy llamando a Block en cadena reactiva, por lo que Web Flux no está contento y digo

block () / blockFirst () / blockLast () están bloqueando, lo que no es compatible con thread reactor-http-client-epoll-12

¿Cómo puedo agregar token de forma reactiva? Tenga en cuenta que puedo crear un filtro, pero aún en el filtro, también necesito llamar a Block

0
Niraj Sonawane 17 feb. 2020 a las 20:04

2 respuestas

La mejor respuesta
I used map for this, not the best solution but does the work

Mono<JwtToken>  token = client.post()
                .uri("")
                .body(BodyInserters.fromFormData("username", "XXX")
                        .with("password", "XXXXX"))
                .retrieve()
                .bodyToMon(JwtToken.class)
                .onErrorMap(e -> new Exception("Error While getting Token", e))


return token
     .flatMap(token -> callApi(request, token));
0
Niraj Sonawane 18 feb. 2020 a las 10:12

Puedes usar el doOnSuccess

client.post()
      .uri("")
      .body(BodyInserters.fromFormData("username", "XXX")
                    .with("password", "XXXXX"))
      .retrieve()
      .bodyToFlux(JwtToken.class)
      .onErrorMap(e -> new Exception("Error While getting Token", e))
      .doOnSuccess(jwtToken -> {
                client.header(HttpHeaders.AUTHORIZATION, "bearer " + jwtToken)
                      .get()
                      ...
      })
1
Thomas Andolf 17 feb. 2020 a las 22:18