RESTful communication is the de-facto standard for interchanging data in a microservice-based environment. Usually, every participating microservice offers different parts of the application’s domain in a RESTful way and calls other microservices to gather data for e.g. a different part of the application’s domain. Resilience and efficient data interchange is, therefore, a key factor when it comes to the success of the whole application. With Spring we usually made use of the RestTemplate to perform HTTP requests, but can now also use the Spring WebClient.
With the release of Spring Framework 5.0, the documentation of the RestTemplate says the following:
NOTE:Â As of 5.0, the non-blocking, reactiveÂ
org.springframework.web.reactive.client.WebClient offers a modern alternative to theÂRestTemplate with efficient support for both sync and async, as well as streaming scenarios. TheÂRestTemplatewill be deprecated in a future version and will not have major new features added going forward. See the WebClient section of the Spring Framework reference documentation for more details and example code.
To be future-ready, your Spring-based application should migrate to reactive and non-blocking Spring WebClient for both its async & sync HTTP communication.
In this blog post, I’ll demonstrate how to work with the WebClient class to master common tasks like HTTP GET/POST requests, configuration, filtering requests, and testing. For the demo application, I’ll use Java 11 and Spring Boot 2.2.
Configure the WebClient
For utilizing the WebClient, you need the following dependency in your Spring Boot project:
1 2 3 4 | <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-webflux</artifactId> </dependency> |
The WebClient internally delegates to an HTTP client library (by default Reactor Netty), but others can be plugged in through a ClientHttpConnector. More information about the WebClient is available here.
When it comes to configuring resilient HTTP clients, connection/read/write timeouts are important to avoid long-running tasks. In addition, HTTP headers and cookies are essential for e.g. authentication or content-negotiation. With WebClient, you can make use of a builder to configure this:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 | @Component public class SimpleWebClientConfiguration { private static final String BASE_URL = "https://jsonplaceholder.typicode.com"; @Bean public WebClient defaultWebClient() { var tcpClient = TcpClient.create() .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 2_000) .doOnConnected(connection -> connection.addHandlerLast(new ReadTimeoutHandler(2)) .addHandlerLast(new WriteTimeoutHandler(2))); return WebClient.builder() .baseUrl(BASE_URL) .clientConnector(new ReactorClientHttpConnector(HttpClient.from(tcpClient))) .defaultCookie("cookieKey", "cookieValue", "teapot", "amsterdam") .defaultCookie("secretToken", UUID.randomUUID().toString()) .defaultHeader(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE) .defaultHeader(HttpHeaders.ACCEPT, MediaType.APPLICATION_JSON_VALUE) .defaultHeader(HttpHeaders.USER_AGENT, "I'm a teapot") .build(); } } |
Make an HTTP GET request with Spring WebClient
Once your WebClient is configured for a specific baseUrl, you can start performing HTTP requests. As the internal WebClient architecture is designed for reactive and non-blocking applications, you either have to call .block() or rewrite your codebase to accept Mono<T> and Flux<T> as method return types.
A simple sync HTTP GET request with our previously configured WebClient looks like the following:
1 2 3 4 5 6 7 8 9 10 11 12 13 | @Service public class SimpleApiClient { @Autowired private WebClient defaultWebClient; public JsonNode getTodoFromAPI() { return this.defaultWebClient.get().uri("/todos/1") .retrieve() .bodyToMono(JsonNode.class) .block(); } } |
For actually performing an HTTP request, you can either use .retrieve() or .exchange() whereby the first method is the easiest way and .exchange() offers more control (have a look at the official documentation to understand the difference in detail). For simplification, I’ll use .retrieve() in all examples.
By default, HTTP responses with 4xx (e.g. 404 for not found) or 5xx (e.g. 500 service unavailable) status codes result in an WebClientResponseException. For modifying the way how errors are handled, you can use the onStatus method of Spring’s WebClient to customize the resulting exception:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 | @Service public class SimpleApiClient { @Autowired private WebClient defaultWebClient; public JsonNode getTodoFromAPI() { return this.defaultWebClient.get().uri("/todos/1") .retrieve() .onStatus(HttpStatus::is4xxClientError, response -> { System.out.println("4xx eror"); return Mono.error(new RuntimeException("4xx")); }) .onStatus(HttpStatus::is5xxServerError, response -> { System.out.println("5xx eror"); return Mono.error(new RuntimeException("5xx")); }) .bodyToMono(JsonNode.class) .block(); } } |
Make an HTTP POST request
Performing HTTP POST request with the WebClient is as simple as the following:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 | @Service public class SimpleApiClient { @Autowired private WebClient defaultWebClient; public JsonNode postToTodoAPI() { return this.defaultWebClient .post() .uri("/todos") .body(BodyInserters.fromObject( "{ \"title\": \"foo\", \"body\": \"bar\", \"userId\": \"1\"}")) .retrieve() .bodyToMono(JsonNode.class) .block(); } } |
To put the request body in place you can use the BodyInserters utility class and add any kind of Object, FormData, Publisher, MultipartData, Resource and much more.
Configure filters for the Spring WebClient
If you have business logic or a configuration setup which should be applied to every HTTP request and response made with the WebClient, you can configure and chain multiple filters.
Logging the request/response might be such a requirement or applying authentication to the request. This is configured during the WebClient setup:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 | @Component public class SimpleWebClientConfiguration { private static final String BASE_URL = "https://jsonplaceholder.typicode.com"; private static final Logger logger = LoggerFactory.getLogger(SimpleApiClient.class); @Bean public WebClient defaultWebClient() { var tcpClient = TcpClient.create() .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 2_000) .doOnConnected(connection -> connection.addHandlerLast(new ReadTimeoutHandler(2)) .addHandlerLast(new WriteTimeoutHandler(2))); return WebClient.builder() .baseUrl(BASE_URL) .clientConnector(new ReactorClientHttpConnector(HttpClient.from(tcpClient))) .defaultCookie("cookieKey", "cookieValue", "teapot", "amsterdam") .defaultCookie("secretToken", UUID.randomUUID().toString()) .defaultHeader(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE) .defaultHeader(HttpHeaders.ACCEPT, MediaType.APPLICATION_JSON_VALUE) .defaultHeader(HttpHeaders.USER_AGENT, "I'm a teapot") .filter(ExchangeFilterFunctions.basicAuthentication("rieckpil", UUID.randomUUID().toString())) .filter(logRequest()) .filter(logResponse()) .build(); } private ExchangeFilterFunction logRequest() { return (clientRequest, next) -> { logger.info("Request: {} {}", clientRequest.method(), clientRequest.url()); logger.info("--- Http Headers: ---"); clientRequest.headers().forEach(this::logHeader); logger.info("--- Http Cookies: ---"); clientRequest.cookies().forEach(this::logHeader); return next.exchange(clientRequest); }; } private ExchangeFilterFunction logResponse() { return ExchangeFilterFunction.ofResponseProcessor(clientResponse -> { logger.info("Response: {} {}", clientResponse.statusCode(), clientResponse.cookies()); clientResponse.headers().asHttpHeaders() .forEach((name, values) -> values.forEach(value -> logger.info("{}={}", name, value))); return Mono.just(clientResponse); }); } private void logHeader(String name, List<String> values) { values.forEach(value -> logger.info("{}={}", name, value)); } } |
Testing with WebTestClient
For efficient testing, you can make use of the WebTestClient during your integration tests. This client offers the same functionality as the normal WebClient and convenience methods for assertions and expectations in addition:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 | @ExtendWith(SpringExtension.class) @SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT) class SimpleApiClientTest { @Autowired private WebTestClient webTestClient; @Test public void testGetTodosAPICall() { this.webTestClient .get() .uri("https://jsonplaceholder.typicode.com/todos/1") .accept(MediaType.APPLICATION_JSON) .exchange() .expectStatus().isOk() .expectHeader().contentType(MediaType.APPLICATION_JSON_UTF8_VALUE) .expectBody() .jsonPath("$.title").isNotEmpty() .jsonPath("$.userId").isNotEmpty() .jsonPath("$.completed").isNotEmpty(); } @Test public void testPostNewTodoCall() { this.webTestClient .post() .uri("https://jsonplaceholder.typicode.com/todos") .contentType(MediaType.APPLICATION_JSON) .accept(MediaType.APPLICATION_JSON) .body(BodyInserters.fromObject( "{ \"title\": \"foo\", \"body\": \"bar\", \"userId\": \"1\"}")) .exchange() .expectStatus().isCreated() .expectHeader().contentType(MediaType.APPLICATION_JSON_UTF8_VALUE) .expectBody() .jsonPath("$.title").isNotEmpty() .jsonPath("$.body").isNotEmpty() .jsonPath("$.userId").isNotEmpty() .jsonPath("$.userId").isEqualTo("1") .jsonPath("$.id").isNotEmpty(); } } |
You can find the full source code for all examples on GitHub. If you want to achieve the same with Java EE, have a look at the JAX-RS Client or the MicroProfile RestClient.
Have fun using the new SpringWebClient,
Phil
1 comment
[…] one of my recent blog posts, I presented Spring’s WebClient for RESTful communication. With Java EE we can utilize the […]