教授通过代码示例学习Commons HTTPClient4组件的编程技术——多线程模式下使用HttpClient4组件

httpclient4  时间:2021-01-29  阅读:()

杨教授工作室精心创作的优秀程序员职业提升必读系列资料

1. 1 多线程模式下使用HttpClient4组件

1. 1. 1 ThreadSafeClientConnManager类

1、对于同一个HttpConnection同一个时间只能有一个线程访问

由于连接是一种有限的资源每个连接在某一时刻只能供一个线程和方法使用所以需要确保在需要时正确地分配连接。HttpC lient采用了一种类似jdbc连接池的方法来管理连接这个管理工作由MultiThreadedHttpConnec tio nManager完成。

为了保证多线程工作环境下不产生冲突 httpc lie nt使用了一个多线程连接管理器的类ThreadS a feC lientCo nnManager。

2、 ThreadS a feC lie ntC o nnManager类

ThreadSafeClientConnManager类支持下面的两个默认设置项目

 ConnManagerPNames.MAX_CONNECTIONS_PER_ROUTE每个主机的最大并行链接数默认为2

 ConnManagerPNames.MAX_TOTAL_CONNECTIONS客户端总并行链接最大数默认为20

3、 SchemeRegistry类

4、添加一个线程类

1类名称为MultiGetThread包名称为co m.p x1987.httpc lient并且继承j ava.lang.Thread

杨教授工作室版权所有盗版必究 1/7页

杨教授工作室精心创作的优秀程序员职业提升必读系列资料类

2编程该类的代码package com.px1987.httpclient;import java. io. IOException;import org.apache.http.HttpEntity;import org.apache.http.HttpResponse;import org.apache.http.client.HttpClient;import org.apache.http.client.methods.HttpGet;import org.apache.http.protocol.BasicHttpContext;import org.apache.http.protocol.HttpContext;import org.apache.http.util.EntityUtils;public class MultiGetThread extends Thread {

杨教授工作室精心创作的优秀程序员职业提升必读系列资料private final HttpClient httpClient;private final HttpContext context;private final HttpGet httpGetMethod;private final int threadNo;public MultiGetThread(HttpClient httpClient, HttpGet httpGetMethod, intthreadNo) {this.httpClient = httpClient;this.context = new BasicHttpContext() ;this.httpGetMethod = httpGetMethod;this. threadNo = threadNo;

}

@Overridepublic void run() {

System.out.println(threadNo + " 号 线 程 将要 访 问  " +httpGetMethod.getURI() ) ;try {

HttpResponse response = httpClient.execute(httpGetMethod, context) ;

HttpEntity entity = response.getEntity() ;if (entity != null) {byte[] bytes = EntityUtils. toByteArray(entity) ;

System.out.println(threadNo + "号线程获得长度为" + bytes. length + "字节数据。 ") ;

}

} catch (IOException exception) {

System.out.println(threadNo+"号线程执行过程中出现了下面的错误 "+exception) ;

}finally{httpGetMethod.abort() ;

}

杨教授工作室版权所有盗版必究 3/7页

杨教授工作室精心创作的优秀程序员职业提升必读系列资料}

}

注意需要对每一个HttpClient.execute()的调用必须要有一个abort()与之匹配。

5、多线程模式下使用HttpC lient的代码示例——HttpC lientMultiThreadedDemo

1在项目中添加HttpClientMultiThreadedDemo类

2代码示例package com.px1987.httpclient;import org.apache.http.HttpVersion;import org.apache.http.client.HttpClient;import org.apache.http.client.methods.HttpGet;import org.apache.http.conn.ClientConnectionManager;import org.apache.http.conn.params.ConnManagerParams;import org.apache.http.conn. scheme.PlainSocketFactory;

