Java:Apache HttpClient中HttpRoute用法的介绍

news/2025/3/21 6:35:22/

当使用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就行。

java">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中。

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

       上述TestRoutePlanner写的比较简单,性能也不太好,只是不演示功能而已,实际使用时还需要进一步改造。

 

 


http://www.ppmy.cn/news/1580800.html

相关文章

【微信小程序变通实现DeepSeek支持语音】

微信小程序实现录音转文字,并调用后端服务(Node.js)进行语音识别和,然后调用DeepSeek 处理的完整实现。 整体架构 前端(微信小程序): 实现录音功能。将录音文件上传到后端。接收后端返回的语音…

STC89C52单片机学习——第28节: [12-2] AT24C02数据存储秒表(定时器扫描按键数码管)

写这个文章是用来学习的,记录一下我的学习过程。希望我能一直坚持下去,我只是一个小白,只是想好好学习,我知道这会很难,但我还是想去做! 本文写于:2025.03.20 51单片机学习——第28节: [12-2] AT24C02数据存储&秒表(定时器扫…

亚马逊Prime Day新算法曝光,2025年流量分配机制大调整

亚马逊Prime Day新算法曝光,2025年流量分配机制大调整 亚马逊调整流量分配规则,影响卖家竞争格局 近日,亚马逊内部泄露的一份文件引发了全球跨境电商卖家的广泛关注。据悉,这份文件披露了亚马逊即将在2025年Prime Day正式启用的新…

DRAMiTransformer:空间与通道注意力融合的高效视觉变换块

DRAMiTransformer:空间与通道注意力融合的高效视觉变换块 随着深度学习在计算机视觉领域的快速发展,自注意力机制(Self-Attention)逐渐成为各种任务的核心组件。然而,传统自注意力机制往往需要较高的计算成本&#xf…

数据采集技术之python网络爬虫(中国天气网的爬取)

一、爬取中国天气网所有地区当天的天气数据(PyCharm): 网址:https://www.weather.com.cn/ 下面爬取数据: 因为现在已经到了夜间,所以白天的数据已经不见了,但原理是一样的。 二、代码以及详情…

HarmonyOS Next~HarmonyOS应用开发工具:DevEco Testing

HarmonyOS应用开发工具:DevEco Testing ​ 随着HarmonyOS生态的快速发展,开发者对高效、稳定的应用开发工具需求日益增长。作为HarmonyOS应用开发工具链中的重要组成部分,DevEco Testing凭借其全面的测试能力和智能化特性,成为保…

PLC控制柜在技术创新驱动中功能演进 尤劲恩科技

在智能制造体系中,PLC控制柜不仅承担着传统设备控制的基础功能,更通过工业以太网、PROFIBUS等现场总线技术,构建起分布式控制系统(DCS)。这种拓扑结构使生产线具备实时数据采集、远程监控和智能决策能力,显…

selenium之基础整理

安装步骤 1,在pycharm中下载selenium库:pip install selenium 2,把下载的chromedriver.exe驱动解压放到python根目录下(如果没有检测到该驱动,可以把将chromedriver.exe配置到环境变量path中) (…