使用 jdk1.8 lambda 表达式对 HttpClient 进行封装

本贴最后更新于 2912 天前,其中的信息可能已经时异事殊

1、使用 jdk lambda 表达式对 HttpClient 进行封装
2、HttpClient 的版本为 4.5.1
3、支持 http 和 https

import org.apache.http.HttpEntity;
import org.apache.http.HttpStatus;
import org.apache.http.NameValuePair;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.methods.HttpRequestBase;
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.ssl.SSLContextBuilder;
import org.apache.http.util.EntityUtils;

import javax.net.ssl.SSLContext;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.security.GeneralSecurityException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.logging.Logger;

/**

  • 说明: HttpClient 工具类
  • httpsclient 版本:4.5.1
  • @author xiaoting
  • Created by 2017-04-06 13:56

/
public class HttpClientUtil {
/

* 日志
/
private static final Logger log = Logger.getLogger("lavasoft");
/
*
* 请求编码
/
private static final String CHARSET_UTF_8 = "UTF-8";
/
*
* json 头
/
private static final String CONTENT_TYPE_JSON = "application/json";
/
*
* xml 请求
/
private static final String CONTENT_TYPE_XML = "text/xml";
/
*
* 连接池
/
private static PoolingHttpClientConnectionManager connMgr;
/
*
* 请求配置
*/
private static RequestConfig requestConfig;

