本文是精讲响应式WebClient第2篇，前篇的blog拜访地址如下：
- 精讲响应式webclient第1篇-响应式非阻塞IO与根底用法
在上一篇文章为大家介绍了响应式IO模型和WebClient的根本用法。本节来持续深刻的为大家介绍：如何应用WebClient作为Http客户端发送GET申请与进行响应后果的接管。
一、block()阻塞式获取响应后果
WebClient客户端既反对同步异步、阻塞与非阻塞IO，咱们先来为大家介绍一下同步阻塞式的编程形式。即：在申请发送之后应用block()办法，阻塞以后线程期待获取响应后果。
1.1.应用Mono接管单个对象
创立测试用例，成员变量WebClient，以 “http://jsonplaceholder.typicode.com” 为拜访服务根底门路，该网站是一个收费提供RESTful API进行接口测试的一个网站。
public class GetTest {
//创立webClient
private WebClient webClient = WebClient.builder()
.baseUrl("http://jsonplaceholder.typicode.com")
.build();
@Test
public void testMono() {
Mono<PostDTO> mono = webClient
.get() // 发送GET 申请
.uri("/posts/1") //服务申请门路，基于baseurl
.retrieve() // 获取响应体
.bodyToMono(PostDTO.class); //响应数据类型转换
System.out.println(mono.block());
}
}- get() 办法示意应用HTTP GET method
- uri() 指定服务接口门路，以baseurl为根底
- retrieve() 获取响应体，即HTTP body
- bodyToMono()将响应体转换为一个对象，Mono英文是单声道、单体的意思，用于接管单个对象
通过浏览器拜访 “http://jsonplaceholder.typicode.com/posts/1” 失去JSON响应后果，和咱们通过程序打印出的响应后果数据内容统一。程序控制台截图如下：
接管响应后果的java POJO实体对象如下：
import lombok.Data;
@Data
public class PostDTO {
private int userId;
private int id;
private String title;
private String body;
}1.2.应用Flux接管汇合对象
拜访http://jsonplaceholder.typicode.com/posts 能够取得JSON数组形式的申请后果如图(一共100条我截图截取3条记录)：
所以咱们须要通过bodyToFlux办法将申请后果转为Flux<PostDTO>，通过flux.collectList().block();接管响应数据为 List<PostDTO>汇合。Flux英文含意：流动的，用于接管汇合元素响应后果。
@Test
public void testFlux() {
Flux<PostDTO> flux = webClient
.get() // 发送GET 申请
.uri("/posts") //服务申请门路，基于baseurl
.retrieve() // 获取响应体
.bodyToFlux(PostDTO.class); //响应数据类型转换
List<PostDTO> posts = flux.collectList().block();
assert posts != null;
System.out.println("获取posts汇合元素数量：" + posts.size());
}控制台打印后果如下：
二、subscribe()非阻塞式获取响应后果
与block()阻塞式获取响应后果不同，应用subscribe()异步订阅响应后果，不会阻塞主线程持续向下执行。获取到响应后果之后，由回调函数handleResponse解决响应后果。
@Test
public void testSubscribe() throws InterruptedException {
Mono<PostDTO> mono = webClient
.get() // 发送GET 申请
.uri("/posts/1") //服务申请门路，基于baseurl
.retrieve() // 获取响应体
.bodyToMono(PostDTO.class); //响应数据类型转换
//异步非阻塞解决响应后果
mono.subscribe(GetTest::handleResponse);
//为了防止测试用例主线程执行实现，导致看不到异步处理结果
Thread.currentThread().sleep(10000);
}
//响应后果解决回调办法
private static void handleResponse(PostDTO postDTO) {
System.out.println("handle response:=======================");
System.out.println(postDTO);
}控制台打印输出后果如下：
三、exchange()获取HTTP响应残缺内容
上文中retrieve()只能获取HTTP报文中的Body，也就是响应体。如果咱们想获取HTTP报文中的状态码、headers、cookies等信息，须要应用exchange()办法。
@Test
public void testExchange() {
Mono<ClientResponse> mono = webClient
.get() // 发送GET 申请
.uri("/posts/1") //服务申请门路，基于baseurl
.exchange();
System.out.println(mono.block());
// 获取残缺的响应对象
ClientResponse response = mono.block();
assert response != null;
HttpStatus httpStatus = response.statusCode(); // 获取响应状态
int statusCodeValue = response.rawStatusCode(); // 获取响应状态码
ClientResponse.Headers headers = response.headers(); // 获取响应头
// 获取响应体
Mono<PostDTO> resultMono = response.bodyToMono(PostDTO.class);
PostDTO postDTO = resultMono.block();
// 输入后果
System.out.println("响应状态：" + httpStatus);
System.out.println("响应状态码值：" + statusCodeValue);
System.out.println("HTTP Headers：" + headers.asHttpHeaders());
System.out.println("响应体：" + postDTO);
}HTTP报文信息详情控制台打印后果
四、占位符传参
非占位符传参，写死的参数形式不灵便
.uri("/posts/1") //服务申请门路，基于baseurl第一种占位符传参：数字程序占位符
Mono<String> mono = webClient.uri("/{1}/{2}", "posts", "1") 第二种占位符传参：参数名称占位符
String type = "posts";
int id = 1;
Mono<String> mono = webClient.uri("/{type}/{id}", type, id) 第三种通过map传参
Map<String,Object> map = new HashMap<>();
map.put("type", "posts");
map.put("id", 1);
Mono<String> mono = webClient
.uri("/{type}/{id}", map) 欢送关注我的博客，外面有很多精品合集
- 本文转载注明出处（必须带连贯，不能只转文字）：字母哥博客。
感觉对您有帮忙的话，帮我点赞、分享！您的反对是我不竭的创作能源！ 。另外，笔者最近一段时间输入了如下的精品内容，期待您的关注。
- 《手摸手教你学Spring Boot2.0》
- 《Spring Security-JWT-OAuth2一本通》
- 《实战前后端拆散RBAC权限管理系统》
- 《实战SpringCloud微服务从青铜到王者》
- 《VUE深入浅出系列》
发表回复