产品解决方案文档与社区免费试用定价云市场合作伙伴支持与服务了解阿里云
备案控制台登录/注册
开发者社区 开发与运维 文章 正文

[Java]Http请求的工具类

2017-10-25 6389
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 说明 该工具类从网络获取参考，在本人进行工作中，进行了部分修改； Http请求工具包，包含： 1、常用的GET/POST请求远程接口方法（可带参数、带头部信息）； 2、可自定义请求方式的请求远程接口方法（可带参数、带头部信息）； 3、可进行文件上传的请求远程接口方法； 具体内容，请大家参阅代码，希望分享出来，为朋友们提供便利； 谢谢。
+关注继续查看

说明

该工具类从网络获取参考，在本人进行工作中，进行了部分修改；

Http请求工具包，包含：
1、常用的GET/POST请求远程接口方法（可带参数、带头部信息）；
2、可自定义请求方式的请求远程接口方法（可带参数、带头部信息）；
3、可进行文件上传的请求远程接口方法；
具体内容，请大家参阅代码，希望分享出来，为朋友们提供便利；
谢谢。

HttpClientUtils .java

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.crm.restapi.result.ApiResult;
import org.apache.http.HttpEntity;
import org.apache.http.NameValuePair;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.entity.EntityBuilder;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.*;
import org.apache.http.client.utils.URIBuilder;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.StringEntity;
import org.apache.http.entity.mime.HttpMultipartMode;
import org.apache.http.entity.mime.MultipartEntityBuilder;
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.util.EntityUtils;

import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.net.URISyntaxException;
import java.nio.charset.Charset;
import java.util.ArrayList;
import java.util.Map;

public class HttpClientUtils {
    private static PoolingHttpClientConnectionManager cm;
    private static String EMPTY_STR = "";
    private static String UTF_8 = "UTF-8";

    private static void init() {
        if (cm == null) {
            cm = new PoolingHttpClientConnectionManager();
            cm.setMaxTotal(50);// 整个连接池最大连接数
            cm.setDefaultMaxPerRoute(5);// 每路由最大连接数，默认值是2
        }
    }