/** * 超时时间 */ private static final int MAX_TIMEOUT = 7000; static { // 设置连接池 connMgr = new PoolingHttpClientConnectionManager(); // 设置连接池大小 connMgr.setMaxTotal(100); connMgr.setDefaultMaxPerRoute(connMgr.getMaxTotal()); /*校验链接*/ connMgr.setValidateAfterInactivity(1000); RequestConfig.Builder configBuilder = RequestConfig.custom(); // 设置连接超时 configBuilder.setConnectTimeout(MAX_TIMEOUT); // 设置读取超时 configBuilder.setSocketTimeout(MAX_TIMEOUT); // 设置从连接池获取连接实例的超时 configBuilder.setConnectionRequestTimeout(MAX_TIMEOUT); requestConfig = configBuilder.build(); } /** * 发送get请求 * * @param url url * @return */ public static String get(String url) { return doGet(url, new HashMap<>()); } /** * 发送get请求 * * @param url url * @return */ public static String getHttps(String url) { return doGet(url, new HashMap<>(), false); } /** * 发送get请求 https * * @param url url * @return */ public static String getHttps(String url, Map<String, Object> params) { return doGet(url, params, false); } public static String doGet(String url, Map<String, Object> params, boolean bl) { log.info("____请求参数:" + params.toString()); String param = getStringBuffer(params); String finalApiUrl = url + param; return HttpClient.domain(httpClient -> { HttpGet httpGet = new HttpGet(finalApiUrl); return execute(httpClient, httpGet); }, bl); } /** * 发送 GET 请求(HTTP),K-V形式 * * @param url * @param params * @return */ public static String doGet(String url, Map<String, Object> params) { return doGet(url, params, true); } private static String getStringBuffer(Map<String, Object> params) { if (MapUtil.isNotNull(params)) { StringBuffer param = new StringBuffer(); int i = 0; for (String key : params.keySet()) { if (i == 0) { param.append("?"); } else { param.append("&"); } param.append(key).append("=").append(params.get(key)); i++; } return param.toString(); } else { return ""; } } /** * 发送post请求 * * @param url post url * @param params post参数 * @return */ public static String post(String url, Map<String, Object> params) { log.info("____请求参数:" + params.toString()); return HttpClient.domain(httpClient -> { HttpPost httpPost = httpPostHandler(url, params); return execute(httpClient, httpPost); }, true); } /** * 发送post请求 * * @param url post url * @return */ public static String post(String url) { return post(url, new HashMap<>()); } /** * post json数据 * * @param url * @param jsonStr * @return */ public static String postJson(String url, String jsonStr) { log.info("____请求参数:" + jsonStr); return HttpClient.domain(httpClient -> { HttpPost httpPost = new HttpPost(url); StringEntity stringEntity; try { stringEntity = new StringEntity(jsonStr); } catch (UnsupportedEncodingException e) { return null; } httpPost.setHeader("Content-Type", CONTENT_TYPE_JSON); httpPost.setEntity(stringEntity); return execute(httpClient, httpPost); }, true); } /** * 发送 SSL POST 请求(HTTPS),K-V形式 * * @param apiUrl API接口URL * @param params 参数map * @return */ public static String doPostSSL(String url, Map<String, Object> params) { log.info("____请求参数:" + params.toString()); return HttpClient.domain(httpClient -> { HttpPost httpPost = httpPostHandler(url, params); return execute(httpClient, httpPost); }, false); } /** * 发送 SSL POST 请求(HTTPS),JSON形式 * * @param apiUrl API接口URL * @param json JSON对象 * @return */ public static String doPostSSL(String apiUrl, Object json) { log.info("____请求参数:" + json); return HttpClient.domain(httpClient -> { HttpPost httpPost = new HttpPost(apiUrl); StringEntity stringEntity; stringEntity = new StringEntity(json.toString(), CHARSET_UTF_8); stringEntity.setContentEncoding(CHARSET_UTF_8); httpPost.setHeader("Content-Type", CONTENT_TYPE_JSON); httpPost.setEntity(stringEntity); return execute(httpClient, httpPost); }, false); } /* public static String postXml(String url, Object xmlObj) { String res = null; CloseableHttpClient httpClient = HttpClients.createDefault(); try { HttpPost httpPost = new HttpPost(url); //解决XStream对出现双下划线的bug XStream xStreamForRequestPostData = new XStream(new DomDriver("UTF-8", new XmlFriendlyNameCoder("-_", "_"))); //将要提交给API的数据对象转换成XML格式数据Post给API String postDataXML = xStreamForRequestPostData.toXML(xmlObj); //得指明使用UTF-8编码,否则到API服务器XML的中文不能被成功识别 StringEntity postEntity = new StringEntity(postDataXML, "UTF-8"); httpPost.addHeader("Content-Type", CONTENT_TYPE_XML); httpPost.setEntity(postEntity); res = execute(httpClient, httpPost); } finally { doHttpClientClose(httpClient); } return res; }*/ private static HttpPost httpPostHandler(String url, Map<String, Object> params) { HttpPost httpPost = new HttpPost(url); List<NameValuePair> naps = new ArrayList<>(); if (MapUtil.isNotNull(params)) { for (Map.Entry<String, Object> entry : params.entrySet()) { naps.add(new BasicNameValuePair(entry.getKey(), entry.getValue().toString())); } } try { httpPost.setEntity(new UrlEncodedFormEntity(naps, CHARSET_UTF_8)); } catch (UnsupportedEncodingException e) { e.printStackTrace(); } return httpPost; } private static String execute(CloseableHttpClient httpClient, HttpRequestBase httpGetOrPost) { String res = null; CloseableHttpResponse response = null; try { httpGetOrPost.setConfig(requestConfig); log.info("________请求url:" + httpGetOrPost.getURI()); response = httpClient.execute(httpGetOrPost); log.info("________返回code:" + response.getStatusLine().getStatusCode()); if (response.getStatusLine().getStatusCode() != HttpStatus.SC_OK) { return null; } HttpEntity entity = response.getEntity(); res = EntityUtils.toString(entity, CHARSET_UTF_8); log.info("________返回值:" + res); } catch (IOException e) { e.printStackTrace(); } finally { doResponseClose(response); } return res; } private static void doHttpClientClose(CloseableHttpClient httpClient) { if (httpClient != null) { try { httpClient.close(); } catch (IOException e) { e.printStackTrace(); } } } private static void doResponseClose(CloseableHttpResponse response) { if (response != null) { try { response.close(); } catch (IOException e) { e.printStackTrace(); } } } public interface HttpClientInterface<T> { T domain(CloseableHttpClient httpClient); } static class HttpClient { /** * @param interfaces 具体的操作接口 * @param bl 是否是http请求,false https true http * @param <T> 返回泛型 * @return */ public static <T extends Object> T domain(HttpClientInterface<T> interfaces, boolean bl) { // 返回值 T object; CloseableHttpClient httpClient; if (bl) { httpClient = HttpClients.createDefault(); } else { httpClient = HttpClients.custom().setSSLSocketFactory(createSSLConnSocketFactory()). setConnectionManager(connMgr).setDefaultRequestConfig(requestConfig). setConnectionManagerShared(true).build(); } try { // 业务操作 object = interfaces.domain(httpClient); } finally { doHttpClientClose(httpClient); } return object; } } /** * 创建SSL安全连接 * * @return */ private static SSLConnectionSocketFactory createSSLConnSocketFactory() { SSLConnectionSocketFactory sslsf = null; try { SSLContext sslContext = new SSLContextBuilder().loadTrustMaterial(null, (chain, authType) -> true).build(); sslsf = new SSLConnectionSocketFactory(sslContext, (arg0, agr1) -> true); } catch (GeneralSecurityException e) { e.printStackTrace(); } return sslsf; }

}

  • B3log

    B3log 是一个开源组织,名字来源于“Bulletin Board Blog”缩写,目标是将独立博客与论坛结合,形成一种新的网络社区体验,详细请看 B3log 构思。目前 B3log 已经开源了多款产品:SymSoloVditor思源笔记

    1062 引用 • 3455 回帖 • 149 关注

