今天就跟大家聊聊有關WebClient中如何進行請求超時設置與異常處理，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結了以下內(nèi)容，希望大家根據(jù)這篇文章可以有所收獲。

成都創(chuàng)新互聯(lián)服務項目包括高陵網(wǎng)站建設、高陵網(wǎng)站制作、高陵網(wǎng)頁制作以及高陵網(wǎng)絡營銷策劃等。多年來，我們專注于互聯(lián)網(wǎng)行業(yè)，利用自身積累的技術優(yōu)勢、行業(yè)經(jīng)驗、深度合作伙伴關系等，向廣大中小型企業(yè)、政府機構等提供互聯(lián)網(wǎng)行業(yè)的解決方案，高陵網(wǎng)站推廣取得了明顯的社會效益與經(jīng)濟效益。目前，我們服務的客戶以成都為中心已經(jīng)輻射到高陵省份的部分城市，未來相信會繼續(xù)擴大服務區(qū)域并繼續(xù)獲得客戶的支持與信任！

當WebClient請求發(fā)生異常的時候，該如何處理。為了講解異常處理，我們需要先制造出異常，所以我們先為大家介紹：請求超時時長的設置。

一、請求超時時長的設置

要想模擬超時異常，我們首先要知道超時時長的正常配置渠道是怎么樣的。如下文代碼所示：

• ChannelOption.CONNECT_TIMEOUT_MILLIS用來設置連接超時時長,單位是毫秒

• ReadTimeoutHandler(5000, TimeUnit.MILLISECONDS)用來設置讀數(shù)據(jù)超時時長,單位是毫秒

• WriteTimeoutHandler(5000, TimeUnit.MILLISECONDS)用來設置寫數(shù)據(jù)超時時長,單位是毫秒

//初始化一個WebClient
private WebClient getWebClient(){
   TcpClient tcpClient = TcpClient
               .create()
               .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 5000)
               .doOnConnected(connection -> {
                  connection.addHandlerLast(new ReadTimeoutHandler(5000, TimeUnit.MILLISECONDS));
                  connection.addHandlerLast(new WriteTimeoutHandler(5000, TimeUnit.MILLISECONDS));
               });

   return WebClient.builder()
               .baseUrl("http://jsonplaceholder.typicode.com")
               .clientConnector(new ReactorClientHttpConnector(HttpClient.from(tcpClient)))
               .build();
}

當我們把連接超時時長設置為5(毫秒)的時候，則連接肯定會超時。隨便發(fā)送一個請求，超時之后會拋出ConnectTimeoutException

當我們把讀數(shù)據(jù)超市時長設置為5(毫秒)的時候，則數(shù)據(jù)讀操作肯定會超時。隨便發(fā)送一個請求，超時之后會拋出ReadTimeoutException

二、處理特定的異常

下面我們就以ConnectTimeoutException為例，進行異常處理

//制造異常，將超時時間設置為5毫秒
.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 5)

然后執(zhí)行下面的GET請求，上文WebClient的baseurl為："http://jsonplaceholder.typicode.com" ，該網(wǎng)站是一個免費提供HTTP服務端測試的網(wǎng)站。

@Test
public void testSimple() throws Exception {
   Mono<String> mono = getWebClient()
               .get()    // 發(fā)送GET 請求
               .uri("/posts/1")  //服務請求路徑，基于baseurl
               .retrieve() // 獲取響應體
               .bodyToMono(String.class) //響應數(shù)據(jù)類型轉(zhuǎn)換
                //進行異常處理
               .doOnError(ConnectTimeoutException.class, err -> {
                  System.out.println("發(fā)生錯誤：" +err.getMessage() );
               });
   System.out.println(mono.block());
}

上文中的doOnError是我們本節(jié)為大家介紹的異常處理方法，用于處理ConnectTimeoutException，輸出結果如下：

從輸出結果上看：一：異常得到處理，因為看到了System.out打印日志。二是異常仍然被拋出了，沒有得到返回值。

三、請求異常給出默認返回值

