杨教授工作室精心创作的优秀程序员职业提升必读系列资料
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性能测试的基础。
最近我们是不是在讨论较多的是关于K12教育的问题,培训机构由于资本的介入确实让家长更为焦虑,对于这样的整改我们还是很支持的。实际上,在云服务器市场中,我们也看到内卷和资本的力量,各大云服务商竞争也是相当激烈,更不用说个人和小公司服务商日子确实不好过。今天有看到UCloud发布的夏季促销活动,直接提前和双十一保价挂钩。这就是说,人家直接在暑假的时候就上线双十一的活动。早年的双十一活动会提前一周到十天...
搬瓦工最新优惠码优惠码:BWH3HYATVBJW,节约6.58%,全场通用!搬瓦工关闭香港 PCCW 机房通知下面提炼一下邮件的关键信息,原文在最后面。香港 CN2 GIA 机房自从 2020 年上线以来,网络性能大幅提升,所有新订单都默认部署在香港 CN2 GIA 机房;目前可以免费迁移到香港 CN2 GIA 机房,在 KiwiVM 控制面板选择 HKHK_8 机房进行迁移即可,迁移会改变 IP...
我们一般的站长或者企业服务器配置WEB环境会用到免费版本的宝塔面板。但是如果我们需要较多的付费插件扩展,或者是有需要企业功能应用的,短期来说我们可能选择按件按月付费的比较好,但是如果我们长期使用的话,有些网友认为选择宝塔面板企业版或者专业版是比较划算的。这样在年中大促618的时候,我们也可以看到宝塔面板也有发布促销活动。企业版年付899元,专业版永久授权1888元起步。对于有需要的网友来说,还是值...