聊聊httpclient的staleConnectionCheckEnabled

序

本文主要研究一下httpclient的staleConnectionCheckEnabled

staleConnectionCheckEnabled

org/apache/http/client/config/RequestConfig.java

public class RequestConfig implements Cloneable {public static final RequestConfig DEFAULT = new Builder().build();private final boolean expectContinueEnabled;private final HttpHost proxy;private final InetAddress localAddress;private final boolean staleConnectionCheckEnabled;//....../*** Determines whether stale connection check is to be used. The stale* connection check can cause up to 30 millisecond overhead per request and* should be used only when appropriate. For performance critical* operations this check should be disabled.* <p>* Default: {@code false} since 4.4* </p>** @deprecated (4.4) Use {@link*   org.apache.http.impl.conn.PoolingHttpClientConnectionManager#getValidateAfterInactivity()}*/@Deprecatedpublic boolean isStaleConnectionCheckEnabled() {return staleConnectionCheckEnabled;}   public static class Builder {private boolean expectContinueEnabled;private HttpHost proxy;private InetAddress localAddress;private boolean staleConnectionCheckEnabled;//......Builder() {super();this.staleConnectionCheckEnabled = false;this.redirectsEnabled = true;this.maxRedirects = 50;this.relativeRedirectsAllowed = true;this.authenticationEnabled = true;this.connectionRequestTimeout = -1;this.connectTimeout = -1;this.socketTimeout = -1;this.contentCompressionEnabled = true;this.normalizeUri = true;}        /*** @deprecated (4.4) Use {@link*   org.apache.http.impl.conn.PoolingHttpClientConnectionManager#setValidateAfterInactivity(int)}*/@Deprecatedpublic Builder setStaleConnectionCheckEnabled(final boolean staleConnectionCheckEnabled) {this.staleConnectionCheckEnabled = staleConnectionCheckEnabled;return this;}  //......}       
}

RequestConfig定义了staleConnectionCheckEnabled属性，在4.4版本废弃了，默认为false，替换设置是org.apache.http.impl.conn.PoolingHttpClientConnectionManager.setValidateAfterInactivity(int)；Builder方法也提供了setStaleConnectionCheckEnabled方法

MainClientExec

