java http请求工具类全功能(get、put、delete、post、文件上传)，使用easy-okhttp

大家好，我是酷酷的韩~

1.简介

本文提供的是java http请求工具类,使用easy-okhttp封装，包含各种方法，含部分测试demo，有疑问可在公屏讨论。

2.为什么使用easy-okhttp

easy-okhttp是对OkHttp网络框架封装，提供文件上传和下载，表单(含文件)提交，链式调用，支持HTTPS和自定义签名证书等特性。 OkHttp网络框架的流行始于Android，但是在Java后端仍然是Apache HttpClient网络框架，这个框架功能非常强大，但缺点在于设计非常的复杂且jar的比较大。所以才有easy-okhttp

3.pom依赖

<dependency><groupId>com.mzlion</groupId><artifactId>easy-okhttp</artifactId><version>1.1.4</version>
</dependency>

4.工具类代码

package com.hjq.demo.common.utils;import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.serializer.SerializerFeature;
import com.hjq.demo.common.json.AjaxJson;
import com.mzlion.easyokhttp.HttpClient;
import com.mzlion.easyokhttp.request.GetRequest;
import com.mzlion.easyokhttp.request.PostRequest;
import com.mzlion.easyokhttp.request.TextBodyRequest;
import com.mzlion.easyokhttp.response.callback.Callback;
import com.mzlion.easyokhttp.response.handle.DataHandler;
import okhttp3.Headers;
import okhttp3.MediaType;
import okhttp3.MultipartBody;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.RequestBody;
import okhttp3.Response;
import org.apache.http.HttpEntity;
import org.apache.http.HttpStatus;
import org.apache.http.NameValuePair;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.*;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.util.EntityUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.util.StringUtils;import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.nio.charset.Charset;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.zip.GZIPInputStream;public class HttpRequestUtils2 {private static Logger logger = LoggerFactory.getLogger(HttpRequestUtils2.class);private static final int DEFAULT_TIMEOUT = 2000;//PUT请求-------------------------------------------------------------------------**/*** @param url        请求的url地址* @param headers    请求头参数map* @param parameters 请求参数map* @return 请求的结果字符串* 发起PUT同步请求*/public static String doPut(String url, Map<String, String> headers, Map<String, String> parameters, String jsonStr) throws UnsupportedEncodingException {CloseableHttpClient httpClient = HttpClientBuilder.create().build();HttpPut httpPut = new HttpPut(url);addParameters(httpPut, parameters, jsonStr);return getResultStr(headers, httpClient, httpPut);}private static void addParameters(HttpEntityEnclosingRequestBase postPutRequest, Map<String, String> parameters, String jsonStr) throws UnsupportedEncodingException, UnsupportedEncodingException {if (!StringUtils.isEmpty(jsonStr)) {postPutRequest.setHeader("Content-Type", "application/json;charset=UTF-8");postPutRequest.setEntity(new StringEntity(jsonStr, Charset.forName("UTF-8")));} else {// 1、构造list集合，往里面存请求的数据List<NameValuePair> list = new ArrayList<>();for (String key : parameters.keySet()) {String value = parameters.get(key);BasicNameValuePair basicNameValuePair = new BasicNameValuePair(key, value);list.add(basicNameValuePair);}//2 我们发现Entity是一个接口，所以只能找实现类，发现实现类又需要一个集合，集合的泛型是NameValuePair类型UrlEncodedFormEntity formEntity = new UrlEncodedFormEntity(list);//3 通过setEntity 将我们的entity对象传递过去postPutRequest.setEntity(formEntity);}}private static String getResultStr(Map<String, String> headers, CloseableHttpClient httpClient, HttpRequestBase httpRequest) {String body = null;CloseableHttpResponse response;//设置请求头的参数setHeaders(headers, httpRequest);try {//执行请求response = httpClient.execute(httpRequest);//请求成功执行if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {//获取返回的数据HttpEntity entity = response.getEntity();//转换成字符串body = EntityUtils.toString(entity);}} catch (IOException e) {e.printStackTrace();}return body;}private static void setHeaders(Map<String, String> headers, HttpRequestBase httpRequest) {if (headers != null && !headers.isEmpty()) {for (String key : headers.keySet()) {String value = headers.get(key);httpRequest.setHeader(key, value);}}}//DELETE请求-------------------------------------------------------------------------**/*** @author Binean* @Description 发送delete请求*/public static String doDelete(String url, Map<String, String> headers, String encode) {if (encode == null) {encode = "utf-8";}String content = null;CloseableHttpClient closeableHttpClient = HttpClientBuilder.create().build();HttpDelete httpdelete = new HttpDelete(url);//设置headerif (headers != null && headers.size() > 0) {for (Map.Entry<String, String> entry : headers.entrySet()) {httpdelete.setHeader(entry.getKey(), entry.getValue());}}CloseableHttpResponse httpResponse = null;try {httpResponse = closeableHttpClient.execute(httpdelete);HttpEntity entity = httpResponse.getEntity();content = EntityUtils.toString(entity, encode);} catch (Exception e) {e.printStackTrace();} finally {try {httpResponse.close();} catch (IOException e) {e.printStackTrace();}}try {   //关闭连接、释放资源closeableHttpClient.close();} catch (IOException e) {e.printStackTrace();}return content;}//各种GET请求-------------------------------------------------------------------------**public static <T> T doGet(String url, Map<String, String> paramMap, Map<String, String> headMap, Class<T> clz) {try {GetRequest request = HttpClient.get(url);if (paramMap != null && !paramMap.isEmpty()) {request = request.queryString(paramMap);}if (headMap != null && !headMap.isEmpty()) {for (Entry<String, String> item : headMap.entrySet()) {request = request.header(item.getKey(), item.getValue());}}request.header("Connection", "close");T result = null;if (clz.equals(String.class)) {result = (T) request.execute().asString();} else {result = request.execute().asBean(clz);}return result;} catch (Exception e) {logger.error(e.getMessage());return null;}}public static <T> T doGet(String url, Map<String, String> paramMap, Map<String, String> headMap, Class<T> clz,Integer timeout) {try {if (timeout == null) {timeout = DEFAULT_TIMEOUT;}GetRequest request = HttpClient.get(url).readTimeout(timeout);if (paramMap != null && !paramMap.isEmpty()) {request = request.queryString(paramMap);}if (headMap != null && !headMap.isEmpty()) {for (Entry<String, String> item : headMap.entrySet()) {request = request.header(item.getKey(), item.getValue());}}request.header("Connection", "close");T result = null;if (clz.equals(String.class)) {result = (T) request.execute().asString();} else {result = request.execute().asBean(clz);}return result;} catch (Exception e) {logger.error(e.getMessage());return null;}}public static String doUpzipGet(String url, Map<String, String> paramMap, Map<String, String> headMap,Integer timeout) {try {if (timeout == null) {timeout = DEFAULT_TIMEOUT;}GetRequest request = HttpClient.get(url).readTimeout(timeout);if (paramMap != null && !paramMap.isEmpty()) {request = request.queryString(paramMap);}if (headMap != null && !headMap.isEmpty()) {for (Entry<String, String> item : headMap.entrySet()) {request = request.header(item.getKey(), item.getValue());}}request.header("Connection", "close");String result = null;result = request.execute().custom(new DataHandler<String>() {@Overridepublic String handle(Response response) throws IOException {// TODO Auto-generated method stubString rs = null;GZIPInputStream gis = null;ByteArrayOutputStream baos = null;try {if ("gzip".equals(response.header("Content-Encoding"))) {byte[] buffer = new byte[4096];int size = 0;baos = new ByteArrayOutputStream();gis = new GZIPInputStream(response.body().byteStream());while ((size = gis.read(buffer)) != -1) {baos.write(buffer, 0, size);}Charset cs = java.nio.charset.Charset.forName("UTF-8");rs = new String(baos.toByteArray(), cs);} else {rs = response.body().string();}} catch (Exception e) {e.printStackTrace();}if (gis != null) {gis.close();}if (baos != null) {baos.close();}return rs;}});return result;} catch (Exception e) {logger.error(e.getMessage());return null;}}public static String doGet(String url, Map<String, String> paramMap) {try {return doGet(url, paramMap, null, String.class);} catch (Exception e) {logger.error(e.getMessage());return null;}}public static <T> void doAsyncGet(String url, Map<String, String> paramMap, Map<String, String> headMap,Callback<T> callback) {try {GetRequest request = HttpClient.get(url);if (paramMap != null && !paramMap.isEmpty()) {request = request.queryString(paramMap);}if (headMap != null && !headMap.isEmpty()) {for (Entry<String, String> item : headMap.entrySet()) {request = request.header(item.getKey(), item.getValue());}}request.header("Connection", "close");request.execute(callback);} catch (Exception e) {logger.error(e.getMessage());}}public static String doGet(String url, Map<String, String> paramMap, Integer timeout) {try {return doGet(url, paramMap, null, String.class, timeout);} catch (Exception e) {logger.error(e.getMessage());return null;}}public static <T> T doGet(String url, Map<String, String> paramMap, Class<T> clz) {return doGet(url, paramMap, null, clz);}//各种POST请求-------------------------------------------------------------------------**public static <T> void doAsyncPost(String url, Map<String, String> paramMap, Map<String, String> headMap,Callback<T> callback) {try {PostRequest request = HttpClient.post(url);if (paramMap != null && !paramMap.isEmpty()) {request = request.param(paramMap);}if (headMap != null && !headMap.isEmpty()) {for (Entry<String, String> item : headMap.entrySet()) {request = request.header(item.getKey(), item.getValue());}}request.header("Connection", "close");request.execute(callback);} catch (Exception e) {logger.error(e.getMessage());}}public static <T> T doPost(String url, Map<String, String> paramMap, Map<String, String> headMap, Class<T> clz) {try {PostRequest request = HttpClient.post(url);if (paramMap != null && !paramMap.isEmpty()) {request = request.param(paramMap);}if (headMap != null && !headMap.isEmpty()) {for (Entry<String, String> item : headMap.entrySet()) {request = request.header(item.getKey(), item.getValue());}}request.header("Connection", "close");T result = null;if (clz.equals(String.class)) {result = (T) request.execute().asString();} else {result = request.execute().asBean(clz);}return result;} catch (Exception e) {logger.error(e.getMessage());return null;}}public static <T> T doPost(String url, Map<String, String> paramMap, Map<String, String> headMap, Class<T> clz,Integer timeout) {try {if (timeout == null) {timeout = DEFAULT_TIMEOUT;}PostRequest request = HttpClient.post(url).readTimeout(timeout);if (paramMap != null && !paramMap.isEmpty()) {request = request.param(paramMap);}if (headMap != null && !headMap.isEmpty()) {for (Entry<String, String> item : headMap.entrySet()) {request = request.header(item.getKey(), item.getValue());}}request.header("Connection", "close");T result = null;if (clz.equals(String.class)) {result = (T) request.execute().asString();} else {result = request.execute().asBean(clz);}return result;} catch (Exception e) {logger.error(e.getMessage());return null;}}public static String postWithFiles(String url, String fileName, byte[] content, String mediaType, Map<String, String> headers) {try {Headers httpHeader = Headers.of(headers);OkHttpClient client = new OkHttpClient();RequestBody formBody = new MultipartBody.Builder().setType(MultipartBody.FORM).addFormDataPart("file", fileName, RequestBody.create(MediaType.parse(mediaType), content)).addFormDataPart("other_field", "other_field_value").build();Request request = new Request.Builder().url(url).headers(httpHeader).post(formBody).build();Response response = client.newCall(request).execute();return response.body().string();} catch (Exception e) {logger.error(e.getMessage());return null;}}public static <T> T doPost(String url, Map<String, String> paramMap, Class<T> clz) {return doPost(url, paramMap, null, clz);}public static String doPost(String url, Map<String, String> paramMap) {try {return doPost(url, paramMap, null, String.class);} catch (Exception e) {// e.printStackTrace();logger.error(e.getMessage());return null;}}public static String doPost(String url, Map<String, String> paramMap, Integer timeout) {try {return doPost(url, paramMap, null, String.class, timeout);} catch (Exception e) {// e.printStackTrace();logger.error(e.getMessage());return null;}}public static String doPost(String url, Map<String, String> paramMap, String cookie) {PostRequest request = HttpClient.post(url);if (paramMap != null && !paramMap.isEmpty()) {request = request.param(paramMap);}request.header("Connection", "close");request.header("Cookie", cookie);String result = request.execute().asString();return result;}public static String doPost(String url, Map<String, String> paramMap, Map<String, String> headMap) {return doPost(url, paramMap, headMap, String.class);}public static String doPostJson(String url, String json) {try {String result = HttpClient.textBody(url).json(json).charset("utf-8").execute().asString();return result;} catch (Exception e) {logger.error(e.getMessage());return null;}}public static <T> void doAsyncPostJson(String url, String json, Callback<T> callback) {try {HttpClient.textBody(url).json(json).charset("utf-8").execute(callback);} catch (Exception e) {logger.error(e.getMessage());}}public static String doPostJson(String url, String json, String cookie) {try {TextBodyRequest request = HttpClient.textBody(url).json(json).charset("utf-8");request.header("Cookie", cookie);request.header("Connection", "close");String result = request.execute().asString();return result;} catch (Exception e) {logger.error(e.getMessage());return null;}}public static <T> T doPostJson(String url, String json, String cookie, Class<T> clz) {try {TextBodyRequest request = HttpClient.textBody(url).json(json).charset("utf-8");request.header("Cookie", cookie);request.header("Connection", "close");T result = request.execute().asBean(clz);return result;} catch (Exception e) {logger.error(e.getMessage());return null;}}public static String doPostJson(String url, String json, Map<String, String> headMap, String cookie) {try {TextBodyRequest request = HttpClient.textBody(url).json(json).charset("utf-8");if (cookie != null) {request.header("Cookie", cookie);}request.header("Connection", "close");if (headMap != null && !headMap.isEmpty()) {for (Entry<String, String> item : headMap.entrySet()) {request = request.header(item.getKey(), item.getValue());}}String result = request.execute().asString();return result;} catch (Exception e) {logger.error(e.getMessage());return null;}}public static <T> T doPostJson(String url, String json, String cookie, Class<T> clz, Integer timeout) {try {TextBodyRequest request = HttpClient.textBody(url).json(json).charset("utf-8").readTimeout(timeout);request.header("Cookie", cookie);request.header("Connection", "close");T result = request.execute().asBean(clz);return result;} catch (Exception e) {logger.error(e.getMessage());return null;}}public static <T> T doPostJson(String url, String json, Map<String, String> headMap, Class<T> clz, Integer timeout) {try {if (timeout == null) {timeout = DEFAULT_TIMEOUT;}TextBodyRequest request = HttpClient.textBody(url).json(json).charset("utf-8").readTimeout(timeout);request.header("Connection", "close");if (headMap != null && !headMap.isEmpty()) {for (Entry<String, String> item : headMap.entrySet()) {request = request.header(item.getKey(), item.getValue());}}T result = request.execute().asBean(clz);return result;} catch (Exception e) {logger.error(e.getMessage());return null;}}public static String doPostXml(String url, String xml) {try {String result = HttpClient.textBody(url).xml(xml).charset("utf-8").execute().asString();return result;} catch (Exception e) {logger.error(e.getMessage());return null;}}public static void main(String[] args) {//get请求
//        String url = "test";
//        Map<String, String> paramMap = new HashMap<>();
//        paramMap.put("orgId", "1");
//        Map<String, String> headerMap = new HashMap<>();
//        headerMap.put("accessToken", "AT-633-8c2x1GtKbD-vTVIbtV-YnnLqRpNZfXYx");
//        AjaxJson ajaxJson = doGet(url, paramMap, headerMap, AjaxJson.class, null);
//        System.out.println(JSONObject.toJSONString(ajaxJson));//post请求String url = "test";Map<String, Object> paramMap = new HashMap<>();paramMap.put("orgId", 1425);Map<String, String> headerMap = new HashMap<>();headerMap.put("accessToken", "AT-633-8c2x1GtKbD-vTVIbtV-YnnLqRpNZfXYx");
//        headerMap.put("Content-Type", "application/json;charset=utf-8");String paramJson = JSONObject.toJSONString(paramMap, SerializerFeature.WriteMapNullValue);AjaxJson ajaxJson = doPostJson(url, paramJson, headerMap, AjaxJson.class, null);System.out.println(JSONObject.toJSONString(ajaxJson));}
}

