Java:Apache HttpClient中HttpRoute用法的介紹

當使用Apache HttpClient組件時,經常會用到它的連接池組件。典型的代碼如下:

		PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager();connectionManager.setMaxTotal(httpConfig.getMaxPoolTotal());connectionManager.setDefaultMaxPerRoute(httpConfig.getMaxDefaultPerRoute());RequestConfig requestConfig = RequestConfig.custom() //.setConnectTimeout(httpConfig.getConnectTimeout()) //.setConnectionRequestTimeout(httpConfig.getConnectionRequestTimeout())//.setSocketTimeout(httpConfig.getSocketTimeout())//.build();HttpClientBuilder httpClientBuilder = HttpClientBuilder.create() //.setConnectionManager(connectionManager) //.setDefaultRequestConfig(requestConfig) //.useSystemProperties();HttpClient httpClient = httpClientBuilder.build();

其中maxTotal表示此連接池的最大連接數,defaultMaxPerRoute表示每路由最大連接數。這里主涉及到route在Apache HttpClient組件中是怎么使用的問題。先分析一下Apache HttpClient的源代碼。以下使用的源代碼版本4.5.14。

org.apache.http.impl.client.InternalHttpClient

?可以看到這個方法傳入的還是HttpHost,也就是請求地址,但下面就通過determineRoute方法生成了一個HttpRoute,并且后續也是使用HttpRoute。

org.apache.http.impl.conn.DefaultRoutePlanner

?可以看到默認情況下,路由中的地址就是主機地址。

org.apache.http.impl.execchain.MainClientExec

?

這里也是使用HttpRoute。

org.apache.http.impl.conn.PoolingHttpClientConnectionManager

這里又開始使用HttpHost。

org.apache.http.impl.conn.DefaultHttpClientConnectionOperator

?????? 這里會解析hostName,如果通過hostName能解析出多個IP地址,則依次使用這些IP嘗試創建socket,只要有一個能創建成功,則停止嘗試。

?????? 從上述代碼中可以看到,是按路由地址創建連接池的,如果路由地址中的主機地址可以解析成多個IP地址時,只會使用第一個可用的IP地址。

????? 一般都是通過域名訪問其它服務,而域名一般可以解析出多個IP,而域名默認情況下就是路由主機地址,只能為其中一個IP建立連接,且能創建的最大連接數就是defaultMaxPerRoute的值。這樣遠遠達不到maxTotal的值。

?????? 當然,有一種辦法是直接使用域名解析出的多個IP訪問其它服務,這樣每個IP就是一個路由,最后創建的總連接數就可以達到maxTotal的值。但這樣的最大弊端是域名解析出的IP一般是動態的,可能會不但變化,程序中寫死IP是非常不靈活的。

?????? 那有沒有兩全其美的辦法,既使用域名訪問其它服務,又使用域名解析后的IP作為路由創建連接池,使用連接數創建到最大值。辦法是有的,只要實現一個RoutePlanner就行。

public class TestRoutePlanner implements RoutePlanner {private final Random random = new Random();public HttpRoute determineRoute(HttpHost host, HttpRequest reqt, HttpContext ctx) {InetAddress[] addrs = InetAddress.getAllByName(host.getHostnName());int idx = random.mextInt(addrs.length);String hostAddr = addrs[idx]getHostAddress();HttpHost newHost = new HttpHost(hostAddr, host.getPort(), host.getSchemeName());return new HttpRoute(newHost, null, false);}
}

?然后將TestRoutePlanner添加到HttpClient中。

		HttpClientBuilder httpClientBuilder = HttpClientBuilder.create() //.setConnectionManager(connectionManager) //.setDefaultRequestConfig(requestConfig) //.setRoutePlanner(new TestRoutePlanner())//.useSystemProperties();

?????? 上述TestRoutePlanner寫的比較簡單,性能也不太好,只是不演示功能而已,實際使用時還需要進一步改造。

?

?

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/bicheng/73917.shtml
繁體地址,請注明出處:http://hk.pswp.cn/bicheng/73917.shtml
英文地址,請注明出處:http://en.pswp.cn/bicheng/73917.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

