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.mzph.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 对象始终唯一…