org/apache/http/impl/execchain/MainClientExec.java

    public CloseableHttpResponse execute(final HttpRoute route,final HttpRequestWrapper request,final HttpClientContext context,final HttpExecutionAware execAware) throws IOException, HttpException {Args.notNull(route, "HTTP route");Args.notNull(request, "HTTP request");Args.notNull(context, "HTTP context");AuthState targetAuthState = context.getTargetAuthState();if (targetAuthState == null) {targetAuthState = new AuthState();context.setAttribute(HttpClientContext.TARGET_AUTH_STATE, targetAuthState);}AuthState proxyAuthState = context.getProxyAuthState();if (proxyAuthState == null) {proxyAuthState = new AuthState();context.setAttribute(HttpClientContext.PROXY_AUTH_STATE, proxyAuthState);}if (request instanceof HttpEntityEnclosingRequest) {RequestEntityProxy.enhance((HttpEntityEnclosingRequest) request);}Object userToken = context.getUserToken();final ConnectionRequest connRequest = connManager.requestConnection(route, userToken);if (execAware != null) {if (execAware.isAborted()) {connRequest.cancel();throw new RequestAbortedException("Request aborted");}execAware.setCancellable(connRequest);}final RequestConfig config = context.getRequestConfig();final HttpClientConnection managedConn;try {final int timeout = config.getConnectionRequestTimeout();managedConn = connRequest.get(timeout > 0 ? timeout : 0, TimeUnit.MILLISECONDS);} catch(final InterruptedException interrupted) {Thread.currentThread().interrupt();throw new RequestAbortedException("Request aborted", interrupted);} catch(final ExecutionException ex) {Throwable cause = ex.getCause();if (cause == null) {cause = ex;}throw new RequestAbortedException("Request execution failed", cause);}context.setAttribute(HttpCoreContext.HTTP_CONNECTION, managedConn);if (config.isStaleConnectionCheckEnabled()) {// validate connectionif (managedConn.isOpen()) {this.log.debug("Stale connection check");if (managedConn.isStale()) {this.log.debug("Stale connection detected");managedConn.close();}}}final ConnectionHolder connHolder = new ConnectionHolder(this.log, this.connManager, managedConn);try {if (execAware != null) {execAware.setCancellable(connHolder);}HttpResponse response;for (int execCount = 1;; execCount++) {if (execCount > 1 && !RequestEntityProxy.isRepeatable(request)) {throw new NonRepeatableRequestException("Cannot retry request " +"with a non-repeatable request entity.");}if (execAware != null && execAware.isAborted()) {throw new RequestAbortedException("Request aborted");}if (!managedConn.isOpen()) {this.log.debug("Opening connection " + route);try {establishRoute(proxyAuthState, managedConn, route, request, context);} catch (final TunnelRefusedException ex) {if (this.log.isDebugEnabled()) {this.log.debug(ex.getMessage());}response = ex.getResponse();break;}}context.setAttribute(HttpCoreContext.HTTP_REQUEST, request);response = requestExecutor.execute(request, managedConn, context);//......}}        //......//......}

MainClientExec的execute先通过connManager.requestConnection获取ConnectionRequest，然后通过connRequest.get(timeout > 0 ? timeout : 0, TimeUnit.MILLISECONDS)获取managedConn，之后判断requestConfig的isStaleConnectionCheckEnabled，为true的话，会执行连接的校验，先判断是否open，再判断是否stale，为stale的话则执行close；在managedConn关闭的时候，会通过establishRoute再进行连接

establishRoute

org/apache/http/impl/execchain/MainClientExec.java

    /*** Establishes the target route.*/void establishRoute(final AuthState proxyAuthState,final HttpClientConnection managedConn,final HttpRoute route,final HttpRequest request,final HttpClientContext context) throws HttpException, IOException {final RequestConfig config = context.getRequestConfig();final int timeout = config.getConnectTimeout();final RouteTracker tracker = new RouteTracker(route);int step;do {final HttpRoute fact = tracker.toRoute();step = this.routeDirector.nextStep(route, fact);switch (step) {case HttpRouteDirector.CONNECT_TARGET:this.connManager.connect(managedConn,route,timeout > 0 ? timeout : 0,context);tracker.connectTarget(route.isSecure());break;case HttpRouteDirector.CONNECT_PROXY:this.connManager.connect(managedConn,route,timeout > 0 ? timeout : 0,context);final HttpHost proxy  = route.getProxyHost();tracker.connectProxy(proxy, route.isSecure() && !route.isTunnelled());break;case HttpRouteDirector.TUNNEL_TARGET: {final boolean secure = createTunnelToTarget(proxyAuthState, managedConn, route, request, context);this.log.debug("Tunnel to target created.");tracker.tunnelTarget(secure);}   break;case HttpRouteDirector.TUNNEL_PROXY: {// The most simple example for this case is a proxy chain// of two proxies, where P1 must be tunnelled to P2.// route: Source -> P1 -> P2 -> Target (3 hops)// fact:  Source -> P1 -> Target       (2 hops)final int hop = fact.getHopCount()-1; // the hop to establishfinal boolean secure = createTunnelToProxy(route, hop, context);this.log.debug("Tunnel to proxy created.");tracker.tunnelProxy(route.getHopTarget(hop), secure);}   break;case HttpRouteDirector.LAYER_PROTOCOL:this.connManager.upgrade(managedConn, route, context);tracker.layerProtocol(route.isSecure());break;case HttpRouteDirector.UNREACHABLE:throw new HttpException("Unable to establish route: " +"planned = " + route + "; current = " + fact);case HttpRouteDirector.COMPLETE:this.connManager.routeComplete(managedConn, route, context);break;default:throw new IllegalStateException("Unknown step indicator "+ step + " from RouteDirector.");}} while (step > HttpRouteDirector.COMPLETE);}

establishRoute方法在循环里头通过connManager.connect建立连接

requestConnection

org/apache/http/impl/conn/PoolingHttpClientConnectionManager.java

    public ConnectionRequest requestConnection(final HttpRoute route,final Object state) {Args.notNull(route, "HTTP route");if (this.log.isDebugEnabled()) {this.log.debug("Connection request: " + format(route, state) + formatStats(route));}final Future<CPoolEntry> future = this.pool.lease(route, state, null);return new ConnectionRequest() {@Overridepublic boolean cancel() {return future.cancel(true);}@Overridepublic HttpClientConnection get(final long timeout,final TimeUnit timeUnit) throws InterruptedException, ExecutionException, ConnectionPoolTimeoutException {final HttpClientConnection conn = leaseConnection(future, timeout, timeUnit);if (conn.isOpen()) {final HttpHost host;if (route.getProxyHost() != null) {host = route.getProxyHost();} else {host = route.getTargetHost();}final SocketConfig socketConfig = resolveSocketConfig(host);conn.setSocketTimeout(socketConfig.getSoTimeout());}return conn;}};}

PoolingHttpClientConnectionManager的requestConnection返回的ConnectionRequest的get方法是通过leaseConnection(future, timeout, timeUnit)来获取连接的，而leaseConnection依赖的是pool.lease(route, state, null)返回的future

lease

org/apache/http/pool/AbstractConnPool.java

    /*** {@inheritDoc}* <p>* Please note that this class does not maintain its own pool of execution* {@link Thread}s. Therefore, one <b>must</b> call {@link Future#get()}* or {@link Future#get(long, TimeUnit)} method on the {@link Future}* returned by this method in order for the lease operation to complete.*/@Overridepublic Future<E> lease(final T route, final Object state, final FutureCallback<E> callback) {Args.notNull(route, "Route");Asserts.check(!this.isShutDown, "Connection pool shut down");return new Future<E>() {private final AtomicBoolean cancelled = new AtomicBoolean(false);private final AtomicBoolean done = new AtomicBoolean(false);private final AtomicReference<E> entryRef = new AtomicReference<E>(null);@Overridepublic boolean cancel(final boolean mayInterruptIfRunning) {if (done.compareAndSet(false, true)) {cancelled.set(true);lock.lock();try {condition.signalAll();} finally {lock.unlock();}if (callback != null) {callback.cancelled();}return true;}return false;}@Overridepublic boolean isCancelled() {return cancelled.get();}@Overridepublic boolean isDone() {return done.get();}@Overridepublic E get() throws InterruptedException, ExecutionException {try {return get(0L, TimeUnit.MILLISECONDS);} catch (final TimeoutException ex) {throw new ExecutionException(ex);}}@Overridepublic E get(final long timeout, final TimeUnit timeUnit) throws InterruptedException, ExecutionException, TimeoutException {for (;;) {synchronized (this) {try {final E entry = entryRef.get();if (entry != null) {return entry;}if (done.get()) {throw new ExecutionException(operationAborted());}final E leasedEntry = getPoolEntryBlocking(route, state, timeout, timeUnit, this);if (validateAfterInactivity > 0)  {if (leasedEntry.getUpdated() + validateAfterInactivity <= System.currentTimeMillis()) {if (!validate(leasedEntry)) {leasedEntry.close();release(leasedEntry, false);continue;}}}if (done.compareAndSet(false, true)) {entryRef.set(leasedEntry);done.set(true);onLease(leasedEntry);if (callback != null) {callback.completed(leasedEntry);}return leasedEntry;} else {release(leasedEntry, true);throw new ExecutionException(operationAborted());}} catch (final IOException ex) {if (done.compareAndSet(false, true)) {if (callback != null) {callback.failed(ex);}}throw new ExecutionException(ex);}}}}};}

lease返回的future的get(final long timeout, final TimeUnit timeUnit)方法在一个循环里头去获取连接，内部是通过getPoolEntryBlocking获取到leasedEntry，然后在validateAfterInactivity大于0的时候进行连接校验，在leasedEntry.getUpdated() + validateAfterInactivity <= System.currentTimeMillis()的时候进行validate，校验不成功的话进行关闭掉leasedEntry，然后release掉leasedEntry，然后继续循环获取下一个连接

小结

httpclient的RequestConfig提供了staleConnectionCheckEnabled属性用于在请求获取到连接的时候进行连接检测，不过这个属性在4.4版本被废弃了，并默认设置为false，替换设置是org.apache.http.impl.conn.PoolingHttpClientConnectionManager.setValidateAfterInactivity(int)，它是在ConnectionRequest的lease方法里头根据leasedEntry.getUpdated() + validateAfterInactivity判断是否需要校验连接，若需要且校验不通过则循环继续获取；而staleConnectionCheckEnabled则是在requestConnection之后根据RequestConfig的isStaleConnectionCheckEnabled来判断，然后进行连接校验，校验不通过则关闭managedConn，最后会在判断如果managedConn.isOpen()为false，则执行establishRoute，在循环里头通过connManager.connect来建立新连接。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/165847.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

【ARM 嵌入式 编译 Makefile 系列 18 -- Makefile 中的 export 命令详细介绍】

【ARM 嵌入式 编译 Makefile 系列 18 -- Makefile 中的 export 命令详细介绍】

文章目录 Makefile 中的 export 命令详细介绍Makefile 使用 export导出与未导出变量的区别示例&#xff1a;导出变量以供子 Makefile 使用 Makefile 中的 export 命令详细介绍 在 Makefile 中&#xff0c;export 命令用于将变量从 Makefile 导出到由 Makefile 启动的子进程的环…
阅读更多...
qgis添加wms服务

qgis添加wms服务

例如添加geoserver的wms服务 左右浏览器-WMS/WMTS-右键-新建连接 URL添加geoserver的wms地址 http://{ip}:{port}/geoserver/{workspace}/wms 展开wms目录&#xff0c;双击相应图层即可打开
阅读更多...
Spark---基于Yarn模式提交任务

Spark---基于Yarn模式提交任务

Yarn模式两种提交任务方式 一、yarn-client提交任务方式 1、提交命令 ./spark-submit --master yarn --class org.apache.spark.examples.SparkPi ../examples/jars/spark-examples_2.11-2.3.1.jar 100 或者 ./spark-submit --master yarn–client --class org.apache.s…
阅读更多...
三菱PLC应用[集锦]

三菱PLC应用[集锦]

三菱PLC应用[集锦] 如何判断用PNP还是NPN的个人工作心得 10&#xff5e;30VDC接近开关与PLC连接时&#xff0c;如何判断用PNP还是NPN的个人工作心得: 对于PLC的开关量输入回路。我个人感觉日本三菱的要好得多&#xff0c;甚至比西门子等赫赫大名的PLC都要实用和可靠&#xff01…
阅读更多...
vulnhub4

vulnhub4

靶机地址: https://download.vulnhub.com/admx/AdmX_new.7z 信息收集 fscan 扫一下 ┌──(kali㉿kali)-[~/Desktop/Tools/fscan] └─$ ./fscan_amd64 -h 192.168.120.138 ___ _ / _ \ ___ ___ _ __ __ _ ___| | __ / /_\/____/ __|/ …
阅读更多...
LeetCode | 622. 设计循环队列

LeetCode | 622. 设计循环队列

LeetCode | 622. 设计循环队列 OJ链接 思路&#xff1a; 我们这里有一个思路&#xff1a; 插入数据&#xff0c;bank往后走 删除数据&#xff0c;front往前走 再插入数据&#xff0c;就循环了 那上面这个方法可行吗&#xff1f; 怎么判断满&#xff0c;怎么判断空&#xff1…
阅读更多...
模电知识点总结（二）二极管

模电知识点总结（二）二极管

系列文章目录 文章目录 系列文章目录二极管二极管电路分析方法理想模型恒压降模型折线模型小信号模型高频/开关 二极管应用整流限幅/钳位开关齐纳二极管变容二极管肖特基二极管光电器件光电二极管发光二极管激光二极管太阳能电池 二极管 硅二极管&#xff1a;死区电压&#xf…
阅读更多...
今年注册电气工程师考试乱象及就业前景分析

今年注册电气工程师考试乱象及就业前景分析

1、注册电气工程师挂靠价格 # 2011年以前约为5万一年&#xff0c;2011年开始强制实施注册电气执业制度&#xff0c;证书挂靠价格开始了飞涨&#xff0c;2013年达到巅峰&#xff0c;供配电15万一年&#xff0c;发输变电20-25万一年&#xff0c;这哪里是证书&#xff0c;简直就是…
阅读更多...
Docker kill 命令

Docker kill 命令

docker kill&#xff1a;杀死一个或多个正在运行的容器。 语法&#xff1a; docker kill [OPTIONS] CONTAINER [CONTAINER...]OPTIONS说明&#xff1a; -s&#xff1a;向容器发送一个信号 描述&#xff1a; docker kill子命令会杀死一个或多个容器。容器内的主进程被发送S…
阅读更多...
C语言数组的距离（ZZULIOJ1200:数组的距离）

C语言数组的距离（ZZULIOJ1200:数组的距离）

题目描述 已知元素从小到大排列的两个数组x[]和y[]&#xff0c; 请写出一个程序算出两个数组彼此之间差的绝对值中最小的一个&#xff0c;这叫做数组的距离 。 输入&#xff1a;第一行为两个整数m, n(1≤m, n≤1000)&#xff0c;分别代表数组f[], g[]的长度。第二行有m个元素&a…
阅读更多...
如何在Simulink中使用syms？换个思路解决报错：Function ‘syms‘ not supported for code generation.

如何在Simulink中使用syms？换个思路解决报错：Function ‘syms‘ not supported for code generation.

问题描述 在Simulink中的User defined function使用syms函数&#xff0c;报错simulink无法使用外部函数。 具体来说&#xff1a; 我想在Predefined function定义如下符号函数作为输入信号&#xff0c;在后续模块传入函数参数赋值&#xff0c;以实现一次定义多次使用&#xf…
阅读更多...
014:MyString

014:MyString

题目 描述 补足MyString类&#xff0c;使程序输出指定结果 #include <iostream> #include <string> #include <cstring> using namespace std; class MyString {char * p; public:MyString(const char * s) {if( s) {p new char[strlen(s) 1];strcpy(p,…
阅读更多...
最小二乘线性回归

最小二乘线性回归

​ 线性回归&#xff08;linear regression&#xff09;&#xff1a;试图学得一个线性模型以尽可能准确地预测实际值的输出。 以一个例子来说明线性回归&#xff0c;假设银行贷款会根据 年龄 和 工资 来评估可放款的额度。即&#xff1a; ​ 数据&#xff1a;工资和年龄&…
阅读更多...
python将模块进行打包

python将模块进行打包

模块名称为&#xff1a;my_module 目录结构&#xff1a; my_modulemy_module__init__.pymy_module_main.pysetup.pypython setup.pu sdist bdist_wheel生成tar.gz包和whl文件用于安装 """ python setup.py sdist bdist_wheel """from setuptoo…
阅读更多...
LeeCode前端算法基础100题（2）- 最多水的容器

LeeCode前端算法基础100题（2）- 最多水的容器

一、问题详情&#xff1a; 给定一个长度为 n 的整数数组 height 。有 n 条垂线&#xff0c;第 i 条线的两个端点是 (i, 0) 和 (i, height[i]) 。 找出其中的两条线&#xff0c;使得它们与 x 轴共同构成的容器可以容纳最多的水。 返回容器可以储存的最大水量。 说明&#xff1a;…
阅读更多...
案例025:基于微信小程序的移动学习平台的设计与实现

案例025:基于微信小程序的移动学习平台的设计与实现

文末获取源码 开发语言&#xff1a;Java 框架&#xff1a;SSM JDK版本&#xff1a;JDK1.8 数据库&#xff1a;mysql 5.7 开发软件&#xff1a;eclipse/myeclipse/idea Maven包&#xff1a;Maven3.5.4 小程序框架&#xff1a;uniapp 小程序开发软件&#xff1a;HBuilder X 小程序…
阅读更多...
[C++历练之路]优先级队列||反向迭代器的模拟实现

[C++历练之路]优先级队列||反向迭代器的模拟实现

W...Y的主页 &#x1f60a; 代码仓库分享&#x1f495; &#x1f354;前言&#xff1a; 在C的宇宙中&#xff0c;优先队列似乎是一座巨大的宝库&#xff0c;藏匿着算法的珍宝。而就在这片代码的天空下&#xff0c;我们不仅可以探索优先队列的神奇&#xff0c;还能够揭开反向迭…
阅读更多...
shutil和fileinput模块：文件操作的最佳实践

shutil和fileinput模块：文件操作的最佳实践

在Python中&#xff0c;shutil和fileinput模块是处理文件和输入/输出(I/O)操作的有力工具。shutil模块提供了一种在Python中操作文件的高级接口&#xff0c;而fileinput模块则允许我们轻松地读取多个输入流。 shutil模块 shutil模块是Python的标准库之一&#xff0c;提供了很…
阅读更多...
【【Linux系统下常用指令学习 之 二 】】

【【Linux系统下常用指令学习 之 二 】】

Linux系统下常用指令学习 之 二 文件查询和搜索 文件的查询和搜索也是最常用的操作&#xff0c;在嵌入式 Linux 开发中常常需要在 Linux 源码文件中查询某个文件是否存在&#xff0c;或者搜索哪些文件都调用了某个函数等等。 1、命令 find find 命令用于在目录结构中查找文件…
阅读更多...
BUUCTF [ACTF新生赛2020]outguess 1

BUUCTF [ACTF新生赛2020]outguess 1

BUUCTF:https://buuoj.cn/challenges 题目描述&#xff1a; 得到的 flag 请包上 flag{} 提交。 密文&#xff1a; 下载附件&#xff0c;得到一堆文件。 解题思路&#xff1a; 1、根据题目和flag.txt文件提示&#xff0c;猜测为outguess隐写。 outguess下载安装 kail 终端命…
阅读更多...
最新文章

Copyright @ 2022~2023