    /**
     * 通过连接池获取HttpClient
     *
     * @return
     */
    private static CloseableHttpClient getHttpClient() {
        init();
        return HttpClients.custom().setConnectionManager(cm).build();
    }
    /**
     * @param url
     * @return
     */
    public static String get(String url) {
        HttpGet httpGet = new HttpGet(url);
        return getResult(httpGet);
    }
    /**
     * @param url、params
     * @return
     */
    public static String get(String url, Map<String, String > params) throws URISyntaxException {
        URIBuilder ub = new URIBuilder();
        ub.setPath(url);

        ArrayList<NameValuePair> pairs = covertParams2NVPS(params);
        ub.setParameters(pairs);

        HttpGet httpGet = new HttpGet(ub.build());
        return getResult(httpGet);
    }
    /**
     * @param url、headers、params
     * @return
     */
    public static String get(String url, Map<String, Object> headers, Map<String, String> params)
            throws URISyntaxException {
        URIBuilder ub = new URIBuilder();
        ub.setPath(url);

        if (params != null) {
            ArrayList<NameValuePair> pairs = covertParams2NVPS(params);
            ub.setParameters(pairs);
        }

        HttpGet httpGet = new HttpGet(ub.build());
        for (Map.Entry<String, Object> param : headers.entrySet()) {
            httpGet.addHeader(param.getKey(), String.valueOf(param.getValue()));
        }
        return getResult(httpGet);
    }
    /**
     * @param url
     * @return
     */
    public static String post(String url) {
        HttpPost httpPost = new HttpPost(url);
        return getResult(httpPost);
    }
    /**
     * @param url、params
     * @return
     */
    public static String post(String url, Map<String, String> params) throws UnsupportedEncodingException {
        HttpPost httpPost = new HttpPost(url);
        httpPost.setEntity(new UrlEncodedFormEntity(covertParams2NVPS(params), "utf-8"));//设置表单提交编码

//        httpPost.setEntity(new StringEntity(JSON.toJSONString(params), ContentType.APPLICATION_FORM_URLENCODED));
        return getResult(httpPost);
    }
    /**
     * @param url、headers、params
     * @return
     */
    public static String post(String url, Map<String, Object> headers, Map<String, String> params)
            throws UnsupportedEncodingException {
        HttpPost httpPost = new HttpPost(url);

        if (params != null) {
            for (Map.Entry<String, Object> param : headers.entrySet()) {
                httpPost.addHeader(param.getKey(), String.valueOf(param.getValue()));
            }
        }

        httpPost.setEntity(new StringEntity(JSON.toJSONString(params), ContentType.APPLICATION_JSON));

        return getResult(httpPost);
    }
    /**
     * @param method、url
     * @return
     */
    public static String request(String method, String url)
            throws UnsupportedEncodingException {

        RequestBuilder requestBuilder = RequestBuilder.create(method);
        requestBuilder.setUri(url);
        return getResult(requestBuilder);
    }
    /**
     * @param method、url、params
     * @return
     */
    public static String request(String method, String url, Map<String, Object> params)
            throws UnsupportedEncodingException {

        RequestBuilder requestBuilder = RequestBuilder.create(method);
        requestBuilder.setUri(url);

        EntityBuilder entityBuilder = EntityBuilder.create();
        entityBuilder.setContentEncoding(UTF_8);
        entityBuilder.setText(JSON.toJSONString(params));
        entityBuilder.setContentType(ContentType.APPLICATION_FORM_URLENCODED);

        requestBuilder.setEntity(entityBuilder.build());

        return getResult(requestBuilder);
    }
    /**
     * @param method、url、headers、params
     * @return
     */
    public static String request(String method, String url, Map<String, Object> headers, Map<String, String> params)
            throws UnsupportedEncodingException {

        RequestBuilder requestBuilder = RequestBuilder.create(method);
        requestBuilder.setUri(url);

        for (Map.Entry<String, Object> param : headers.entrySet()) {
            requestBuilder.addHeader(param.getKey(), String.valueOf(param.getValue()));
        }

        EntityBuilder entityBuilder = EntityBuilder.create();
        entityBuilder.setContentEncoding(UTF_8);
        entityBuilder.setText(JSON.toJSONString(params));
        entityBuilder.setContentType(ContentType.APPLICATION_JSON);

        requestBuilder.setEntity(entityBuilder.build());

        return getResult(requestBuilder);
    }
    /**
     * @param url、file、fileName
     * @return
     */
    public static String uploadFile(String url, byte[] file, String fileName) {

        HttpPost httpPost = new HttpPost(url);
        httpPost.setHeader("Accept-Encoding", "gzip");
        httpPost.setHeader("charset", "utf-8");

        MultipartEntityBuilder multipartEntityBuilder = MultipartEntityBuilder.create();
        multipartEntityBuilder.setMode(HttpMultipartMode.BROWSER_COMPATIBLE);
        multipartEntityBuilder.setCharset(Charset.forName(UTF_8));
        multipartEntityBuilder.addBinaryBody("file", file, ContentType.MULTIPART_FORM_DATA, fileName);

        httpPost.setEntity(multipartEntityBuilder.build());

        return getResult(httpPost);
    }

    private static ArrayList<NameValuePair> covertParams2NVPS(Map<String, String> params) {
        ArrayList<NameValuePair> pairs = new ArrayList<NameValuePair>();
        for (Map.Entry<String, String> param : params.entrySet()) {
            if (param.getValue() != null) {
                pairs.add(new BasicNameValuePair(param.getKey(), param.getValue()));
            }
        }

        return pairs;
    }

