HttpUtil 网络请求工具类java
工具类
1、pom添加maven依赖
<dependency>
<groupId>cn.hutool</groupId>
<artifactId>hutool-all</artifactId>
</dependency>
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpmime</artifactId>
</dependency>
2、工具类
import cn.hutool.core.map.MapUtil;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
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.HttpPost;
import org.apache.http.client.methods.HttpUriRequest;
import org.apache.http.client.methods.RequestBuilder;
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.HttpClientBuilder;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.protocol.HTTP;
import org.apache.http.util.EntityUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.web.multipart.MultipartFile;
import java.io.IOException;
import java.nio.charset.Charset;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
/**
* http请求工具类
*
* @author wangfenglei
*/
public class HttpUtil {
private static Logger log = LoggerFactory.getLogger(HttpUtil.class);
private static PoolingHttpClientConnectionManager connectionManager = null;
private static HttpClientBuilder httpBuilder = null;
private static RequestConfig requestConfig = null;
/**
* 最大连接连接数量
*/
private static int MAX_CONNECTION = 100;
/**
* 最大并发请求数量
*/
private static int DEFAULT_MAX_CONNECTION = 50;
static {
// 设置http的状态参数
requestConfig = RequestConfig.custom().setSocketTimeout(10000).setConnectTimeout(10000)
.setConnectionRequestTimeout(10000).build();
connectionManager = new PoolingHttpClientConnectionManager();
connectionManager.setMaxTotal(MAX_CONNECTION);
connectionManager.setDefaultMaxPerRoute(DEFAULT_MAX_CONNECTION);
httpBuilder = HttpClients.custom();
httpBuilder.setConnectionManager(connectionManager);
}
/**
* 获取http客户端连接
*
* @return http客户端连接
*/
public static CloseableHttpClient getConnection() {
return httpBuilder.build();
}
/**
* http post请求,利用http请求池
*
* @param url 请求url
* @param paramsMap 请求参数
* @return 请求结果
* @throws Exception 异常
*/
public static String httpPost(String url, Map<String, String> paramsMap) throws Exception {
List<NameValuePair> params = new ArrayList<>();
for (Map.Entry<String, String> e : paramsMap.entrySet()) {
NameValuePair pair = new BasicNameValuePair(e.getKey(), e.getValue());
params.add(pair);
}
HttpUriRequest postMethod = RequestBuilder.post().setUri(url)
.addParameters(params.toArray(new BasicNameValuePair[params.size()])).setConfig(requestConfig).build();
HttpResponse response = getConnection().execute(postMethod);
return EntityUtils.toString(response.getEntity());
}
/**
* http post请求,利用http请求池
*
* @param url 请求url
* @param paramsMap 请求参数
* @param urlParams url请求参数
* @return 请求结果
* @throws Exception 异常
*/
public static String httpPost(String url, Map<String, String> paramsMap, Map<String, Object> urlParams) throws Exception {
List<NameValuePair> params = new ArrayList<>();
for (Map.Entry<String, String> e : paramsMap.entrySet()) {
NameValuePair pair = new BasicNameValuePair(e.getKey(), e.getValue());
params.add(pair);
}
StringBuilder sb = new StringBuilder("?");
for (Map.Entry<String, Object> e : urlParams.entrySet()) {
sb.append(e.getKey()).append("=").append(e.getValue()).append("&");
}
if (urlParams!= null&&urlParams.size()!=0){
url = url sb.toString();
}
HttpUriRequest postMethod = RequestBuilder.post().setUri(url)
.addParameters(params.toArray(new BasicNameValuePair[params.size()])).setConfig(requestConfig).build();
HttpResponse response = getConnection().execute(postMethod);
return EntityUtils.toString(response.getEntity());
}
/**
* http post请求,利用http请求池
*
* @param url 请求url
* @param jsonStr json字符串
* @return 请求结果
* @throws Exception 异常
*/
public static String httpPostJson(String url, String jsonStr) throws Exception {
HttpUriRequest postMethod = RequestBuilder.post().setUri(url)
.setHeader("Content-Type", "application/json;charset=utf-8").setHeader("Accept", "application/json")
.setEntity(new StringEntity(jsonStr, Charset.forName("UTF-8"))).setConfig(requestConfig).build();
HttpResponse response = getConnection().execute(postMethod);
return EntityUtils.toString(response.getEntity());
}
/**
* http post请求,利用http请求池,设置head内容
*
* @param url 请求url
* @param jsonStr json字符串
* @param head head内容
* @return 请求结果
* @throws Exception 异常
*/
public static String httpPostJson(String url, String jsonStr, Map<String, String> head) throws Exception {
if (MapUtil.isNotEmpty(head)) {
RequestBuilder requestBuilder = RequestBuilder.post().setUri(url)
.setHeader("Content-Type", "application/json;charset=utf-8")
.setHeader("Accept", "application/json");
for (Map.Entry<String, String> entry : head.entrySet()) {
requestBuilder.setHeader(entry.getKey(), entry.getValue());
}
HttpUriRequest postMethod = requestBuilder.setEntity(new StringEntity(jsonStr, Charset.forName("UTF-8")))
.setConfig(requestConfig).build();
HttpResponse response = getConnection().execute(postMethod);
return EntityUtils.toString(response.getEntity());
} else {
return httpPostJson(url, jsonStr);
}
}
/**
* http post请求,利用http请求池,设置head内容
*
* @param url 请求url
* @param jsonStr json字符串
* @param head head内容
* @return 请求结果
* @throws Exception 异常
*/
public static String httpPostJson(String url, String jsonStr, Map<String, String> head, Map<String, Object> urlParams) throws Exception {
if (MapUtil.isNotEmpty(head)) {
StringBuilder sb = new StringBuilder("?");
for (Map.Entry<String, Object> e : urlParams.entrySet()) {
sb.append(e.getKey()).append("=").append(e.getValue()).append("&");
}
if (urlParams!= null&&urlParams.size()!=0){
url = url sb.toString();
}
RequestBuilder requestBuilder = RequestBuilder.post().setUri(url)
.setHeader("Content-Type", "application/json;charset=utf-8")
.setHeader("Accept", "application/json");
for (Map.Entry<String, String> entry : head.entrySet()) {
requestBuilder.setHeader(entry.getKey(), entry.getValue());
}
HttpUriRequest postMethod = requestBuilder.setEntity(new StringEntity(jsonStr, Charset.forName("UTF-8")))
.setConfig(requestConfig).build();
HttpResponse response = getConnection().execute(postMethod);
return EntityUtils.toString(response.getEntity());
} else {
return httpPostJson(url, jsonStr);
}
}
/**
* http get请求,利用http请求池
*
* @param url 请求url
* @return 请求结果
* @throws Exception 异常
*/
public static String httpGet(String url) throws Exception {
HttpUriRequest getMethod = RequestBuilder.get().setUri(url).setConfig(requestConfig).build();
HttpResponse response = getConnection().execute(getMethod);
return EntityUtils.toString(response.getEntity());
}
/**
* http get请求,利用http请求池
*
* @param url 请求url
* @param paramsMap 请求参数
* @return 请求结果
* @throws Exception 异常
*/
public static String httpGet(String url, Map<String, String> paramsMap) throws Exception {
List<NameValuePair> params = new ArrayList<>();
for (Map.Entry<String, String> e : paramsMap.entrySet()) {
NameValuePair pair = new BasicNameValuePair(e.getKey(), e.getValue());
params.add(pair);
}
HttpUriRequest getMethod = RequestBuilder.get().setUri(url)
.addParameters(params.toArray(new BasicNameValuePair[params.size()])).setConfig(requestConfig).build();
HttpResponse response = getConnection().execute(getMethod);
return EntityUtils.toString(response.getEntity());
}
/**
* http get请求,利用http请求池 设置head内容
*
* @param url 请求url
* @param paramsMap 请求参数
* @param head head内容
* @return 请求结果
* @throws Exception 异常
*/
public static String httpGet(String url, Map<String, String> paramsMap, Map<String, String> head) throws Exception {
List<NameValuePair> params = new ArrayList<>();
for (Map.Entry<String, String> e : paramsMap.entrySet()) {
NameValuePair pair = new BasicNameValuePair(e.getKey(), e.getValue());
params.add(pair);
}
RequestBuilder requestBuilder = RequestBuilder.get().setUri(url);
for (Map.Entry<String, String> entry : head.entrySet()) {
requestBuilder.setHeader(entry.getKey(), entry.getValue());
}
HttpUriRequest getMethod = requestBuilder.addParameters(params.toArray(new BasicNameValuePair[params.size()]))
.setConfig(requestConfig).build();
HttpResponse response = getConnection().execute(getMethod);
return EntityUtils.toString(response.getEntity());
}
/**
* http post 请求,每次创建请求客户端
*
* @param url url
* @param params 请求参数
* @return 请求返回值
*/
public static String httpPostNoPool(String url, Map<String, String> params) {
CloseableHttpClient closeableHttpClient = null;
try {
HttpPost httpPost = new HttpPost(url);
if (params != null) {
List<NameValuePair> form = new ArrayList<>();
for (String name : params.keySet()) {
form.add(new BasicNameValuePair(name, params.get(name)));
}
httpPost.setEntity(new UrlEncodedFormEntity(form, HTTP.UTF_8));
}
closeableHttpClient = HttpClients.createDefault();
CloseableHttpResponse httpResponse = closeableHttpClient.execute(httpPost);
HttpEntity entry = httpResponse.getEntity();
return EntityUtils.toString(entry);
} catch (Exception e) {
log.error("HttpUtil.httpPost failed!", e);
} finally {
if (null != closeableHttpClient) {
try {
closeableHttpClient.close();
} catch (IOException e) {
log.error("closeableHttpClient.close failed!", e);
}
}
}
return null;
}
/**
* 使用httpclint 发送文件
*
* @param file 上传的文件
* @return 响应结果
*/
public static String uploadFile(String url, MultipartFile file, String fileParamName,
Map<String, String> headerParams, Map<String, String> otherParams) {
CloseableHttpClient closeableHttpClient = null;
String result = "";
try {
String fileName = file.getOriginalFilename();
HttpPost httpPost = new HttpPost(url);
// 添加header
for (Map.Entry<String, String> e : headerParams.entrySet()) {
httpPost.addHeader(e.getKey(), e.getValue());
}
MultipartEntityBuilder builder = MultipartEntityBuilder.create();
builder.setCharset(Charset.forName("utf-8"));
builder.setMode(HttpMultipartMode.BROWSER_COMPATIBLE);// 加上此行代码解决返回中文乱码问题
builder.addBinaryBody(fileParamName, file.getInputStream(), ContentType.MULTIPART_FORM_DATA, fileName);// 文件流
for (Map.Entry<String, String> e : otherParams.entrySet()) {
builder.addTextBody(e.getKey(), e.getValue());// 类似浏览器表单提交,对应input的name和value
}
HttpEntity entity = builder.build();
httpPost.setEntity(entity);
closeableHttpClient = HttpClients.createDefault();
HttpResponse response = closeableHttpClient.execute(httpPost);// 执行提交
HttpEntity responseEntity = response.getEntity();
if (responseEntity != null) {
// 将响应内容转换为字符串
result = EntityUtils.toString(responseEntity, Charset.forName("UTF-8"));
}
} catch (IOException e) {
e.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
} finally {
if (null != closeableHttpClient) {
try {
closeableHttpClient.close();
} catch (IOException e) {
log.error("closeableHttpClient.close failed!", e);
}
}
}
return result;
}
}
3、调用
Map<String, String> paramsMap = new HashMap<>();
paramsMap.put("limit", "100");
Map<String, String> head = new HashMap<>();
head.put("Access-Token", hwyToken);
String result = HttpUtil.httpGet(url, paramsMap, head);
JSONObject jsonObject = JSONUtil.parseObj(result);
String result = HttpUtil.httpPost(url, new HashMap<>(), paramsMap);
JSONObject jsonObject = JSONUtil.parseObj(result);
Map<String, Object> paramsMap = new HashMap<>();
paramsMap.put("accessToken", ysyToken);
paramsMap.put("deviceSerial", deviceId);
String result = HttpUtil.httpPost(url, new HashMap<>(), paramsMap);
JSONObject jsonObject = JSONUtil.parseObj(result);
这篇好文章是转载于:学新通技术网
- 版权申明: 本站部分内容来自互联网,仅供学习及演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系,请提供相关证据及您的身份证明,我们将在收到邮件后48小时内删除。
- 本站站名: 学新通技术网
- 本文地址: /boutique/detail/tanhihcibf
系列文章
更多
同类精品
更多
-
photoshop保存的图片太大微信发不了怎么办
PHP中文网 06-15 -
photoshop扩展功能面板显示灰色怎么办
PHP中文网 06-14 -
word里面弄一个表格后上面的标题会跑到下面怎么办
PHP中文网 06-20 -
《学习通》视频自动暂停处理方法
HelloWorld317 07-05 -
TikTok加速器哪个好免费的TK加速器推荐
TK小达人 10-01 -
Android 11 保存文件到外部存储,并分享文件
Luke 10-12 -
excel下划线不显示怎么办
PHP中文网 06-23 -
微信公众号没有声音提示怎么办
PHP中文网 03-31 -
excel图片置于文字下方的方法
PHP中文网 06-27 -
微信运动停用后别人还能看到步数吗
PHP中文网 07-22