使用WebClient時(shí)的內(nèi)部細(xì)節(jié)有哪些，相信很多沒有經(jīng)驗(yàn)的人對(duì)此束手無策，為此本文總結(jié)了問題出現(xiàn)的原因和解決方法，通過這篇文章希望你能解決這個(gè)問題。

創(chuàng)新互聯(lián)堅(jiān)持“要么做到，要么別承諾”的工作理念，服務(wù)領(lǐng)域包括：成都網(wǎng)站設(shè)計(jì)、成都網(wǎng)站制作、企業(yè)官網(wǎng)、英文網(wǎng)站、手機(jī)端網(wǎng)站、網(wǎng)站推廣等服務(wù)，滿足客戶于互聯(lián)網(wǎng)時(shí)代的峽江網(wǎng)站設(shè)計(jì)、移動(dòng)媒體設(shè)計(jì)的需求，幫助企業(yè)找到有效的互聯(lián)網(wǎng)解決方案。努力成為您成熟可靠的網(wǎng)絡(luò)建設(shè)合作伙伴！

WebClient的一些內(nèi)部細(xì)節(jié)

默認(rèn)使用全局資源

默認(rèn)情況下，所有WebClient的實(shí)例，公用Reactor.netty.http.HttpResources中包含的全局Reactor -Netty資源，資源這里具體是指事件循環(huán)處理線程池（event loop group）和連接管理池(http連接池)。

這是Spring的推薦的模式，因?yàn)閺?fù)用事件循環(huán)線程池是并發(fā)調(diào)優(yōu)的首選。

全局資源中默認(rèn)的事件循環(huán)處理線程池中包含12個(gè)線程。連接池默認(rèn)支持最大500個(gè)連接，并且當(dāng)達(dá)到最大鏈接后，使用無界隊(duì)列緩存待獲取鏈接的請(qǐng)求，另外如果超過45000ms還沒獲取到鏈接則報(bào)超時(shí)。

注：由于連接池中鏈接是不區(qū)分域名的，如果有些域名的響應(yīng)很耗時(shí)，則可能一直持有鏈接不釋放，這可能會(huì)影響其他域名的請(qǐng)求。

這時(shí)，你可以自定義資源，避免使用全局資源：

@Beanpublic ReactorResourceFactory resourceFactory() {    ReactorResourceFactory factory = new ReactorResourceFactory();    factory.setUseGlobalResources(false);     return factory;}
@Beanpublic WebClient webClient() {
    Function mapper = client -> {        // Further customizations...    };
    ClientHttpConnector connector =            new ReactorClientHttpConnector(resourceFactory(), mapper); 
    return WebClient.builder().clientConnector(connector).build(); }

但是這樣會(huì)導(dǎo)致不能復(fù)用事件處理線程池。

默認(rèn)IO線程執(zhí)行回調(diào)

WebClient默認(rèn)內(nèi)部使用Netty實(shí)現(xiàn)http客戶端調(diào)用，這里IO線程其實(shí)是netty的IO線程，而netty客戶端的IO線程內(nèi)是不建議做耗時(shí)操作的，因?yàn)镮O線程是用來輪訓(xùn)注冊(cè)到select上的channel的數(shù)據(jù)的，如果阻塞了，那么其他channel的讀寫請(qǐng)求就會(huì)得不到及時(shí)處理。所以如果consumer內(nèi)邏輯比較耗時(shí)，建議從IO線程切換到其他線程來做。

那么如何切換那？可以使用publishOn把IO線程切換到自定義線程池進(jìn)行處理：

resp.publishOn(Schedulers.elastic())//切換到Schedulers.elastic()對(duì)應(yīng)的線程池進(jìn)行處理        .onErrorMap(throwable -> {            System.out.println("onErrorMap:" + throwable.getLocalizedMessage());            return throwable;        }).subscribe(s -> System.out.println("result:" + Thread.currentThread().getName() + " " + s));

超時(shí)相關(guān)的配置

• 與服務(wù)端建立鏈接超時(shí)

HttpClient httpClient = HttpClient.create()        .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 10000);
WebClient webClient = WebClient.builder()        .clientConnector(new ReactorClientHttpConnector(httpClient))        .build();

• 從服務(wù)端讀取數(shù)據(jù)超時(shí)

HttpClient httpClient = HttpClient.create()        .doOnConnected(conn -> conn                .addHandlerLast(new ReadTimeoutHandler(10)));

• 寫數(shù)據(jù)到服務(wù)端超時(shí)

HttpClient httpClient = HttpClient.create()        .doOnConnected(conn -> conn                .addHandlerLast(new WriteTimeoutHandler(10)));

• 從鏈接池獲取鏈接超時(shí) 需要自己重寫ReactorResourceFactory

private Supplier connectionProviderSupplier = () -> {   return ConnectionProvider.fixed("webflux", 500,45000);//設(shè)置超時(shí)時(shí)間為45s};

使用WebClient可以便捷的使用Reactor風(fēng)格的異步調(diào)用，但是知其然還要知其所以然。

看完上述內(nèi)容，你們掌握使用WebClient時(shí)的內(nèi)部細(xì)節(jié)有哪些的方法了嗎？如果還想學(xué)到更多技能或想了解更多相關(guān)內(nèi)容，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝各位的閱讀！