Миграция с RestTemplate на WebFlux

Чтобы сделать запрос и получить ответ, вам нужно вызвать функцию retrieve в WebClient. Затем вы можете проанализировать тело ответа с помощью bodyToMono. Важно знать, что Mono — это один объект, а Flux — это типы коллекций.

Envelope envelope = WebClient.builder()
                .build()
                .get()
                .uri("https://www.ecb.europa.eu/stats/eurofxref/eurofxref-daily.xml")
                .accept(MediaType.APPLICATION_XML)
                .exchangeToMono(res -> Mono.just(res.statusCode().equals(HttpStatus.OK)))
                .timeout(Duration.ofSeconds(2))
                .retrieve()
                .bodyToMono(Envelope.class)
                .block();

На этой странице также есть хороший пример и объяснение: https://www.baeldung.com/webflux-webclient-parameters

Но я бы посоветовал вам немного больше структурировать свой код. Например, когда вы используете Spring Boot, подумайте об использовании этого WebClientBuilder для создания WebClient как Bean, этот WebClient будет настроен на наличие базового URL-адреса (https://www.ecb.europa.eu). Затем у вас есть сервис, в который вы внедряете этот веб-клиент и совершаете вызов, чтобы получить свой конверт. Что-то вроде этого позволит вам использовать один и тот же WebCLient для разных вызовов одного и того же хоста:

import java.util.List;
import java.util.concurrent.TimeUnit;

import io.netty.channel.ChannelOption;
import io.netty.handler.timeout.ReadTimeoutHandler;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.MediaType;
import org.springframework.http.client.reactive.ClientHttpConnector;
import org.springframework.http.client.reactive.ReactorClientHttpConnector;
import org.springframework.stereotype.Service;
import org.springframework.web.reactive.function.client.WebClient;
import reactor.netty.http.client.HttpClient;

@Configuration
public class RestConfig {
    @Bean
    public WebClient ecbEuropaWebClient(WebClient.Builder webClientBuilder) {
        HttpClient httpClient = HttpClient.create().tcpConfiguration(
                (client) -> client.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 2000).doOnConnected(
                        (connection) -> connection.addHandlerLast(
                                new ReadTimeoutHandler(2000, TimeUnit.MILLISECONDS))));
        ClientHttpConnector connector = new ReactorClientHttpConnector(httpClient);
        return webClientBuilder
                .baseUrl("https://www.ecb.europa.eu")
                .clientConnector(connector)
                .build();
    }
}

@Service
public class EcbEuropaService {
    @Autowired
    private WebClient ecbEuropaWebClient;

    public Envelope getEnvelope() {
        return ecbEuropaWebClient.get()
                .uri(uriBuilder -> uriBuilder.path("/stats/eurofxref/eurofxref-daily.xml").build())
                .accept(MediaType.APPLICATION_XML).retrieve().bodyToMono(Envelope.class).block();
    }
}