|
|
@@ -0,0 +1,246 @@
|
|
|
+package org.jeecg.modules.system.util;
|
|
|
+
|
|
|
+import com.alibaba.fastjson.JSONObject;
|
|
|
+import org.apache.commons.lang.StringUtils;
|
|
|
+import org.apache.http.Consts;
|
|
|
+import org.apache.http.HttpEntity;
|
|
|
+import org.apache.http.NameValuePair;
|
|
|
+import org.apache.http.client.ClientProtocolException;
|
|
|
+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.HttpGet;
|
|
|
+import org.apache.http.client.methods.HttpPost;
|
|
|
+import org.apache.http.entity.StringEntity;
|
|
|
+import org.apache.http.impl.client.CloseableHttpClient;
|
|
|
+import org.apache.http.impl.client.HttpClients;
|
|
|
+import org.apache.http.message.BasicNameValuePair;
|
|
|
+import org.apache.http.util.EntityUtils;
|
|
|
+import org.jeecg.common.system.api.ISysBaseAPI;
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+
|
|
|
+import java.io.IOException;
|
|
|
+import java.net.URLEncoder;
|
|
|
+import java.util.*;
|
|
|
+
|
|
|
+/**
|
|
|
+ * @author fenghaifu
|
|
|
+ * @version V1.0
|
|
|
+ * @Copyright: 上海萃颠信息科技有限公司. All rights reserved.
|
|
|
+ * @Title:HttpHelper
|
|
|
+ * @projectName data-exchange-platform
|
|
|
+ * @Description:通用http请求
|
|
|
+ * @date: 2020/1/11 15:16
|
|
|
+ * @updatehistory: 2020/1/11 15:16 新增
|
|
|
+ */
|
|
|
+public class HttpHelper {
|
|
|
+ private static final int SOCKET_TIME_OUT = 300000;
|
|
|
+ /**
|
|
|
+ * 发送http请求
|
|
|
+ * @param url
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public static String httpGet(String url, Map<String,Object> params, Map<String,Object> headerItems) {
|
|
|
+ //创建httpClient
|
|
|
+ CloseableHttpClient httpClient = HttpClients.createDefault();
|
|
|
+ // 附加参数
|
|
|
+ url = getFullUrl(url, params);
|
|
|
+
|
|
|
+ HttpGet httpGet = new HttpGet(url); //生成一个请求
|
|
|
+ RequestConfig requestConfig = RequestConfig.custom(). //配置请求的一些属性
|
|
|
+ setSocketTimeout(SOCKET_TIME_OUT).setConnectTimeout(SOCKET_TIME_OUT).setConnectionRequestTimeout(SOCKET_TIME_OUT).build();
|
|
|
+ httpGet.setConfig(requestConfig); //为请求设置属性
|
|
|
+ // 设置http头
|
|
|
+ if (headerItems != null) {
|
|
|
+ for (String key : headerItems.keySet()) {
|
|
|
+ httpGet.addHeader(key, headerItems.get(key).toString());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ CloseableHttpResponse response = null;
|
|
|
+ HttpEntity entity = null;
|
|
|
+ try {
|
|
|
+ response = httpClient.execute(httpGet);
|
|
|
+ //如果返回结果的code不等于200，说明出错了
|
|
|
+ if (response.getStatusLine().getStatusCode() != 200) {
|
|
|
+ System.out.println("request url failed, http code=" + response.getStatusLine().getStatusCode() + ", url=" + url);
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+ entity = response.getEntity(); //reponse返回的数据在entity中
|
|
|
+ String ret = null;
|
|
|
+ if (entity != null) {
|
|
|
+ ret = EntityUtils.toString(entity, "utf-8");//将数据转化为string格式
|
|
|
+ }
|
|
|
+ return ret;
|
|
|
+ } catch (ClientProtocolException e) {
|
|
|
+ // TODO Auto-generated catch block
|
|
|
+ System.out.println("request url=" + url + ", exception, msg=" + e.getMessage());
|
|
|
+ e.printStackTrace();
|
|
|
+ } catch (Exception e) {
|
|
|
+ // TODO Auto-generated catch block
|
|
|
+ System.out.println("request url=" + url + ", exception, msg=" + e.getMessage());
|
|
|
+ e.printStackTrace();
|
|
|
+ } finally {
|
|
|
+ if (response != null) try {
|
|
|
+ response.close();
|
|
|
+ EntityUtils.consume(entity);
|
|
|
+ } catch (IOException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+
|
|
|
+ //post请求
|
|
|
+ public static String httpPost(String url, Map<String,Object> params, Map<String,Object> headerItems) {
|
|
|
+ CloseableHttpClient client = HttpClients.createDefault();
|
|
|
+ CloseableHttpResponse response = null;
|
|
|
+ HttpEntity entity = null;
|
|
|
+ try {
|
|
|
+ if (params != null) {
|
|
|
+ //建立Request的对象，一般用目标url来构造，Request一般配置addHeader、setEntity、setConfig
|
|
|
+ HttpPost req = new HttpPost(url);
|
|
|
+ entity = new UrlEncodedFormEntity(createParam(params), Consts.UTF_8);
|
|
|
+ //setHeader,添加头文件
|
|
|
+ if (headerItems != null) {
|
|
|
+ Set<String> keys = headerItems.keySet();
|
|
|
+ for (String key : keys) {
|
|
|
+ req.setHeader(key, headerItems.get(key).toString());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //setConfig,添加配置,如设置请求超时时间,连接超时时间
|
|
|
+ RequestConfig reqConfig = RequestConfig.custom().setSocketTimeout(SOCKET_TIME_OUT).setConnectTimeout(SOCKET_TIME_OUT).setConnectionRequestTimeout(SOCKET_TIME_OUT).build();
|
|
|
+ req.setConfig(reqConfig);
|
|
|
+ //setEntity,添加内容
|
|
|
+ req.setEntity(entity);
|
|
|
+ //执行Request请求,CloseableHttpClient的execute方法返回的response都是CloseableHttpResponse类型
|
|
|
+ //其常用方法有getFirstHeader(String)、getLastHeader(String)、headerIterator（String）取得某个Header name对应的迭代器、getAllHeaders()、getEntity、getStatus等
|
|
|
+ response = client.execute(req);
|
|
|
+ entity = response.getEntity();
|
|
|
+ //用EntityUtils.toString()这个静态方法将HttpEntity转换成字符串,防止服务器返回的数据带有中文,所以在转换的时候将字符集指定成utf-8就可以了
|
|
|
+ String result = EntityUtils.toString(entity, "UTF-8");
|
|
|
+ if (response.getStatusLine().getStatusCode() == 200) {
|
|
|
+ return result;
|
|
|
+ } else {
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return null;
|
|
|
+ } catch (Exception ex) {
|
|
|
+ ex.printStackTrace();
|
|
|
+ } finally {
|
|
|
+ //一定要记得把entity fully consume掉，否则连接池中的connection就会一直处于占用状态
|
|
|
+ try {
|
|
|
+ EntityUtils.consume(entity);
|
|
|
+ } catch (Exception ex) {
|
|
|
+ ex.printStackTrace();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+
|
|
|
+ //post请求
|
|
|
+ public static String httpJsonPost(String url, String bodyParam, Map<String,Object> headerItems) {
|
|
|
+ CloseableHttpClient client = HttpClients.createDefault();
|
|
|
+ CloseableHttpResponse response = null;
|
|
|
+ StringEntity entity = null;
|
|
|
+ try {
|
|
|
+ if (StringUtils.isNotEmpty(bodyParam)) {
|
|
|
+ //建立Request的对象，一般用目标url来构造，Request一般配置addHeader、setEntity、setConfig
|
|
|
+ HttpPost req = new HttpPost(url);
|
|
|
+ //entity = new StringEntity(bodyParam.toString(),"utf-8");//解决中文乱码问题
|
|
|
+ entity = new StringEntity(bodyParam,"utf-8");//解决中文乱码问题
|
|
|
+ entity.setContentEncoding("UTF-8");
|
|
|
+ entity.setContentType("application/json");
|
|
|
+ //setHeader,添加头文件
|
|
|
+ if (headerItems != null) {
|
|
|
+ Set<String> keys = headerItems.keySet();
|
|
|
+ for (String key : keys) {
|
|
|
+ req.setHeader(key, headerItems.get(key).toString());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //setConfig,添加配置,如设置请求超时时间,连接超时时间
|
|
|
+ RequestConfig reqConfig = RequestConfig.custom().setSocketTimeout(SOCKET_TIME_OUT).setConnectTimeout(SOCKET_TIME_OUT).setConnectionRequestTimeout(SOCKET_TIME_OUT).build();
|
|
|
+ req.setConfig(reqConfig);
|
|
|
+ //setEntity,添加内容
|
|
|
+ req.setEntity(entity);
|
|
|
+ //执行Request请求,CloseableHttpClient的execute方法返回的response都是CloseableHttpResponse类型
|
|
|
+ //其常用方法有getFirstHeader(String)、getLastHeader(String)、headerIterator（String）取得某个Header name对应的迭代器、getAllHeaders()、getEntity、getStatus等
|
|
|
+ response = client.execute(req);
|
|
|
+ if (response.getStatusLine().getStatusCode() == 200) {
|
|
|
+ HttpEntity responseEntity = response.getEntity();
|
|
|
+ //用EntityUtils.toString()这个静态方法将HttpEntity转换成字符串,防止服务器返回的数据带有中文,所以在转换的时候将字符集指定成utf-8就可以了
|
|
|
+ String result = EntityUtils.toString(responseEntity, "UTF-8");
|
|
|
+ return result;
|
|
|
+ } else {
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return null;
|
|
|
+ } catch (Exception ex) {
|
|
|
+ ex.printStackTrace();
|
|
|
+ } finally {
|
|
|
+ //一定要记得把entity fully consume掉，否则连接池中的connection就会一直处于占用状态
|
|
|
+ try {
|
|
|
+ EntityUtils.consume(entity);
|
|
|
+ } catch (Exception ex) {
|
|
|
+ ex.printStackTrace();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+ /**
|
|
|
+ * 把参数合成完整url
|
|
|
+ * @param url
|
|
|
+ * @param params
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public static String getFullUrl(String url, Map<String,Object> params){
|
|
|
+ StringBuilder appendParams = new StringBuilder();
|
|
|
+ if (params != null){
|
|
|
+ for(String key : params.keySet()){
|
|
|
+ if (appendParams.length() > 0)
|
|
|
+ appendParams.append("&");
|
|
|
+ appendParams.append(key+"="+ MyUrlEncode(params.get(key).toString()));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (appendParams.length()>0){
|
|
|
+ if (url.indexOf("?") == -1)
|
|
|
+ url = url +"?"+appendParams.toString();
|
|
|
+ else
|
|
|
+ url = url +"&"+appendParams.toString();
|
|
|
+ }
|
|
|
+ return url;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 参数编码
|
|
|
+ * @param data
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ private static String MyUrlEncode(String data){
|
|
|
+ String ret = data;
|
|
|
+ try{
|
|
|
+ ret = URLEncoder.encode(ret, "GBK");
|
|
|
+ }catch (Exception ex){
|
|
|
+
|
|
|
+ }
|
|
|
+ return ret;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * post提交参数转换
|
|
|
+ * @param param
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ private static List<NameValuePair> createParam(Map<String, Object> param) {
|
|
|
+ //建立一个NameValuePair数组，用于存储欲传送的参数
|
|
|
+ List<NameValuePair> nvps = new ArrayList<NameValuePair>();
|
|
|
+ if(param != null) {
|
|
|
+ for(String k : param.keySet()) {
|
|
|
+ nvps.add(new BasicNameValuePair(k, param.get(k).toString()));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return nvps;
|
|
|
+ }
|
|
|
+}
|
