AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

[Java]Http请求的工具类

2017-10-25 6762
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 说明该工具类从网络获取参考，在本人进行工作中，进行了部分修改；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
关键词：
Java http
HTTP请求
Java请求
Java http请求
HTTPS请求
luckcheng
目录
相关文章
艾利克斯冰
|
3月前
|
JSON Java Apache
非常实用的Http应用框架，杜绝Java Http 接口对接繁琐编程
UniHttp 是一个声明式的 HTTP 接口对接框架，帮助开发者快速对接第三方 HTTP 接口。通过 @HttpApi 注解定义接口，使用 @GetHttpInterface 和 @PostHttpInterface 等注解配置请求方法和参数。支持自定义代理逻辑、全局请求参数、错误处理和连接池配置，提高代码的内聚性和可读性。
艾利克斯冰
260 3
小白学大数据
|
5天前
|
API 数据安全/隐私保护
Haskell中的HTTP请求：代理与响应状态检查
Haskell中的HTTP请求：代理与响应状态检查
小白学大数据
24 13
刘大猫.
|
2月前
|
JSON Java 数据格式
java操作http请求针对不同提交方式(application/json和application/x-www-form-urlencoded)
java操作http请求针对不同提交方式(application/json和application/x-www-form-urlencoded)
刘大猫.
107 25
java操作http请求针对不同提交方式(application/json和application/x-www-form-urlencoded)
蓝易云
|
1月前
|
缓存 应用服务中间件 Apache
HTTP 范围Range请求
HTTP范围请求是一种强大的技术，允许客户端请求资源的部分内容，提高了传输效率和用户体验。通过正确配置服务器和实现范围请求，可以在视频流、断点续传下载等场景中发挥重要作用。希望本文提供的详细介绍和示例代码能帮助您更好地理解和应用这一技术。
蓝易云
89 19
蓝易云
|
2月前
|
JSON JavaScript 前端开发
什么是HTTP POST请求？初学者指南与示范
HTTP POST请求是一种常用的HTTP方法，主要用于向服务器发送数据。通过合理设置请求头和请求主体，可以实现数据的可靠传输。无论是在客户端使用JavaScript，还是在服务器端使用Node.js，理解和掌握POST请求的工作原理和应用场景，对于Web开发至关重要。
蓝易云
357 18
senmeng
|
2月前
|
JSON 数据格式
.net HTTP请求类封装
`HttpRequestHelper` 是一个用于简化 HTTP 请求的辅助类，支持发送 GET 和 POST 请求。它使用 `HttpClient` 发起请求，并通过 `Newtonsoft.Json` 处理 JSON 数据。示例展示了如何使用该类发送请求并处理响应。注意事项包括：简单的错误处理、需安装 `Newtonsoft.Json` 依赖，以及建议重用 `HttpClient` 实例以优化性能。
senmeng
89 2
德国都芳最好
|
3月前
|
开发者
HTTP 协议请求方法的发展历程
【10月更文挑战第21天】
德国都芳最好
117 45
蓝易云
|
2月前
|
Web App开发 大数据 应用服务中间件
什么是 HTTP Range请求（范围请求）
HTTP Range 请求是一种非常有用的 HTTP 功能，允许客户端请求资源的特定部分，从而提高传输效率和用户体验。通过合理使用 Range 请求，可以实现断点续传、视频流播放和按需加载等功能。了解并掌握 HTTP Range 请求的工作原理和应用场景，对开发高效的网络应用至关重要。
蓝易云
221 15
蓝易云
|
2月前
|
安全 Java API
java如何请求接口然后终止某个线程
通过本文的介绍，您应该能够理解如何在Java中请求接口并根据返回结果终止某个线程。合理使用标志位或 `interrupt`方法可以确保线程的安全终止，而处理好网络请求中的各种异常情况，可以提高程序的稳定性和可靠性。
蓝易云
60 6
左诗右码
|
2月前
|
数据采集 JSON 测试技术
Grequests，非常 Nice 的 Python 异步 HTTP 请求神器
在Python开发中，处理HTTP请求至关重要。`grequests`库基于`requests`，支持异步请求，通过`gevent`实现并发，提高性能。本文介绍了`grequests`的安装、基本与高级功能，如GET/POST请求、并发控制等，并探讨其在实际项目中的应用。
左诗右码
79 3

热门文章

最新文章

  • 1
    docker pull mysql:8.0.26提示Error response from daemon: Get “https://registry-1.docker.io/v2/“: EOF错误
  • 2
    HTTPS 证书自动化运维：https证书管理系统- 自动化监控
  • 3
    HTTPS 证书自动化运维：使用Certbot来申请https证书实践指南
  • 4
    HTTPS 证书自动化运维：https证书管理系统之自动化签发
  • 5
    HTTPS 证书自动化运维：https证书管理系统-自动化部署
  • 6
    HTTPS 证书自动化运维：HTTPS 证书管理系统之使用指南
  • 7
    HTTPS 证书自动化运维：基础知识与重要性
  • 8
    HTTPS 证书自动化运维：HTTPS 证书管理系统之优势对比
  • 9
    HTTPS 证书自动化运维：展望未来发展趋势
  • 10
    如何配置 Java 环境变量：设置 JAVA_HOME 和 PATH
  • 1
    代理协议解析：如何根据需求选择HTTP、HTTPS或SOCKS5？
    31
  • 2
    Haskell中的HTTP请求：代理与响应状态检查
    24
  • 3
    Introduction to the HTTP and HTTPS Protocol
    62
  • 4
    HTTP 协议浅析
    76
  • 5
    指纹浏览器中HTTP代理IP的重要性及使用原因
    89
  • 6
    合适的HTTP代理IP关键考虑因素与实用建议
    113
  • 7
    探究HTTP动态代理跟隧道代理的显著特点有哪些
    68
  • 8
    解析HTTP代理服务器不稳定致使掉线的关键原因
    62
  • 9
    Web 性能优化｜了解 HTTP 协议后才能理解的预加载
    69
  • 10
    HTTPS与HTTP：区别及安全性对比
    63

    • 相关课程

    更多
  • Java面试疑难点解析 - 面试技巧及语言基础
  • Java面试疑难点解析 - Java Web开发
  • Java面试疑难点解析 - 系统架构及项目设计
  • Java编程入门
  • Java面向对象编程
  • Java高级编程

    • 相关电子书

    更多
  • 阿里巴巴HTTP 2.0实践及无线通信协议的演进之路
  • 如何通过 Serverless 提高 Java 微服务治理效
  • CDN助力企业网站进入HTTPS时代

    • 相关实验场景

    更多
  • 通过轻量消息队列（原MNS）主题HTTP订阅+ARMS实现自定义数据多渠道告警
  • 通过HTTPS加速网关快速部署网站加密
  • 阿里云平台上进行Java程序的编译与运行
  • 使用Java面向对象编写网络通信程序应用
  • 手动部署Java Web环境（Alibaba Cloud Linux 2）
  • 搭建Java Web开发环境（Anolis OS）
    • 下一篇
    PAI Model Gallery 支持云上一键部署 DeepSeek-V3、DeepSeek-R1 系列模型