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

[Java]Http请求的工具类

2017-10-25 6869
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 说明该工具类从网络获取参考，在本人进行工作中，进行了部分修改；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
关键词：
HTTP请求
Java http
HTTPS请求
Java请求
Java http请求
luckcheng
目录
相关文章
null_is_null
|
19天前
|
JSON 监控 API
掌握使用 requests 库发送各种 HTTP 请求和处理 API 响应
本课程全面讲解了使用 Python 的 requests 库进行 API 请求与响应处理，内容涵盖环境搭建、GET 与 POST 请求、参数传递、错误处理、请求头设置及实战项目开发。通过实例教学，学员可掌握基础到高级技巧，并完成天气查询应用等实际项目，适合初学者快速上手网络编程与 API 调用。
null_is_null
299 130
vaelfy7
|
1月前
HTTP协议中请求方式GET 与 POST 什么区别 ?
GET和POST的主要区别在于参数传递方式、安全性和应用场景。GET通过URL传递参数，长度受限且安全性较低，适合获取数据；而POST通过请求体传递参数，安全性更高，适合提交数据。
vaelfy7
343 2
蓝易云
|
3月前
|
JavaScript 前端开发 API
Node.js中发起HTTP请求的五种方式
以上五种方式，尽管只是冰山一角，但已经足以让编写Node.js HTTP请求的你，在连接世界的舞台上演奏出华丽的乐章。从原生的 `http`到现代的 `fetch`，每种方式都有独特的风格和表现力，让你的代码随着项目的节奏自由地舞动。
蓝易云
428 65
蓝易云
|
2月前
|
Go 定位技术
Golang中设置HTTP请求代理的策略
在实际应用中，可能还需要处理代理服务器的连接稳定性、响应时间、以及错误处理等。因此，建议在使用代理时增加适当的错误重试机制，以确保网络请求的健壮性。此外，由于网络编程涉及的细节较多，彻底测试以确认代理配置符合预期的行为也是十分重要的。
蓝易云
140 8
蓝易云
|
2月前
|
缓存
HTTP请求方法、状态码以及消息报文结构详解
返回给客户端的内容。
蓝易云
332 9
小白学大数据
|
1月前
|
JSON JavaScript API
Python模拟HTTP请求实现APP自动签到
Python模拟HTTP请求实现APP自动签到
小白学大数据
173 0
程序员爱钓鱼
|
1月前
|
数据采集 JSON Go
Go语言实战案例：实现HTTP客户端请求并解析响应
本文是 Go 网络与并发实战系列的第 2 篇，详细介绍如何使用 Go 构建 HTTP 客户端，涵盖请求发送、响应解析、错误处理、Header 与 Body 提取等流程，并通过实战代码演示如何并发请求多个 URL，适合希望掌握 Go 网络编程基础的开发者。
程序员爱钓鱼
340 0
蓝易云
|
2月前
|
缓存 JavaScript 前端开发
Vue 3 HTTP请求封装导致响应结果无法在浏览器中获取，尽管实际请求已成功。
通过逐项检查和调试，最终可以定位问题所在，修复后便能正常在浏览器中获取响应结果。
蓝易云
165 0
蓝易云
|
2月前
|
Go
如何在Go语言的HTTP请求中设置使用代理服务器
当使用特定的代理时，在某些情况下可能需要认证信息，认证信息可以在代理URL中提供，格式通常是：
蓝易云
238 0
大数据文摘
|
2月前
|
存储 人工智能 Java
java之通过Http下载文件
本文介绍了使用Java实现通过文件链接下载文件到本地的方法，主要涉及URL、HttpURLConnection及输入输出流的操作。
大数据文摘
176 0

热门文章

最新文章

  • 1
    Java中的Switch表达式：更简洁的多路分支
  • 2
    Java中的Lambda表达式：简洁与功能的结合
  • 3
    Java Stream API：现代数据处理之道
  • 4
    Java记录类型（Record）：简化数据载体类
  • 5
    2025 年 Java 开发者必知的最新技术实操指南全览
  • 6
    Java 转 AI 不用慌！3 周求职打卡表，帮你按天推进、高效拿 offer
  • 7
    Java Stream API：现代数据处理之道
  • 8
    Java中的Lambda表达式：简化代码的利器
  • 9
    从 Java 到 AI：三周求职冲刺打卡，步步为营拿 offer
  • 10
    阿里出手！Java 开发者狂喜！开源 AI Agent 框架 JManus 来了，初次见面就心动～
  • 1
    【python】python指南（三）：使用正则表达式re提取文本中的http链接
    185
  • 2
    Flutter配置Android和IOS允许http访问
    453
  • 3
    HTTP慢速攻击详解
    222
  • 4
    Ueditor——请求后台配置项http错误,上传功能将不能正常使用
    191
  • 5
    代理服务器在HTTP请求中的应用：Ruby实例
    145
  • 6
    深入解析Python `httpx`源码，探索现代HTTP客户端的秘密！
    251
  • 7
    深入解析Python `requests`库源码，揭开HTTP请求的神秘面纱！
    433
  • 8
    HttpClient在ASP.NET Core中的最佳实践：实现高效的HTTP请求
    276
  • 9
    Nginx七层（应用层）反向代理：HTTP反向代理proxy_pass篇（三）
    216
  • 10
    Nginx七层（应用层）反向代理：HTTP反向代理proxy_pass篇（二）
    605

    • 相关课程

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

    • 相关电子书

    更多
  • Spring Cloud Alibaba - 重新定义 Java Cloud-Native
  • The Reactive Cloud Native Arch
  • JAVA开发手册1.5.0
    • 下一篇
    2025云栖大会，阿里云百炼邀请您的参与和见证