本文是精講回應式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 = https://www.cnblogs.com/zimug/p/response.rawStatusCode(); // 獲取回應狀態碼
ClientResponse.Headers headers = response.headers(); // 獲取回應頭
// 獲取回應體
Mono 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深入淺出系列》
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/61818.html
標籤：Java
上一篇：Java語法