如果你是使用maven来管理项目,你需要在pom.xml添加如下配置:
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
<version>4.5</version>
</dependency>
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpmime</artifactId>
<version>4.5</version>
</dependency>
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpcore</artifactId>
<version>4.4.1</version>
</dependency>
示例代码如下:
package org.apache.http.examples.entity.mime; import java.io.IOException; import java.io.InterruptedIOException; import java.net.UnknownHostException; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Map.Entry; import javax.net.ssl.SSLException; import org.apache.commons.codec.Charsets; import org.apache.http.Header; import org.apache.http.HttpEntityEnclosingRequest; import org.apache.http.HttpRequest; import org.apache.http.HttpResponse; import org.apache.http.client.HttpClient; import org.apache.http.client.HttpRequestRetryHandler; import org.apache.http.client.config.RequestConfig; import org.apache.http.client.methods.HttpGet; import org.apache.http.client.methods.HttpPost; import org.apache.http.client.protocol.HttpClientContext; import org.apache.http.client.utils.URIBuilder; import org.apache.http.config.SocketConfig; import org.apache.http.conn.ConnectTimeoutException; import org.apache.http.impl.client.HttpClients; import org.apache.http.impl.conn.PoolingHttpClientConnectionManager; import org.apache.http.protocol.HttpContext; import org.apache.http.util.EntityUtils; /** * 使用HttpClient发送和接收Http请求 * * @author manzhizhen * */ public class HttpUtils { private static HttpClient httpClient; // 最大连接数 private static final int MAX_CONNECTION = 100; // 每个route能使用的最大连接数,一般和MAX_CONNECTION取值一样 private static final int MAX_CONCURRENT_CONNECTIONS = 100; // 建立连接的超时时间,单位毫秒 private static final int CONNECTION_TIME_OUT = 200; // 请求超时时间,单位毫秒 private static final int REQUEST_TIME_OUT = 200; // 最大失败重试次数 private static final int MAX_FAIL_RETRY_COUNT = 3; // 请求配置,可以复用 private static RequestConfig requestConfig; static { SocketConfig socketConfig = SocketConfig.custom() .setSoTimeout(REQUEST_TIME_OUT).setSoKeepAlive(true) .setTcpNoDelay(true).build(); requestConfig = RequestConfig.custom() .setSocketTimeout(REQUEST_TIME_OUT) .setConnectTimeout(CONNECTION_TIME_OUT).build(); /** * 每个默认的 ClientConnectionPoolManager 实现将给每个route创建不超过2个并发连接,最多20个连接总数。 */ PoolingHttpClientConnectionManager connManager = new PoolingHttpClientConnectionManager(); connManager.setMaxTotal(MAX_CONNECTION); connManager.setDefaultMaxPerRoute(MAX_CONCURRENT_CONNECTIONS); connManager.setDefaultSocketConfig(socketConfig); httpClient = HttpClients.custom().setConnectionManager(connManager) // 添加重试处理器 .setRetryHandler(new MyHttpRequestRetryHandler()).build(); } public static void main(String[] args) { testGet(); } /** * 测试get方法 */ private static void testGet() { String url = "http://restapi.amap.com/v3/place/text"; Map<String, String> paramMap = new HashMap<String, String>(); paramMap.put("key", "95708f902ac2428ea119ec99fb70e6a3"); paramMap.put("keywords", "互联网金融大厦"); paramMap.put("city", "330100"); paramMap.put("extensions", "all"); try { System.out.println(get(url, paramMap)); } catch (Exception e) { e.printStackTrace(); } } /** * post请求 * * @param url * @param paramMap * @param headers * @return * @throws Exception */ public static String post(String url, Map<String, String> paramMap, List<Header> headers) throws Exception { URIBuilder uriBuilder = new URIBuilder(url); if (paramMap != null) { // 添加请求参数 for (Entry<String, String> entry : paramMap.entrySet()) { uriBuilder.addParameter(entry.getKey(), entry.getValue()); } } HttpPost httpPost = new HttpPost(uriBuilder.build()); if (headers != null) { // 添加请求首部 for (Header header : headers) { httpPost.addHeader(header); } } httpPost.setConfig(requestConfig); // 执行请求 HttpResponse response = httpClient.execute(httpPost); return EntityUtils.toString(response.getEntity(), Charsets.UTF_8); } /** * post请求,不带请求首部 * * @param url * @param paramMap * @return * @throws Exception */ public static String post(String url, Map<String, String> paramMap) throws Exception { return post(url, paramMap, null); } /** * get请求 * * @param url * @param paramMap * @param headers * @return * @throws Exception */ public static String get(String url, Map<String, String> paramMap, List<Header> headers) throws Exception { URIBuilder uriBuilder = new URIBuilder(url); if (paramMap != null) { // 添加请求参数 for (Entry<String, String> entry : paramMap.entrySet()) { uriBuilder.addParameter(entry.getKey(), entry.getValue()); } } HttpGet httpGet = new HttpGet(uriBuilder.build()); if (headers != null) { // 添加请求首部 for (Header header : headers) { httpGet.addHeader(header); } } httpGet.setConfig(requestConfig); // 执行请求 HttpResponse response = httpClient.execute(httpGet); return EntityUtils.toString(response.getEntity(), Charsets.UTF_8); } /** * get请求,不带请求首部 * * @param url * @param paramMap * @return * @throws Exception */ public static String get(String url, Map<String, String> paramMap) throws Exception { return get(url, paramMap, null); } /** * 请求重试处理器 * @author manzhizhen * */ private static class MyHttpRequestRetryHandler implements HttpRequestRetryHandler { @Override public boolean retryRequest(IOException exception, int executionCount, HttpContext context) { if (executionCount >= MAX_FAIL_RETRY_COUNT) { return false; } if (exception instanceof InterruptedIOException) { // 超时 return false; } if (exception instanceof UnknownHostException) { // 未知主机 return false; } if (exception instanceof ConnectTimeoutException) { // 连接被拒绝 return false; } if (exception instanceof SSLException) { // SSL handshake exception return false; } HttpClientContext clientContext = HttpClientContext.adapt(context); HttpRequest request = clientContext.getRequest(); boolean idempotent = !(request instanceof HttpEntityEnclosingRequest); if (idempotent) { // 如果请求被认为是幂等的,则重试 return true; } return false; } } }
相关推荐
HttpClient抓取网页Demo,HttpClient 的入门示例,配合blog文章的附件
Angular 11示例HttpClient 一个具有和的Angular入门工具包 它是一个回购系列的一部分,该系列旨在使用Angular创建渐进式Web应用程序 Web应用程序实时演示 快速开始 # choose a repo # download the example or ...
Spring Boot示范 该项目旨在展示Spring Boot。 它包含一些幻灯片的演示以及演示应用程序。... Apache HTTPClient入门 先决条件 此演示需要JDK 8以及Maven> 3.0。 启动应用程序 # ./mvnw spring-boot:run
OkHttp3入门准备工作添加依赖设置网络权限创建简单创建四步走异步请求同步请求中止请求具体介绍GET请求POST请求下载(保存到本地)简单的下载请求(示例)准备工作显示下载进度上传文件上传文件上传(简单示例)涉及...
主要给大家介绍了关于.NET CORE HttpClient的使用方法,文中通过示例代码介绍的非常详细,对大家的学习或者使用.NET CORE具有一定的参考学习价值,需要的朋友们下面来一起学习学习吧
这并不是一个完整的爬虫程序,只是一些示例。 为什么要拿C#开发爬虫项目,因为个人还是比较喜欢C#。C#虽然库少一点,但想要的功能基本还是能实现的。 总结的知识点如果什么错误之处,还恳请大家提个issue指正,一起...
客户端基于套接字的完全托管的 HttpMessageHandler 实现。 该项目是 ASP.NET vNext 的一部分。 您可以在库中找到 ASP.NET vNext 的示例、文档和入门说明。
网络爬虫的入门代码示例,采用 Java 开发语言,内容涵盖了网络爬虫的原理以及开发逻辑,Java 网络爬虫基础知识,网络抓包介绍,jsoup 的介绍与使用,HttpClient 的介绍与使用等内容。注重具体的代码实现,加深读者对...
具有HttpClient扩展方法,以使用JWT客户端凭据请求令牌。 具有一个Identity Server 4秘密验证器,该验证器了解的客户端证书授予。 集成测试。 单元测试。 NuGet 图书馆 释放 售前赛 优势 LtiAdvantage....
Planet Xamarin - 来自网络研讨会的示例应用程序加载: : rss feed 特征: HttpClient 异步读取 rss 提要 XDocument 在后台解析 下载和缓存网络图像(目前仅在 android 上缓存) 显示每个平台上的加载微调器 每...
包含一个介绍性示例,用户指南,javadoc等。 有关更改列表,请参见 。 入门实例 在这个例子中,我们展示了如何并行获取多个页面,以及如何在它们全部被检索后将它们合并。 您可以在这里找到源代码: 。 首先,...
各种EJB之间的调用源码示例,用远程接口的引用访问EJB、函数将被FirstEJB调用,同时它将调用secondEJB 基于JAVA的UDP服务器模型源代码 2个目标文件 摘要:Java源码,网络相关,UDP 基于JAVA的UDP服务器模型源代码...
各种EJB之间的调用源码示例,用远程接口的引用访问EJB、函数将被FirstEJB调用,同时它将调用secondEJB 基于JAVA的UDP服务器模型源代码 2个目标文件 摘要:Java源码,网络相关,UDP 基于JAVA的UDP服务器模型源代码...
HttpAsyncClient 的出现并不是为了替换 HttpClient,而是作为一个补充用于需要大量并发连接,对性能要求非常高的基于HTTP的原生数据通信,而且提供了事件驱动的 API。 NIO网络框架 xSocket xSocket是一个轻量级的...
HttpAsyncClient 的出现并不是为了替换 HttpClient,而是作为一个补充用于需要大量并发连接,对性能要求非常高的基于HTTP的原生数据通信,而且提供了事件驱动的 API。 NIO网络框架 xSocket xSocket是一个轻量级的...
HttpAsyncClient 的出现并不是为了替换 HttpClient,而是作为一个补充用于需要大量并发连接,对性能要求非常高的基于HTTP的原生数据通信,而且提供了事件驱动的 API。 NIO网络框架 xSocket xSocket是一个轻量级的...
HttpAsyncClient 的出现并不是为了替换 HttpClient,而是作为一个补充用于需要大量并发连接,对性能要求非常高的基于HTTP的原生数据通信,而且提供了事件驱动的 API。 NIO网络框架 xSocket xSocket是一个轻量级的...
HttpAsyncClient 的出现并不是为了替换 HttpClient,而是作为一个补充用于需要大量并发连接,对性能要求非常高的基于HTTP的原生数据通信,而且提供了事件驱动的 API。 NIO网络框架 xSocket xSocket是一个轻量级的...