WebClient学习
1. 介绍
Java中传统的RestTemplate 的主要问题在于不支持响应式流规范,也就无法提供非阻塞式的流式操作。而WebClient是响应式、非阻塞的客户端,属于Spring5中的spring-webflux库
2. 依赖
maven依赖
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-webflux</artifactId>
</dependency>
gradle依赖
dependencies {compile 'org.springframework.boot:spring-boot-starter-webflux'
}
3. 使用
- WebClient实例创建
WebClient client = WebClient.create();
也可以创建的时候指定base URI
WebClient client = WebClient.create("http://localhost:8080");
方式二:最常用的方式是使DefaultWebClientBuilder类
WebClient client = WebClient.builder().baseUrl("http://localhost:8080").defaultCookie("cookieKey", "cookieValue").defaultHeader(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE) .defaultUriVariables(Collections.singletonMap("url", "http://localhost:8080")).build();
方式三:创建WebClient实例并指定超时时间
- 可以通过ChannelOption.CONNECT_TIMEOUT_MILLIS** option** 指定连接超时时间
- 可以通过 ReadTimeoutHandler** **和WriteTimeoutHandler设置读和写的超时时间
- 可以通过responseTimeout设置响应超时时间
HttpClient httpClient = HttpClient.create().option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 5000).responseTimeout(Duration.ofMillis(5000)).doOnConnected(conn -> conn.addHandlerLast(new ReadTimeoutHandler(5000, TimeUnit.MILLISECONDS)).addHandlerLast(new WriteTimeoutHandler(5000, TimeUnit.MILLISECONDS)));WebClient client = WebClient.builder().clientConnector(new ReactorClientHttpConnector(httpClient)).build();
2) 准备请求——指定Method
第一种方式:使用WebClient对象的method方法(通用)
UriSpec<RequestBodySpec> uriSpec = client.method(HttpMethod.POST);
另外,WebClient对象也提供了get、post、delete等方法
UriSpec<RequestBodySpec> uriSpec = client.post();
- 准备请求——指定URL
使用uri方法
RequestBodySpec bodySpec = uriSpec.uri("/resource");
使用UriBuilder函数
RequestBodySpec bodySpec = uriSpec.uri(uriBuilder -> uriBuilder.pathSegment("/resource").build());
使用URI实例
RequestBodySpec bodySpec = uriSpec.uri(URI.create("/resource"));
- 准备请求——指定方法体
最常见是直接使用bodyValue方法
RequestHeadersSpec<?> headersSpec = bodySpec.bodyValue("data");
通过响应式Publisher指定
RequestHeadersSpec<?> headersSpec = bodySpec.body(Mono.just(new Foo("name")), Foo.class);
通过BodyInserters工具类指定
RequestHeadersSpec<?> headersSpec = bodySpec.body(BodyInserters.fromValue("data"));
通过BodyInserters响应式Publisher指定
RequestHeadersSpec headersSpec = bodySpec.body(BodyInserters.fromPublisher(Mono.just("data")),String.class);
当传递的请求体是一个 MultiValueMap 对象时,WebClient 默认发起的是表单提交
LinkedMultiValueMap map = new LinkedMultiValueMap();
map.add("key1", "value1");
map.add("key2", "value2");
RequestHeadersSpec<?> headersSpec = bodySpec.body(BodyInserters.fromMultipartData(map));
- 准备请求——指定Headers
可以通过header方法设置请求的Header
ResponseSpec responseSpec = headersSpec.header(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE).accept(MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML).acceptCharset(StandardCharsets.UTF_8).ifNoneMatch("*").ifModifiedSince(ZonedDateTime.now()).retrieve();
- 获取请求的响应
我们可以通过exchangeToMono/exchangeToFlux o或者 retrieve获取请求的响应结果
Mono<String> response = headersSpec.exchangeToMono(response -> {if (response.statusCode().equals(HttpStatus.OK)) {return response.bodyToMono(String.class);} else if (response.statusCode().is4xxClientError()) {return Mono.just("Error response");} else {return response.createException().flatMap(Mono::error);}
});
Mono<String> response = headersSpec.retrieve().bodyToMono(String.class);