请看我漂亮的坚持。------酷酷的韩~

java http请求工具类全功能(get、put、delete、post、文件上传)，使用easy-okhttp相关推荐

通过Java程序将“/你的名字拼音缩写/input1/shixun1.txt”文件上传到HDFS的“/你的名字拼音缩写/java/input1/”目录下；通过Java程序将HDFS上的“/你的名字拼音
题目: 通过Java程序将"/你的名字拼音缩写/input1/shixun1.txt"文件上传到HDFS的"/你的名字拼音缩写/java/input1/"目录下 ...
Java Https请求工具类
个人技术网站欢迎关注由于微信API接口建议使用Https请求方式而且过不久就废弃http请求方式了所以提供以下Https工具类 public class SSLClient extends D ...
通过xhr实现文件上传功能，使用jQuery实现文件上传功能
目录一.使用xhr实现文件上传功能 1.定义UI结构 2.验证用户是否选择了文件 3.向FormData中追加文件 4.使用xhr发起上传文件的请求 5.监听onreadyStatechange事件 ...
java day62【响应数据和结果视图、 SpringMVC 实现文件上传、 SpringMVC 中的异常处理、 SpringMVC 中的拦截器】...
第1章响应数据和结果视图 1.1返回值分类 1.1.1 字符串 1.1.2 void 1.1.3 ModelAndView 1.2转发和重定向 1.2.1 forward 转发 1.2.2 Redi ...
Java基于nfs-client包实现NFS协议连接linux服务器进行文件上传与下载操作源码
添加依赖 // https://mvnrepository.com/artifact/com.emc.ecs/nfs-clientcompile group: 'com.emc.ecs', name: ...
关于 PHPMailer 邮件发送类的使用心得（含多文件上传）
This is important for send mail PHPMailer 核心文件 class.phpmailer.php class.phpmaileroauth.php class.ph ...
JAVA http请求工具类http-request
前言在我们日常工作中,我们需要经常和第三方接口进行交互通信,很多时候我们都是使用http协议进行交互,java原生自带对http的支持(java.net.*),但是使用起来不太方便,除此之外,用的最 ...
java tailer apache_工具类commons-io的Tailer用来监控文件
一.前言: 使用Commons-io的monitor下的相关类可以处理对文件进行监控,它采用的是观察者模式来实现的 1.可以监控文件夹的创建.删除和修改 2.可以监控文件的创建.删除和修改 3.采用的 ...
Java 常用的工具类—判断Excel版本读取Excel/CSV文件
以下内容均来自实际项目需求,记录下,网上找的读取Excel会出现不少问题,下面代码是经过好多次测试改进的符合现在项目的代码,如有不同要求,请自行修改,代码均只去掉了包名. 注:我们的Excel 第一行 ...
java http请求工具类_java模拟http请求调用远程接口工具类
package ln; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamRea ...

java http请求工具类全功能(get、put、delete、post、文件上传)，使用easy-okhttp

java http请求工具类全功能(get、put、delete、post、文件上传)，使用easy-okhttp

java http请求工具类全功能(get、put、delete、post、文件上传)，使用easy-okhttp相关推荐

最新文章

热门文章