相关帖子

欢迎来到这里!

我们正在构建一个小众社区,大家在这里相互信任,以平等 • 自由 • 奔放的价值观进行分享交流。最终,希望大家能够找到与自己志同道合的伙伴,共同成长。

注册 关于
请输入回帖内容 ...

推荐标签 标签

  • TensorFlow

    TensorFlow 是一个采用数据流图(data flow graphs),用于数值计算的开源软件库。节点(Nodes)在图中表示数学操作,图中的线(edges)则表示在节点间相互联系的多维数据数组,即张量(tensor)。

    20 引用 • 19 回帖 • 3 关注
  • 大疆创新

    深圳市大疆创新科技有限公司(DJI-Innovations,简称 DJI),成立于 2006 年,是全球领先的无人飞行器控制系统及无人机解决方案的研发和生产商,客户遍布全球 100 多个国家。通过持续的创新,大疆致力于为无人机工业、行业用户以及专业航拍应用提供性能最强、体验最佳的革命性智能飞控产品和解决方案。

    2 引用 • 14 回帖
  • SEO

    发布对别人有帮助的原创内容是最好的 SEO 方式。

    36 引用 • 200 回帖 • 39 关注
  • jQuery

    jQuery 是一套跨浏览器的 JavaScript 库,强化 HTML 与 JavaScript 之间的操作。由 John Resig 在 2006 年 1 月的 BarCamp NYC 上释出第一个版本。全球约有 28% 的网站使用 jQuery,是非常受欢迎的 JavaScript 库。

    63 引用 • 134 回帖 • 734 关注
  • PWA

    PWA(Progressive Web App)是 Google 在 2015 年提出、2016 年 6 月开始推广的项目。它结合了一系列现代 Web 技术,在网页应用中实现和原生应用相近的用户体验。

    14 引用 • 69 回帖 • 184 关注
  • TextBundle

    TextBundle 文件格式旨在应用程序之间交换 Markdown 或 Fountain 之类的纯文本文件时,提供更无缝的用户体验。

    1 引用 • 2 回帖 • 83 关注
  • 脑图

    脑图又叫思维导图,是表达发散性思维的有效图形思维工具 ,它简单却又很有效,是一种实用性的思维工具。

    32 引用 • 99 回帖
  • webpack

    webpack 是一个用于前端开发的模块加载器和打包工具,它能把各种资源,例如 JS、CSS(less/sass)、图片等都作为模块来使用和处理。

    42 引用 • 130 回帖 • 254 关注
  • Vim

    Vim 是类 UNIX 系统文本编辑器 Vi 的加强版本,加入了更多特性来帮助编辑源代码。Vim 的部分增强功能包括文件比较(vimdiff)、语法高亮、全面的帮助系统、本地脚本(Vimscript)和便于选择的可视化模式。

    29 引用 • 66 回帖
  • Node.js

    Node.js 是一个基于 Chrome JavaScript 运行时建立的平台, 用于方便地搭建响应速度快、易于扩展的网络应用。Node.js 使用事件驱动, 非阻塞 I/O 模型而得以轻量和高效。

    139 引用 • 269 回帖 • 1 关注
  • SMTP

    SMTP(Simple Mail Transfer Protocol)即简单邮件传输协议,它是一组用于由源地址到目的地址传送邮件的规则,由它来控制信件的中转方式。SMTP 协议属于 TCP/IP 协议簇,它帮助每台计算机在发送或中转信件时找到下一个目的地。

    4 引用 • 18 回帖 • 636 关注
  • Eclipse

    Eclipse 是一个开放源代码的、基于 Java 的可扩展开发平台。就其本身而言,它只是一个框架和一组服务,用于通过插件组件构建开发环境。

    76 引用 • 258 回帖 • 625 关注
  • JVM

    JVM(Java Virtual Machine)Java 虚拟机是一个微型操作系统,有自己的硬件构架体系,还有相应的指令系统。能够识别 Java 独特的 .class 文件(字节码),能够将这些文件中的信息读取出来,使得 Java 程序只需要生成 Java 虚拟机上的字节码后就能在不同操作系统平台上进行运行。

    180 引用 • 120 回帖 • 3 关注
  • BookxNote

    BookxNote 是一款全新的电子书学习工具,助力您的学习与思考,让您的大脑更高效的记忆。

    笔记整理交给我,一心只读圣贤书。

    1 引用 • 1 回帖 • 5 关注
  • Notion

    Notion - The all-in-one workspace for your notes, tasks, wikis, and databases.

    10 引用 • 77 回帖
  • NGINX

    NGINX 是一个高性能的 HTTP 和反向代理服务器,也是一个 IMAP/POP3/SMTP 代理服务器。 NGINX 是由 Igor Sysoev 为俄罗斯访问量第二的 Rambler.ru 站点开发的,第一个公开版本 0.1.0 发布于 2004 年 10 月 4 日。

    315 引用 • 547 回帖
  • 国际化

    i18n(其来源是英文单词 internationalization 的首末字符 i 和 n,18 为中间的字符数)是“国际化”的简称。对程序来说,国际化是指在不修改代码的情况下,能根据不同语言及地区显示相应的界面。

    8 引用 • 26 回帖
  • 正则表达式

    正则表达式(Regular Expression)使用单个字符串来描述、匹配一系列遵循某个句法规则的字符串。

    31 引用 • 94 回帖
  • NetBeans

    NetBeans 是一个始于 1997 年的 Xelfi 计划,本身是捷克布拉格查理大学的数学及物理学院的学生计划。此计划延伸而成立了一家公司进而发展这个商用版本的 NetBeans IDE,直到 1999 年 Sun 买下此公司。Sun 于次年(2000 年)六月将 NetBeans IDE 开源,直到现在 NetBeans 的社群依然持续增长。

    78 引用 • 102 回帖 • 712 关注
  • C++

    C++ 是在 C 语言的基础上开发的一种通用编程语言,应用广泛。C++ 支持多种编程范式,面向对象编程、泛型编程和过程化编程。

    108 引用 • 153 回帖 • 1 关注
  • QQ

    1999 年 2 月腾讯正式推出“腾讯 QQ”,在线用户由 1999 年的 2 人(马化腾和张志东)到现在已经发展到上亿用户了,在线人数超过一亿,是目前使用最广泛的聊天软件之一。

    45 引用 • 557 回帖
  • abitmean

    有点意思就行了

    35 关注
  • ZeroNet

    ZeroNet 是一个基于比特币加密技术和 BT 网络技术的去中心化的、开放开源的网络和交流系统。

    1 引用 • 21 回帖 • 651 关注
  • 爬虫

    网络爬虫(Spider、Crawler),是一种按照一定的规则,自动地抓取万维网信息的程序。

    106 引用 • 275 回帖
  • 设计模式

    设计模式(Design pattern)代表了最佳的实践,通常被有经验的面向对象的软件开发人员所采用。设计模式是软件开发人员在软件开发过程中面临的一般问题的解决方案。这些解决方案是众多软件开发人员经过相当长的一段时间的试验和错误总结出来的。

    201 引用 • 120 回帖 • 1 关注
  • 知乎

    知乎是网络问答社区,连接各行各业的用户。用户分享着彼此的知识、经验和见解,为中文互联网源源不断地提供多种多样的信息。

    10 引用 • 66 回帖
  • AngularJS

    AngularJS 诞生于 2009 年,由 Misko Hevery 等人创建,后为 Google 所收购。是一款优秀的前端 JS 框架,已经被用于 Google 的多款产品当中。AngularJS 有着诸多特性,最为核心的是:MVC、模块化、自动化双向数据绑定、语义化标签、依赖注入等。2.0 版本后已经改名为 Angular。

    12 引用 • 50 回帖 • 522 关注