RHCE(RHCSA復習:npm、dnf、源碼安裝實驗)

七、軟件管理 7.1 rpm 安裝 7.1.1 掛載 [rootlocalhost ~]# ll /mnt total 0 drwxr-xr-x. 2 root root 6 Oct 27 21:32 hgfs[rootlocalhost ~]# mount /dev/sr0 /mnt #掛載 mount: /mnt: WARNING: source write-protected, mounted read-only. [rootlocalhost ~]# [rootlo…

分布式的消息流平臺之Pulsar

Pulsar 流處理詳解 Apache Pulsar 是一個分布式的消息流平臺,集成了**消息隊列(MQ)和流處理(Stream Processing)**能力。Pulsar 不僅提供低延遲、高吞吐的消息傳輸能力,還支持基于 Pulsar Functions、Flin…

【C++多線程】thread

C中的std::thread是C11引入的線程庫的一部分&#xff0c;提供了創建和管理線程的能力。它封裝了操作系統的線程接口&#xff0c;使得在C中更方便地進行多線程編程。 1. std::thread 的定義 std::thread 類位于<thread>頭文件中&#xff0c;定義在std命名空間下&#xff…

【css酷炫效果】純CSS實現故障文字特效

【css酷炫效果】純CSS實現故障文字特效 緣創作背景html結構css樣式完整代碼基礎版進階版(3D效果) 效果圖 想直接拿走的老板&#xff0c;鏈接放在這里&#xff1a;https://download.csdn.net/download/u011561335/90492053 緣 創作隨緣&#xff0c;不定時更新。 創作背景 剛…

uniapp配置代理解決跨域問題

兩種方式&#xff1a; 1、manifest.json中配置 "h5" : {"template" : "static/index.html","devServer" : {"port" : 9090,"https" : false,"proxy":{"/prod-api":{"target":&quo…

物聯網為什么用MQTT不用 HTTP 或 UDP?

先來兩個代碼對比&#xff0c;上傳溫度數據給服務器。 MQTT代碼示例 // MQTT 客戶端連接到 MQTT 服務器 mqttClient.connect("mqtt://broker.server.com:8883", clientId) // 訂閱特定主題 mqttClient.subscribe("sensor/data", qos1) // …

Flutter:頁面滾動,導航欄背景顏色過渡動畫

記錄&#xff1a;導航默認透明&#xff0c;頁面發生滾動后&#xff0c;導航背景色由0-1&#xff0c;過渡到白色背景。 view import package:ducafe_ui_core/ducafe_ui_core.dart; import package:flutter/material.dart; import package:get/get.dart; import package:redo…

STM32 —— MCU、MPU、ARM、FPGA、DSP

在嵌入式系統中&#xff0c;MCU、MPU、ARM、FPGA和DSP是核心組件&#xff0c;各自在架構、功能和應用場景上有顯著差異。以下從專業角度詳細解析這些概念&#xff1a; 一、 MCU&#xff08;Microcontroller Unit&#xff0c;微控制器單元&#xff09; 核心定義 集成系統芯片&a…

批量刪除 PPT 空白幻燈片頁面

如果我們需要刪除 PPT 文檔中的空白幻燈片頁面&#xff0c;我們可以借助 Office 工具來完成&#xff0c;但是如果是大量的 PPT 文檔需要批量刪除空白幻燈片頁面&#xff0c;那就需要使用專業的批量處理工具來完成&#xff0c;今天就給大家介紹一種批量刪除 PPT 空白幻燈片頁面的…

【canvas】一鍵自動布局:如何讓流程圖節點自動找到最佳位置

一鍵自動布局&#xff1a;如何讓流程圖節點自動找到最佳位置 引言 在流程圖、拓撲圖和系統架構圖設計中&#xff0c;節點布局往往是最令人頭疼的問題。如果手動調整每個節點位置&#xff0c;不僅耗時費力&#xff0c;還難以保證美觀性和一致性。本文將深入解析如何實現自動布…

【平臺優化】大數據集群一個客戶端參數引起的任務性能差的問題

