溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
使用WebClient時的內部細節有哪些，相信很多沒有經驗的人對此束手無策，為此本文總結了問題出現的原因和解決方法，通過這篇文章希望你能解決這個問題。
默認情況下，所有WebClient的實例，公用Reactor.netty.http.HttpResources中包含的全局Reactor -Netty資源，資源這里具體是指事件循環處理線程池（event loop group）和連接管理池(http連接池)。
這是Spring的推薦的模式，因為復用事件循環線程池是并發調優的首選。
全局資源中默認的事件循環處理線程池中包含12個線程。連接池默認支持最大500個連接，并且當達到最大鏈接后，使用無界隊列緩存待獲取鏈接的請求，另外如果超過45000ms還沒獲取到鏈接則報超時。
注：由于連接池中鏈接是不區分域名的，如果有些域名的響應很耗時，則可能一直持有鏈接不釋放，這可能會影響其他域名的請求。
這時，你可以自定義資源，避免使用全局資源：
@Beanpublic ReactorResourceFactory resourceFactory() {ReactorResourceFactory factory = new ReactorResourceFactory();factory.setUseGlobalResources(false);return factory;}@Beanpublic WebClient webClient() {Function<HttpClient, HttpClient> mapper = client -> {// Further customizations...};ClientHttpConnector connector =new ReactorClientHttpConnector(resourceFactory(), mapper);return WebClient.builder().clientConnector(connector).build();}
但是這樣會導致不能復用事件處理線程池。
WebClient默認內部使用Netty實現http客戶端調用，這里IO線程其實是netty的IO線程，而netty客戶端的IO線程內是不建議做耗時操作的，因為IO線程是用來輪訓注冊到select上的channel的數據的，如果阻塞了，那么其他channel的讀寫請求就會得不到及時處理。所以如果consumer內邏輯比較耗時，建議從IO線程切換到其他線程來做。
那么如何切換那？可以使用publishOn把IO線程切換到自定義線程池進行處理：
resp.publishOn(Schedulers.elastic())//切換到Schedulers.elastic()對應的線程池進行處理 .onErrorMap(throwable -> { System.out.println("onErrorMap:" + throwable.getLocalizedMessage()); return throwable; }).subscribe(s -> System.out.println("result:" + Thread.currentThread().getName() + " " + s));
與服務端建立鏈接超時
HttpClient httpClient = HttpClient.create().option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 10000);WebClient webClient = WebClient.builder().clientConnector(new ReactorClientHttpConnector(httpClient)).build();
從服務端讀取數據超時
HttpClient httpClient = HttpClient.create() .doOnConnected(conn -> conn .addHandlerLast(new ReadTimeoutHandler(10)));
寫數據到服務端超時
HttpClient httpClient = HttpClient.create() .doOnConnected(conn -> conn .addHandlerLast(new WriteTimeoutHandler(10)));
從鏈接池獲取鏈接超時 需要自己重寫ReactorResourceFactory
private Supplier<ConnectionProvider> connectionProviderSupplier = () -> { return ConnectionProvider.fixed("webflux", 500,45000);//設置超時時間為45s};
使用WebClient可以便捷的使用Reactor風格的異步調用，但是知其然還要知其所以然。
看完上述內容，你們掌握使用WebClient時的內部細節有哪些的方法了嗎？如果還想學到更多技能或想了解更多相關內容，歡迎關注億速云行業資訊頻道，感謝各位的閱讀！
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