從第二小節(jié)中的代碼及控制臺輸出，可以看出HTTP 客戶端請求沒有得到返回值，而是繼續(xù)把異常對外拋出。假如我們目前的需求是，不論請求成功失敗，都給客戶端一個返回值，該怎么做？也就是說我們需要在請求發(fā)生異常的時候，給出默認返回值。

@Test
public void testReturn() throws Exception {
   Mono<String> mono = getWebClient()
               .get()    // 發(fā)送GET 請求
               .uri("/posts/1")  //服務請求路徑，基于baseurl
               .retrieve() // 獲取響應體
               .bodyToMono(String.class) //響應數(shù)據(jù)類型轉(zhuǎn)換
               .doOnError(ConnectTimeoutException.class, err -> {
                  System.out.println("發(fā)生錯誤：" +err.getMessage() );
               })
               .onErrorReturn("請求發(fā)生異常，請檢查！");
   System.out.println(mono.block());
}

使用onErrorReturn();給出請求的默認返回值，輸出結果如下：

可以看到請求測試用例成功pass了，因為我們給出了異常處理的默認返回值，沒有把異常繼續(xù)拋出。

四、分類異常處理

上面的異常處理方法，只能處理指定的某種異常：ConnectTimeoutException。如果說我們想讓異常處理相對通用一些該怎么辦？有的小伙伴可能會想到攔截異常的父類Exception，當然這也是一種辦法。

.doOnError(Exception.class, err -> {
   System.out.println("發(fā)生錯誤：" +err.getMessage() );
});

我們下面為大家介紹一種，針對HTTP 響應異常處理更友好的一種方式。通常來說，異?？梢苑譃閮煞N：

• 一種是客戶端輸入或訪問異常，比如：訪問的資源不存在404，沒有權限訪問資源403，輸入的數(shù)據(jù)不符合格式等等。這種異常通常是用戶訪問了不該訪問的資源，或者輸入了不該輸入的數(shù)據(jù)導致的。通常用HTTP狀態(tài)碼表示在400-499范圍內(nèi)。

• 另一種是服務端內(nèi)部錯誤，比如：500服務內(nèi)部錯誤、502網(wǎng)關錯誤等等。這種異常通常和用戶沒什么關系，是IT基礎設施或者編程導致的異常。

所以我們只需要針對上面的兩類異常進行處理即可。如下文代碼所示：

• e.is4xxClientError()表示的是400-499狀態(tài)碼段的異常

• e.is5xxClientError()表示的是500-599狀態(tài)碼段的異常

public void testSimple2() throws Exception {
   Mono<String> mono = getWebClient()
               .get()    // 發(fā)送GET 請求
               .uri("/postss/1")  //服務請求路徑，基于baseurl
               .retrieve() // 獲取響應體
               .onStatus(e -> e.is4xxClientError(), resp -> {
                  System.out.println("發(fā)生客戶端輸入錯誤：" + resp.statusCode().value() + " "
                              + resp.statusCode().getReasonPhrase());
                  return Mono.error(new RuntimeException("請求失敗"));
               })
               .onStatus(e -> e.is5xxServerError(), resp -> {
                  System.out.println("發(fā)生服務端錯誤：" + resp.statusCode().value() + " "
                              + resp.statusCode().getReasonPhrase());
                  return Mono.error(new RuntimeException("服務器異常"));
               })
               .bodyToMono(String.class); //響應數(shù)據(jù)類型轉(zhuǎn)換
   System.out.println(mono.block());
}

現(xiàn)在我們將請求地址由正確的"/posts/1"，改成錯誤的"/postss/1"，所以當我們訪問服務端的時候，服務端并不存在這個資源。異常處理的輸出結果如下：

看完上述內(nèi)容，你們對WebClient中如何進行請求超時設置與異常處理有進一步的了解嗎？如果還想了解更多知識或者相關內(nèi)容，請關注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝大家的支持。

當前名稱：WebClient中如何進行請求超時設置與異常處理
URL網(wǎng)址：http://jinyejixie.com/article8/iepgop.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供ChatGPT、服務器托管、網(wǎng)站內(nèi)鏈、虛擬主機、手機網(wǎng)站建設、搜索引擎優(yōu)化

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)