大數據集群一個客戶端參數引起的任務性能差的問題 背景介紹排查過程任務慢的具體原因Executor中數據內存往磁盤溢寫結果數據寫入分區路徑 分析解決方案 結語&思考 背景介紹 隨著業務量不斷擴大&#xff0c;平臺逐步發展成HDFS多聯邦的架構&#xff0c;這個過程中&#xff…

【微信小程序變通實現DeepSeek支持語音】

微信小程序實現錄音轉文字&#xff0c;并調用后端服務&#xff08;Node.js&#xff09;進行語音識別和&#xff0c;然后調用DeepSeek 處理的完整實現。 整體架構 前端&#xff08;微信小程序&#xff09;&#xff1a; 實現錄音功能。將錄音文件上傳到后端。接收后端返回的語音…

uniapp常用組件

寫在前面 今天將uniapp中的組件都過了一遍&#xff0c;上手難度不大&#xff0c;但是還是遇到了一些問題&#xff1a; HBuilder實在是太難用&#xff0c;不管是插件生態還是設計之類的&#xff0c;總之就是用的哪哪不順手雖然打開內置瀏覽器是挺方便的&#xff0c;但是不知道…

【Linux】應用層自定義協議 + 序列化和反序列化

應用層自定義協議 序列化和反序列化 一.應用層1.再談 "協議"2.序列化 和 反序列化 二. Jsoncpp1.序列化2.反序列化 三. Tcp全雙工 面向字節流四.自定義協議 保證報文的完整性1.Makefile2.Mutex.hpp3.Cond.hpp4.Log.hpp5.Thread.hpp6.ThreadPool.hpp7.Common.hpp8.…

二.使用ffmpeg對原始音頻數據重采樣并進行AAC編碼

重采樣&#xff1a;將音頻三元組【采樣率 采樣格式 通道數】之中的任何一個或者多個值改變。 一.為什么要進行重采樣&#xff1f; 1.原始音頻數據和編碼器的數據格式不一致 2.播放器要求的和獲取的數據不一致 3.方便運算 二.本次編碼流程 1.了解自己本機麥克風參數&#x…

器材借用管理系統詳細設計基于Spring Boot-SSM

? 目錄 ?摘要 一、系統概述? ?二、系統架構設計? 2?.1技術選型? ?2.2系統架構? ?三、需求分析 3.1用戶需求分析 3.2功能模塊設計? 3.3、性能需求分析 3.4、安全需求分析 ?四、數據庫設計? ?五、安全性設計? ?六、系統測試與維護? ?七、總結?…

麒麟V10 arm cpu aarch64 下編譯 RocketMQ-Client-CPP 2.2.0

國產自主可控服務器需要訪問RocketMQ消息隊列&#xff0c;最新的CSDK是2020年發布的 rocketmq-client-cpp-2.2.0 這個版本支持TLS模式。 用默認的版本安裝遇到一些問題&#xff0c;記錄一下。 下載Releases apache/rocketmq-client-cpp GitHubhttps://github.com/apache/roc…

C語言每日一練——day_12(最后一天)

引言 針對初學者&#xff0c;每日練習幾個題&#xff0c;快速上手C語言。第十二天。&#xff08;最后一天&#xff0c;完結散花啦&#xff09; 采用在線OJ的形式 什么是在線OJ&#xff1f; 在線判題系統&#xff08;英語&#xff1a;Online Judge&#xff0c;縮寫OJ&#xff0…

網絡安全應急入門到實戰

奇安信&#xff1a;95015網絡安全應急響應分析報告&#xff08;2022-2024年&#xff09;官網可以下載 https://github.com/Bypass007/Emergency-Response-Notes 應急響應實戰筆記 網絡安全應急響應技術實戰指南 .pdf 常見場景 第4章 勒索病毒網絡安全應急響應 第5章 挖礦木…

jvm中每個類的Class對象是唯一的嗎

jvm中每個類的Class對象是唯一的嗎 在 Java 中&#xff0c;同一個類的 Class 對象在由同一個類加載器加載時是唯一的。析&#xff1a; 1. 同一類加載器的唯一性 規則&#xff1a;若一個類被同一個類加載器加載&#xff0c;無論創建多少實例&#xff0c;其 Class 對象始終唯一…