HttpUtil工具

http工具

用到的依赖

<dependency><groupId>org.apache.httpcomponents</groupId><artifactId>httpclient</artifactId><version>4.5.13</version></dependency><dependency><groupId>org.apache.httpcomponents</groupId><artifactId>httpmime</artifactId><version>4.5.13</version></dependency><dependency><groupId>commons-io</groupId><artifactId>commons-io</artifactId><version>2.11.0</version></dependency>

httpUtil工具

import org.apache.commons.io.IOUtils;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.client.config.RequestConfig;
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.client.utils.HttpClientUtils;
import org.apache.http.entity.StringEntity;
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.util.EntityUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;import java.io.IOException;
import java.io.InputStream;
import java.util.Iterator;
import java.util.Map;/*** http请求工具类*/
public class HttpUtil {private static final Logger logger = LoggerFactory.getLogger(HttpUtil.class);private static PoolingHttpClientConnectionManager connMgr = new PoolingHttpClientConnectionManager();private static RequestConfig requestConfig;private static final String DEFAULT_CHARSET = "UTF-8";public HttpUtil() {}static {connMgr.setMaxTotal(100);connMgr.setDefaultMaxPerRoute(connMgr.getMaxTotal());RequestConfig.Builder configBuilder = RequestConfig.custom();configBuilder.setConnectTimeout(5000);configBuilder.setSocketTimeout(20000);configBuilder.setConnectionRequestTimeout(5000);requestConfig = configBuilder.build();}/*** Post方式** @param apiUrl* @param json      json数据* @param headerMap 请求头* @return*/public static String doPost(String apiUrl, String json, Map<String, String> headerMap) throws Exception {long start = System.currentTimeMillis();CloseableHttpClient httpClient = HttpClients.createDefault();String httpStr = null;HttpPost httpPost = new HttpPost(apiUrl);CloseableHttpResponse response = null;int statusCode = -999;try {httpPost.setConfig(requestConfig);StringEntity stringEntity = new StringEntity(json.toString(), DEFAULT_CHARSET);stringEntity.setContentEncoding(DEFAULT_CHARSET);//循环增加headerif (headerMap != null) {Iterator headerIterator = headerMap.entrySet().iterator();while (headerIterator.hasNext()) {Map.Entry<String, String> elem = (Map.Entry<String, String>) headerIterator.next();httpPost.addHeader(elem.getKey(), elem.getValue());}}stringEntity.setContentType("application/json");httpPost.setEntity(stringEntity);response = httpClient.execute(httpPost);HttpEntity entity = response.getEntity();statusCode = response.getStatusLine().getStatusCode();httpStr = EntityUtils.toString(entity, DEFAULT_CHARSET);} catch (Exception e) {logger.error("HttpUtil发生错误:", e);throw new Exception("网络异常", e);} finally {if (response != null) {try {EntityUtils.consume(response.getEntity());} catch (IOException var19) {var19.printStackTrace();}}logger.info("request to:{},param:{},response code:{},result:{},cost {} ms", new Object[]{apiUrl, json, statusCode, httpStr, System.currentTimeMillis() - start});}return httpStr;}/*** 请求方式 Get** @param url       请求链接* @param params    以 x-www-form-urlencoded* @param headerMap 请求头参数* @return*/public static String doGet(String url, Map<String, Object> params, Map<String, String> headerMap) throws Exception {long start = System.currentTimeMillis();StringBuffer param = new StringBuffer();if (null != params) {int i = 0;for (Iterator iterator = params.keySet().iterator(); iterator.hasNext(); ++i) {String key = (String) iterator.next();if (i == 0) {param.append("?");} else {param.append("&");}param.append(key).append("=").append(params.get(key));}}String apiUrl = url + param;String result = null;CloseableHttpClient httpClient = HttpClients.createDefault();int statusCode = -999;try {HttpGet httpGet = new HttpGet(apiUrl);//循环增加headerif (headerMap != null) {Iterator headerIterator = headerMap.entrySet().iterator();while (headerIterator.hasNext()) {Map.Entry<String, String> elem = (Map.Entry<String, String>) headerIterator.next();httpGet.addHeader(elem.getKey(), elem.getValue());}}HttpResponse response = httpClient.execute(httpGet);statusCode = response.getStatusLine().getStatusCode();HttpEntity entity = response.getEntity();if (entity != null) {InputStream instream = entity.getContent();result = IOUtils.toString(instream, DEFAULT_CHARSET);}} catch (Exception e) {logger.error("HttpUtil发生错误:", e);throw new Exception("网络异常", e);} finally {if (httpClient != null) {HttpClientUtils.closeQuietly(httpClient);}logger.info("request to:{},param:{},response code:{},result:{},cost {} ms", new Object[]{apiUrl, param.toString(), statusCode, result, System.currentTimeMillis() - start});}return result;}}