杨教授工作室精心创作的优秀程序员职业提升必读系列资料import org.apache.http.conn. scheme.Scheme;import org.apache.http.conn. scheme.SchemeRegistry;import org.apache.http.conn. ssl.SSLSocketFactory;import org.apache.http. impl.client.DefaultHttpClient;import org.apache.http. impl.conn. tsccm.ThreadSafeClientConnManager;import org.apache.http.params.BasicHttpParams;import org.apache.http.params.HttpParams;import org.apache.http.params.HttpProtocolParams;public class HttpClientMultiThreadedDemo {

HttpClient httpClient=null;public HttpClientMultiThreadedDemo() {

HttpParams params = new BasicHttpParams() ;

ConnManagerParams. setMaxTotalConnections(params, 100) ;

HttpProtocolParams. setVersion(params, HttpVersion.HTTP_1_1) ;

SchemeRegistry schemeRegistry = new SchemeRegistry() ;schemeRegistry.register(new Scheme("http",

PlainSocketFactory.getSocketFactory() , 8080) ) ;schemeRegistry.register(new Scheme("https",

SSLSocketFactory.getSocketFactory() , 8443) ) ;

ClientConnectionManager cm = new ThreadSafeClientConnManager(params,schemeRegistry) ;httpClient = new DefaultHttpClient(cm, params) ;

String targetURIToGet = "http://127. 0.0. 1:8080/webbank/index. jsp";MultiGetThread[] threads = new MultiGetThread[10] ;for (int i = 0; i < threads. length; i++) {

HttpGet httpGetMethod = new HttpGet(targetURIToGet) ;threads[i] = new MultiGetThread(httpClient, httpGetMethod, i + 1) ;threads[i] . start() ;

}

/*

杨教授工作室版权所有盗版必究 5/7页

杨教授工作室精心创作的优秀程序员职业提升必读系列资料

*不能再此释放连接 因为在线程中海需要应用 httpClient对象本示例为异

步请求

*/

// httpClient.getConnectionManager() . shutdown() ;

}protected void finalize() {httpCl ient.getConnectionManager() . shutdown() ; //释放连接

}public static void main(String[] args) throws Exception {

HttpClientMultiThreadedDemo httpClientMultiThreadedDemo=newHttpClientMultiThreadedDemo() ;

}

}

在客户端的代码中同时产生出10个线程 向同一个URL地址发送请求。注意释放httpClient对象的方式否则会出现下面的错误。

6、示例代码执行的结果

杨教授工作室版权所有盗版必究 6/7页

杨教授工作室精心创作的优秀程序员职业提升必读系列资料

该示例其实是Web性能测试的基础。

webhosting24:€28/年,日本NVMe3900X+Webvps

webhosting24决定从7月1日开始对日本机房的VPS进行NVMe和流量大升级,几乎是翻倍了硬盘和流量,当然前提是价格依旧不变。目前来看,国内过去走的是NTT直连,服务器托管机房应该是CDN77*(也就是datapacket.com),加上高性能平台(AMD Ryzen 9 3900X+NVMe),这样的日本VPS还是有相当大的性价比的。官方网站:https://www.webhosting...

PIGYUN:美国联通CUVIPCUVIP限时cuvip、AS9929、GIA/韩国CN2机房限时六折

pigyun怎么样?PIGYunData成立于2019年,2021是PIGYun为用户提供稳定服务的第三年,目前商家提供香港CN2线路、韩国cn2线路、美西CUVIP-9929、GIA等线路优质VPS,基于KVM虚拟架构,商家采用魔方云平台,所有的配置都可以弹性选择,目前商家推出了七月优惠,韩国和美国所有线路都有相应的促销,六折至八折,性价比不错。点击进入:PIGYun官方网站地址PIGYUN优惠...

注册做什么96%可以干啥,常用的7个常用的国内国外域名注册服务商_云服务器可以干什么

日前,国内知名主机服务商阿里云与国外资深服务器面板Plesk强强联合,推出 阿里云域名注册与备案、服务器ECS购买与登录使用 前言云服务器(Elastic  只需要确定cpu内存与带宽基本上就可以了,对于新手用户来说,我们在购买阿里云服务申请服务器与域名许多云服务商的云服务器配置是弹性的 三周学会小程序第三讲:服务 不过这个国外服务器有点慢,可以考虑国内的ngrokcc。 ngrokcc...

httpclient4为你推荐
内存卡数据恢复软件谁有恢复内存卡数据的好用的软件~~~急天玑1000plus和骁龙865哪个好CPU型号 MediaTek MT6853 5G,和天玑1000+哪个好?燃气热水器和电热水器哪个好燃气热水器和电热水器的区别是什么,哪个比较好?朱祁钰和朱祁镇哪个好朱高炽在位时间长还是朱祁钰在位时间长?石英表和机械表哪个好手表是电子手表好还是机械手表好?炒股软件哪个好炒股软件真的那么好用吗?qq空间登录QQ页面上空间不能登陆了,怎么回事?qq空间登录器QQ空间校友网页自动登陆器yy空间登录怎么登陆YY空间飞信空间登录飞信客户端空间登录 飞信绿色版历史记录
最便宜虚拟主机 域名商 vmsnap3 网通ip 空间论坛 北京双线 如何安装服务器系统 web服务器是什么 主机返佣 网络速度 广东服务器托管 免费赚q币 时间服务器 godaddy中文 webmin 服务器是什么意思 侦探online easypanel 卡巴下载 神棍节 更多