摘要：對于異步的請求，使用的是異步客戶端即。要實現(xiàn)的配置設(shè)計以及使用舉例要實現(xiàn)的配置設(shè)計以及使用舉例首先，我們要實現(xiàn)的，其包含三個重試重試的要在負(fù)載均衡之前，因為重試的時候，我們會從負(fù)載均衡器獲取另一個實例進(jìn)行重試，而不是在同一個實例上重試多次。

本系列代碼地址：https://github.com/JoJoTec/spring-cloud-parent

為何需要封裝異步 HTTP 客戶端 WebClient

對于同步的請求，我們使用 spring-cloud-openfeign 封裝的 FeignClient，并做了額外的定制。對于異步的請求，使用的是異步 Http 客戶端即 WebClient。WebClient 使用也比較簡單，舉一個簡單的例子即：

//使用 WebClient 的 Builder 創(chuàng)建 WebClientWebClient client = WebClient.builder()  //指定基址  .baseUrl("http://httpbin.org")  //可以指定一些默認(rèn)的參數(shù)，例如默認(rèn) Cookie，默認(rèn) HttpHeader 等等  .defaultCookie("cookieKey", "cookieValue")  .defaultHeader(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)   .build();

創(chuàng)建好 WebClient 后即可以使用這個 WebClient 進(jìn)行調(diào)用：

// GET 請求 /anything 并將 body 轉(zhuǎn)化為 StringMono stringMono = client.get().uri("/anything").retrieve().bodyToMono(String.class);//這里為了測試，采用阻塞獲取String block = stringMono.block();

返回的結(jié)果如下所示（請求 http://httporg.bin/anything 會將請求中的所有內(nèi)容原封不動返回，從這里我們可以看出上面測試的 Header 還有 cokkie 都被返回了）：

{  "args": {},   "data": "",   "files": {},   "form": {},   "headers": {    "Accept": "*/*",     "Accept-Encoding": "gzip",     "Cookie": "TestCookie=TestCookieValue,getAnythingCookie=getAnythingCookieValue",     "Getanythingheader": "getAnythingHeaderValue",     "Host": "httpbin.org",     "Testheader": "TestHeaderValue",     "User-Agent": "ReactorNetty/1.0.7"  },   "json": null,   "method": "GET",   "origin": "12.12.12.12",   "url": "http://httpbin.org/anything"}

我們也可以加入負(fù)載均衡的功能，讓 WebClient 利用我們內(nèi)部的 LoadBalancer，負(fù)載均衡調(diào)用其他微服務(wù)，首先注入負(fù)載均衡 Filter：

@AutowiredReactorLoadBalancerExchangeFilterFunction lbFunction;

創(chuàng)建 WebClient 的時候，將這個 Filter 加入：

//使用 WebClient 的 Builder 創(chuàng)建 WebClientWebClient client = WebClient.builder()  //指定基址微服務(wù)  .baseUrl("http://微服務(wù)名稱")  //可以指定一些默認(rèn)的參數(shù)，例如默認(rèn) Cookie，默認(rèn) HttpHeader 等等  .defaultCookie("cookieKey", "cookieValue")  .defaultHeader(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)   //負(fù)載均衡器，改寫url  .filter(lbFunction)  .build();

這樣，這個 WebClient 就能調(diào)用微服務(wù)了。

但是，這樣還不能滿足我們的需求：

1. 需要在 WebClient 加入像 Feignclient 里面加的類似的重試與斷路機制，線程隔離就不需要了，因為都是異步請求不會阻塞任務(wù)線程。
2. 需要針對不同的微服務(wù)配置不同的連接超時以及響應(yīng)超時來適應(yīng)不同微服務(wù)。
3. 這些配置都增加了代碼的復(fù)雜度，我們需要減少這些代碼對于業(yè)務(wù)的侵入性，最好能通過純配置實現(xiàn)這些 WebClient 的初始化。

要實現(xiàn)的配置設(shè)計以及使用舉例

首先，我們要實現(xiàn)的 WebClient，其 Filter 包含三個：

1. 重試 Filter：重試的 Filter 要在負(fù)載均衡 Filter 之前，因為重試的時候，我們會從負(fù)載均衡器獲取另一個實例進(jìn)行重試，而不是在同一個實例上重試多次。
2. 負(fù)載均衡 Filter，其實就是內(nèi)置的 ReactorLoadBalancerExchangeFilterFunction
3. 斷路器 Filter：斷路器需要在負(fù)載均衡之后，因為只有負(fù)載均衡之后才能拿到具體本地調(diào)用的服務(wù)實例，這樣我們才能實現(xiàn)基于微服務(wù)實例方法級別的斷路器。

需要重試的場景：

1. 非 2xx 的響應(yīng)碼返回，并且方法是可以重試的方法。如何定義方法是可以重試的，首先 GET 方法是可以重試的，對于其他方法，根據(jù)配置中的是否配置了這個 URL 可以重試決定。
2. 異常重試：
   1. 連接異常：例如連接超時，連接中斷等等，所有請求的連接異常都可以重試，因為請求并沒有發(fā)出去。
   2. 斷路器異常：該服務(wù)實例方法級別的斷路器打開了，需要直接重試其他實例，因為請求并沒有發(fā)出去。
   3. 響應(yīng)超時異常：這個重試邏輯和非 2xx 的響應(yīng)碼返回一樣。

我們需要實現(xiàn)的配置方式是，通過這樣配置 application.yml：

webclient:  configs:    //微服務(wù)名稱    testService1:      //請求基址，第一級域名作為微服務(wù)名稱      baseUrl: http://testService1      //最多的 http 連接數(shù)量      maxConnection: 50      //連接超時      connectTimeout: 500ms      //響應(yīng)超時      responseTimeout: 60s      //除了 GET 方法外，哪些路徑還能重試      retryablePaths:        - /retryable/**        - /user/orders

加入這些配置，我們就能獲取載對應(yīng)微服務(wù)的 WebClient 的 Bean，例如：

//自動裝載 我們自定義的 WebClient 的 NamedContextFactory，這個是我們后面要實現(xiàn)的@Autowiredprivate WebClientNamedContextFactory webClientNamedContextFactory;//通過微服務(wù)名稱，獲取對應(yīng)的微服務(wù)調(diào)用的 WebClientwebClientNamedContextFactory.getWebClient("testService1");

接下來，我們會實現(xiàn)這些。

微信搜索“我的編程喵”關(guān)注公眾號，每日一刷，輕松提升技術(shù)，斬獲各種offer：