iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

added and ordered tests in WebClientIntegrationTest to match article - test not passing (reusing specs)

Browse Source
This commit is contained in:
Gerardo Roza 2021-01-24 15:18:29 -03:00
parent 725465b0b6
commit 2bc7dbc708
1 changed files with 58 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

82
spring-5-reactive/src/test/java/com/baeldung/web/client/WebClientIntegrationTest.java
View File

@ -1,7 +1,7 @@
package com.baeldung.web.client; package com.baeldung.web.client;
import java.net.URI; import java.net.URI;
import java.nio.charset.Charset; import java.nio.charset.StandardCharsets;
import java.time.ZonedDateTime; import java.time.ZonedDateTime;
import java.util.Collections; import java.util.Collections;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
@ -10,6 +10,7 @@ import org.junit.jupiter.api.Test;
import org.reactivestreams.Publisher; import org.reactivestreams.Publisher;
import org.reactivestreams.Subscriber; import org.reactivestreams.Subscriber;
import org.springframework.boot.test.context.SpringBootTest; import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.boot.test.context.SpringBootTest.WebEnvironment;
import org.springframework.boot.web.server.LocalServerPort; import org.springframework.boot.web.server.LocalServerPort;
import org.springframework.http.HttpHeaders; import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpMethod; import org.springframework.http.HttpMethod;
@ -22,6 +23,10 @@ import org.springframework.util.MultiValueMap;
import org.springframework.web.reactive.function.BodyInserter; import org.springframework.web.reactive.function.BodyInserter;
import org.springframework.web.reactive.function.BodyInserters; import org.springframework.web.reactive.function.BodyInserters;
import org.springframework.web.reactive.function.client.WebClient; import org.springframework.web.reactive.function.client.WebClient;
import org.springframework.web.reactive.function.client.WebClient.RequestBodySpec;
import org.springframework.web.reactive.function.client.WebClient.RequestHeadersSpec;
import org.springframework.web.reactive.function.client.WebClient.ResponseSpec;
import org.springframework.web.reactive.function.client.WebClient.UriSpec;
import com.baeldung.web.reactive.client.WebClientApplication; import com.baeldung.web.reactive.client.WebClientApplication;
@ -31,7 +36,7 @@ import io.netty.handler.timeout.WriteTimeoutHandler;
import reactor.core.publisher.Mono; import reactor.core.publisher.Mono;
import reactor.netty.http.client.HttpClient; import reactor.netty.http.client.HttpClient;
@SpringBootTest(classes = WebClientApplication.class, webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT) @SpringBootTest(classes = WebClientApplication.class, webEnvironment = WebEnvironment.RANDOM_PORT)
public class WebClientIntegrationTest { public class WebClientIntegrationTest {
@LocalServerPort @LocalServerPort
@ -40,44 +45,73 @@ public class WebClientIntegrationTest {
@Test @Test
public void demonstrateWebClient() { public void demonstrateWebClient() {
// request // request
WebClient.UriSpec<WebClient.RequestBodySpec> request1 = createWebClientWithServerURLAndDefaultValues().method(HttpMethod.POST); UriSpec<WebClient.RequestBodySpec> requestPost1 = createWebClientWithServerURLAndDefaultValues().method(HttpMethod.POST);
WebClient.UriSpec<WebClient.RequestBodySpec> request2 = createWebClientWithServerURLAndDefaultValues().post(); UriSpec<WebClient.RequestBodySpec> requestPost2 = createWebClientWithServerURLAndDefaultValues().post();
UriSpec<?> requestGet = createWebClientWithServerURLAndDefaultValues().get();
// request body specifications // request body specifications
WebClient.RequestBodySpec uri1 = createWebClientWithServerURLAndDefaultValues().method(HttpMethod.POST) RequestBodySpec bodySpecPost = requestPost1.uri("/resource");
.uri("/resource"); RequestBodySpec bodySpecPostMultipart = requestPost2.uri(uriBuilder -> uriBuilder.pathSegment("resource-multipart")
WebClient.RequestBodySpec uri2 = createWebClientWithServerURLAndDefaultValues().post() .build());
.uri(URI.create("/resource")); RequestBodySpec bodySpecOverridenBaseUri = requestPost2.uri(URI.create("/resource"));
// request header specification // request header specification
WebClient.RequestHeadersSpec<?> requestSpec1 = uri1.body(BodyInserters.fromPublisher(Mono.just("data"), String.class)); String bodyValue = "bodyValue";
WebClient.RequestHeadersSpec<?> requestSpec2 = uri2.body(BodyInserters.fromValue("data")); RequestHeadersSpec<?> headerSpecPost1 = bodySpecPost.body(BodyInserters.fromPublisher(Mono.just(bodyValue), String.class));
RequestHeadersSpec<?> headerSpecPost2 = bodySpecPost.body(BodyInserters.fromValue(bodyValue));
RequestHeadersSpec<?> headerSpecGet = requestGet.uri("/resource");
// inserters // request header specification using inserters
BodyInserter<Publisher<String>, ReactiveHttpOutputMessage> inserter1 = BodyInserters.fromPublisher(Subscriber::onComplete, String.class); BodyInserter<Publisher<String>, ReactiveHttpOutputMessage> inserterCompleteSuscriber = BodyInserters.fromPublisher(Subscriber::onComplete, String.class);
LinkedMultiValueMap<String, String> map = new LinkedMultiValueMap<>(); LinkedMultiValueMap<String, String> map = new LinkedMultiValueMap<>();
map.add("key1", "value1"); map.add("key1", "multipartValue1");
map.add("key2", "value2"); map.add("key2", "multipartValue2");
BodyInserter<MultiValueMap<String, Object>, ClientHttpRequest> inserter2 = BodyInserters.fromMultipartData(map); BodyInserter<MultiValueMap<String, Object>, ClientHttpRequest> inserterMultipart = BodyInserters.fromMultipartData(map);
BodyInserter<Object, ReactiveHttpOutputMessage> inserter3 = BodyInserters.fromValue(new Object()); BodyInserter<Object, ReactiveHttpOutputMessage> inserterObject = BodyInserters.fromValue(new Object());
BodyInserter<String, ReactiveHttpOutputMessage> inserter4 = BodyInserters.fromValue("body"); BodyInserter<String, ReactiveHttpOutputMessage> inserterString = BodyInserters.fromValue(bodyValue);
RequestHeadersSpec<?> headerSpecInserterCompleteSuscriber = bodySpecPost.body(inserterCompleteSuscriber);
RequestHeadersSpec<?> headerSpecInserterMultipart = bodySpecPostMultipart.body(inserterMultipart);
RequestHeadersSpec<?> headerSpecInserterObject = bodySpecPost.body(inserterObject);
RequestHeadersSpec<?> headerSpecInserterString = bodySpecPost.body(inserterString);
// responses // responses
WebClient.ResponseSpec response1 = uri1.body(inserter3) ResponseSpec responsePostObject = headerSpecInserterObject.header(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)
.header(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)
.accept(MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML) .accept(MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML)
.acceptCharset(Charset.forName("UTF-8")) .acceptCharset(StandardCharsets.UTF_8)
.ifNoneMatch("*") .ifNoneMatch("*")
.ifModifiedSince(ZonedDateTime.now()) .ifModifiedSince(ZonedDateTime.now())
.retrieve(); .retrieve();
String response2 = uri1.exchangeToMono(response -> response.bodyToMono(String.class)) String responsePostString = headerSpecInserterString.exchangeToMono(response -> response.bodyToMono(String.class))
.block(); .block();
String response3 = uri2.retrieve() String responsePostMultipart = headerSpecInserterMultipart.header(HttpHeaders.CONTENT_TYPE, MediaType.MULTIPART_FORM_DATA_VALUE)
.retrieve()
.bodyToMono(String.class) .bodyToMono(String.class)
.block(); .block();
WebClient.ResponseSpec response4 = requestSpec2.retrieve(); String responsePostCompleteSubsciber = headerSpecInserterCompleteSuscriber.retrieve()
.bodyToMono(String.class)
.block();
String responsePostWithBody1 = headerSpecPost1.retrieve()
.bodyToMono(String.class)
.block();
String responsePostWithBody3 = headerSpecPost2.retrieve()
.bodyToMono(String.class)
.block();
String responseGet = headerSpecGet.retrieve()
.bodyToMono(String.class)
.block();
String responsePostWithNoBody = bodySpecPost.retrieve()
.bodyToMono(String.class)
.block();
try {
bodySpecOverridenBaseUri.retrieve()
.bodyToMono(String.class)
.block();
} catch (Exception ex) {
System.out.println(ex.getClass());
}
} }
private WebClient createWebClient() { private WebClient createWebClient() {
@ -101,7 +135,7 @@ public class WebClientIntegrationTest {
private WebClient createWebClientWithServerURLAndDefaultValues() { private WebClient createWebClientWithServerURLAndDefaultValues() {
return WebClient.builder() return WebClient.builder()
.baseUrl("http://localhost:8081") .baseUrl("http://localhost:" + port)
.defaultCookie("cookieKey", "cookieValue") .defaultCookie("cookieKey", "cookieValue")
.defaultHeader(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE) .defaultHeader(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)
.defaultUriVariables(Collections.singletonMap("url", "http://localhost:8080")) .defaultUriVariables(Collections.singletonMap("url", "http://localhost:8080"))