Apache HttpClient 连接池的使用
发布时间:2020-12-14 23:29:06 所属栏目:Java 来源:网络整理
导读:今天PHP站长网 52php.cn把收集自互联网的代码分享给大家,仅供参考。 import java.io.IOException;import java.util.Random;import org.apache.commons.logging.Log;import org.apache.commons.logging.LogFactory;import
以下代码由PHP站长网 52php.cn收集自互联网 现在PHP站长网小编把它分享给大家,仅供参考 import java.io.IOException; import java.util.Random; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.http.HttpEntity; import org.apache.http.HttpResponse; import org.apache.http.HttpStatus; import org.apache.http.HttpVersion; import org.apache.http.client.ClientProtocolException; import org.apache.http.client.HttpClient; import org.apache.http.client.methods.HttpGet; 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.impl.client.DefaultHttpClient; import org.apache.http.impl.conn.tsccm.ThreadSafeClientConnManager; import org.apache.http.params.BasicHttpParams; import org.apache.http.params.CoreConnectionPNames; import org.apache.http.params.CoreProtocolPNames; import org.apache.http.params.HttpParams; public class HttpClientUtils { private static final Log log = LogFactory.getLog(HttpClientUtils.class); private static ThreadSafeClientConnManager cm = null; static { SchemeRegistry schemeRegistry = new SchemeRegistry(); schemeRegistry.register(new Scheme("http",80,PlainSocketFactory .getSocketFactory())); cm = new ThreadSafeClientConnManager(schemeRegistry); try { int maxTotal = 100; cm.setMaxTotal(maxTotal); } catch (NumberFormatException e) { log.error( "Key[httpclient.max_total] Not Found in systemConfig.properties",e); } // 每条通道的并发连接数设置(连接池) try { int defaultMaxConnection = 50; cm.setDefaultMaxPerRoute(defaultMaxConnection); } catch (NumberFormatException e) { log.error( "Key[httpclient.default_max_connection] Not Found in systemConfig.properties",e); } } public static HttpClient getHttpClient() { HttpParams params = new BasicHttpParams(); params.setParameter(CoreProtocolPNames.PROTOCOL_VERSION,HttpVersion.HTTP_1_1); params.setParameter(CoreConnectionPNames.CONNECTION_TIMEOUT,3000); // 3000ms return new DefaultHttpClient(cm,params); } public static void release() { if (cm != null) { cm.shutdown(); } } public static void main(String[] args) throws ClientProtocolException,IOException { Random r = new Random(); for (int i = 0; i < 10; i++) { long l1 = System.currentTimeMillis(); HttpClient client = getHttpClient(); HttpGet get = new HttpGet("http://www.baidu.com/s?wd=" + r.nextInt(5000)); HttpResponse response = client.execute(get); if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) { HttpEntity entity = response.getEntity(); long l = entity.getContentLength(); System.out.println("回应结果长度:" + l); } System.out.println("查询耗时" + (System.currentTimeMillis() - l1)); } } } 以上内容由PHP站长网【52php.cn】收集整理供大家参考研究 如果以上内容对您有帮助,欢迎收藏、点赞、推荐、分享。 (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |
相关内容
- java – 为什么onNewIntent(Intent intent)方法被调用两次?
- Java运算符>、>>、>>>三者的
- java – @GET可以为JAX-RS实现定义Consumes Content-Type吗
- Java 7的BigInteger操作有多复杂?
- Android开发中json数据解析工具类
- jpa – 添加EntityListeners后的sun.reflect.annotation.Ty
- javax.xml.bind的Base64编码器/解码器吃掉字符串的最后两个
- java_自定义标签运行原理
- Java包装器和String的对象池
- 调试 – 关闭调试堆的负面后果是什么? (_NO_DEBUG_HEAP ==