    /**
     * 处理Http请求
     *
     * @param request
     * @return
     */
    private static String getResult(HttpRequestBase request) {
        // CloseableHttpClient httpClient = HttpClients.createDefault();
        CloseableHttpClient httpClient = getHttpClient();
        try {
            CloseableHttpResponse response = httpClient.execute(request);
            // response.getStatusLine().getStatusCode();
            HttpEntity entity = response.getEntity();
            if (entity != null) {
                // long len = entity.getContentLength();// -1 表示长度未知
                String result = EntityUtils.toString(entity, UTF_8);
                response.close();
                // httpClient.close();
                return result;
            }
        } catch (ClientProtocolException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {

        }

        return EMPTY_STR;
    }

    /**
     * 处理Http请求
     *
     * @param requestBuilder
     * @return
     */
    private static String getResult(RequestBuilder requestBuilder) {
        // CloseableHttpClient httpClient = HttpClients.createDefault();
        CloseableHttpClient httpClient = getHttpClient();
        try {
            CloseableHttpResponse response = httpClient.execute(requestBuilder.build());
            // response.getStatusLine().getStatusCode();
            HttpEntity entity = response.getEntity();
            if (entity != null) {
                // long len = entity.getContentLength();// -1 表示长度未知
                String result = EntityUtils.toString(entity, UTF_8);
                response.close();
                // httpClient.close();
                return result;
            }
        } catch (ClientProtocolException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {

        }

        return EMPTY_STR;
    }

    public static ApiResult toApiRequest(String resultStr) {
        return JSONObject.parseObject(resultStr, ApiResult.class);
    }
}

HttpClientUtils .java中涉及的自己封装的结果返回类，ApiResult.java

public class ApiResult<T> {
    public Integer code;
    public String msg;
    public T data;

    public ApiResult success(){
        this.code = ResultCode.SUCCESS.getCode();
        this.msg = ResultCode.SUCCESS.getDesc();
        return this;
    }

    public ApiResult success(T data){
        this.code = ResultCode.SUCCESS.getCode();
        this.msg = ResultCode.SUCCESS.getDesc();
        this.data = data;
        return this;
    }

    public ApiResult failure(){
        this.code = ResultCode.ERROR.getCode();
        this.msg = ResultCode.ERROR.getDesc();
        return this;
    }

    public ApiResult failure(T data){
        this.code = ResultCode.ERROR.getCode();
        this.msg = ResultCode.ERROR.getDesc();
        this.data = data;
        return this;
    }

    public Integer getCode() {
        return code;
    }

    public void setCode(Integer code) {
        this.code = code;
    }

    public String getMsg() {
        return msg;
    }

    public void setMsg(String msg) {
        this.msg = msg;
    }

    public T getData() {
        return data;
    }

    public void setData(T data) {
        this.data = data;
    }
}

ApiResult.java中涉及的ResultCode.java

public enum ResultCode {
    SUCCESS(200, "success"), // 正确请求
    ERROR(500, "failure"); // 请求错误

    /** 主键 */
    private final Integer code;

    /** 描述 */
    private final String desc;

    ResultCode(final Integer code, final String desc) {
        this.code = code;
        this.desc = desc;
    }

    public Integer getCode() {
        return this.code;
    }

    public String getDesc() {
        return this.desc;
    }
}

在该工具类中涉及的依赖：
Gradle

compile "org.apache.httpcomponents:httpcore"
compile "org.apache.httpcomponents:httpclient"
compile "org.apache.httpcomponents:httpmime"
compile "com.alibaba:fastjson:1.2.34"

Maven

<dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.33</version>
        </dependency>
        <dependency>
            <groupId>org.apache.httpcomponents</groupId>
            <artifactId>httpcore</artifactId>
            <version>4.4.5</version>
        </dependency>
        <dependency>
            <groupId>org.apache.httpcomponents</groupId>
            <artifactId>httpclient</artifactId>
            <version>4.5.2</version>
        </dependency>
        <dependency>
            <groupId>org.apache.httpcomponents</groupId>
            <artifactId>httpmime</artifactId>
            <version>4.4</version>
</dependency>

不完善的地方希望大家提建议，谢谢；

文章标签：
Java
fastjson
Maven
关键词：
HTTPS请求
Java http
HTTPS Java
Java请求
Java工具类
luckcheng
目录
相关文章
苍何
|
1天前
|
前端开发 Java
java在过滤器中为http请求加请求头header
现在有一个需求场景是，每一个请求我都需要在请求头里面加上token这个请求头，作为一种校验机制，传统的接口可以通过设置一个全局的变量，然后通过页面携带过来（大概就是先将我们的token放在session中，写一个服务用来获取session中的token，然后主页面用ajax调用接口，将token放在隐藏域中，然后将请求头放进来，用ajax方法，这里不想洗说了），但是有一种情况是通过页面传递的并不一定都会适用所有接口，比如上传和下载的接口有时候头里面就没有token参数，可能是上传和下载是用表单提交的 这个时候如何将请求头通过后台的方法加进来？ 想到用过滤器，用后台方法强制加入请求头。
苍何
9 0
游客slk27ouxhrsjy
|
1月前
|
SQL Java 数据处理
Java中的HttpServletRequest：解析与处理HTTP请求
在现代的Java Web应用开发中，与客户端的数据交互是至关重要的一部分。Spring框架中的`HttpServletRequest`对象为我们提供了处理和解析HTTP请求的能力。本文将引导您深入了解`HttpServletRequest`对象，探讨其特点、用法、实现方式以及在实际应用中的优势。
游客slk27ouxhrsjy
73 0
游客slk27ouxhrsjy
|
1月前
|
JSON 自然语言处理 Java
Java中的HttpServletResponse：构建定制化的HTTP响应
在现代的Java Web应用开发中，与客户端的数据交互不仅限于请求，同样重要的是如何构建并发送适当的HTTP响应。在Spring框架中，`HttpServletResponse` 对象为我们提供了处理和定制HTTP响应的能力。本文将引导您深入了解`HttpServletResponse`对象，探讨其特点、用法、实现方式以及在实际应用中的优势。
游客slk27ouxhrsjy
33 0
beloved000
|
1月前
|
Java
Java HTTP请求 如何获取并解析返回的HTML内容
在Java开发中，经常会遇到需要获取网页内容的情况。而HTTP请求是实现这一目标的常用方法之一。本文将介绍如何使用Java进行HTTP请求，并解析返回的HTML内容。
beloved000
99 0
beloved000
|
1月前
|
Java API Apache
Java HTTP请求封装的方法及实现
在Java开发中，我们经常需要与服务器进行数据交互，发送HTTP请求是其中常见的一种方式。为了简化开发过程，我们可以封装HTTP请求的方法，让调用者只需要关注业务逻辑而不用关心底层的细节实现。本文将介绍一种基于Java的HTTP请求封装方法及其实现。
beloved000
91 2
beloved000
|
1月前
|
Java
Java HTTP多线程下载实现方法
在如今互联网高速发展的时代，对于下载来说，速度是一个非常重要的因素。而多线程下载是一种提高下载速度的常见方法。本文将介绍如何使用Java编程实现HTTP多线程下载功能。
beloved000
39 0
TiAmoZhang
|
1月前
|
Java
Java Web应用开发案例｜用过滤器解决HTTP请求导致的乱码问题
在Web应用开发中经常会遇到乱码问题，使用过滤器解决HTTP 请求导致的乱码问题，是十分有效的解决方案。
TiAmoZhang
49 0
Java Web应用开发案例｜用过滤器解决HTTP请求导致的乱码问题
暗武逢天
|
2月前
|
Java
JAVA Http的Post请求传参
JAVA Http的Post请求传参
暗武逢天
66 0
时间不会赖着不走
|
3月前
|
缓存 Java
Java中HTTP响应状态码
Java中HTTP响应状态码
时间不会赖着不走
51 0
我要好好学java
|
3月前
|
JSON 网络协议 Java
java发送Http请求
java发送Http请求
我要好好学java
128 0
热门文章
最新文章
1
Java上进了，JDK21 要来了，并发编程再也不是噩梦了
2
Java 应用程序在 Kubernetes 上棘手的内存管理(上)
3
无意中发现阿里巴巴Java开发手册「2023最新黄山版」竟然发布了
4
Java处理并发编程工具集合(JUC)详解2
5
Java处理并发编程工具集合(JUC)详解 1
6
2023最全Java面试题及答案汇总
7
面渣逆袭：Java并发六十问，你会多少道？
8
零拷贝技术在Java中为何这么牛？
9
Java 应用程序在 Kubernetes 上棘手的内存管理（下）
10
Java并发编程：探索多线程和同步
1
如何让 ABAP 服务器能够响应通过浏览器发起的自定义 HTTP 请求的试读版
12
2
关于 HTTP post 请求 form data 里的特殊符号，比如加号 plus symbol
13
3
Angular 如何通过 HTTP Interceptor 实现 HTTP 请求的超时监控
12
4
java在过滤器中为http请求加请求头header
9
5
使用 RxJS timeout 操作符给 Angular SSR 服务器端渲染模式下的 HTTP 请求添加超时机制
9
6
socks5代理是什么意思？它跟http代理有什么不同点？它有什么应用场景？
61
7
iOS HTTPS 介绍
7
8
js - HTTP
9
9
【Web安全】不安全的HTTP方法
17
10
http代理价格监控和分布式价格监控有什么不同处？
37
相关产品
云迁移中心
文档详情 产品详情
相关课程
更多
Java编程入门 Java面向对象编程 Java高级编程 Java面试疑难点解析 - 面试技巧及语言基础 Java面试疑难点解析 - Java Web开发 Java面试疑难点解析 - 系统架构及项目设计
相关电子书
更多
Spring Cloud Alibaba - 重新定义 Java Cloud-Native The Reactive Cloud Native Arch JAVA开发手册1.5.0
相关实验场景
更多
阿里云平台上进行Java程序的编译与运行 使用Java面向对象编写网络通信程序应用 Elasticsearch Java API Client 开发 手动部署Java Web环境（Alibaba Cloud Linux 2） 搭建Java Web开发环境（Anolis OS） RocketMQ中使用Java客户端发送消息和消费的应用
推荐文章
更多
重磅来袭！参与评测赢Iphone14 pro！ 文件存储NAS评测征集令！ 招募！寻找技术人的伯乐！ 乘风者计划邀您入驻社区，精彩权益即刻享
下一篇
部署并使用Docker（CentOS 8）