HttpClient封装工具类
作者：互联网
1 URIBuilder ub = new URIBuilder();
2 URI uri = ub.setScheme("http")
3 .setHost("www.google.com")
4 .setPath("/search")
5 .setParameter("q", "编程狗的博客")
6 .setParameter("btnG", "Google Search")
7 .setParameter("aq", "f")
8 .setParameter("oq", "")
9 .build();
10 System.out.println(uri);
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
<version>4.5.12</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.72</version>
</dependency>
<dependency>
<groupId>commons-lang</groupId>
<artifactId>commons-lang</artifactId>
<version>2.6</version>
</dependency>
Mven依赖
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import org.apache.commons.lang.StringEscapeUtils;
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.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.methods.HttpRequestBase;
import org.apache.http.client.utils.URIBuilder;
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.message.BasicNameValuePair;
import org.apache.http.util.EntityUtils;
import java.util.*;
import java.io.IOException;
import java.net.URISyntaxException;
import java.util.ArrayList;
import java.util.Map;
public final class HttpClientUtils {
private static volatile PoolingHttpClientConnectionManager cm;// 连接池配置管理
private static String EMPTY_STR = "";
private static String UTF_8 = "UTF-8";
/**
* 配置初始化
*/
private static synchronized void init() {
if (cm == null) {
cm = new PoolingHttpClientConnectionManager();
cm.setMaxTotal(50);// 整个连接池最大连接数
cm.setDefaultMaxPerRoute(25);// 每路由最大连接数，默认值是2
}
}
/**
* 通过连接池获取HttpClient
*/
private static CloseableHttpClient getHttpClient() {
// 初始化
init();
// 返回httpclient
return HttpClients.custom().setConnectionManager(cm).build();
}
/**
* get请求
*/
public static HttpEntity httpGetRequest(String url) throws URISyntaxException, IOException {
return httpGetRequest(url,null,null);
}
/**
* get请求，参数
*/
public static HttpEntity httpGetRequest(String url, Map<String, Object> params) throws URISyntaxException, IOException {
return httpGetRequest(url,null,params);
}
/**
* get请求，请求头
*/
public static HttpEntity httpGetRequest(String url, HashMap<String, Object> headers) throws URISyntaxException, IOException {
return httpGetRequest(url,headers,null);
}
/**
* get请求，请求头 + 参数
*/
public static HttpEntity httpGetRequest(String url, Map<String, Object> headers, Map<String, Object> params) throws URISyntaxException, IOException {
URIBuilder ub = new URIBuilder(url);
if(!Objects.isNull(params)){
ArrayList<NameValuePair> pairs = covertParams2NVPS(params);
ub.setParameters(pairs);
}
HttpGet httpGet = new HttpGet(ub.build());
if(!Objects.isNull(headers)){
for (Map.Entry<String, Object> header : headers.entrySet()) {
httpGet.addHeader(header.getKey(), String.valueOf(header.getValue()));
}
}
return getEntity(httpGet);
}
/**
* post请求
*/
public static HttpEntity httpPostRequest(String url) throws IOException {
return httpPostRequest(url, null, null, null);
}
/**
* post请求，请求头
*/
public static HttpEntity httpPostRequest(String url, HashMap<String, Object> headers) throws IOException {
return httpPostRequest(url, headers, null, null);
}
/**
* post请求，json体
*/
public static HttpEntity httpPostRequest(String url, String jsonStrBody) throws IOException {
return httpPostRequest(url, null, null, jsonStrBody);
}
/**
* post请求，formdata参数
*/
public static HttpEntity httpPostRequest(String url, Map<String, Object> params) throws IOException {
return httpPostRequest(url, null, params, null);
}
/**
* post请求，请求头 + json体
*/
public static HttpEntity httpPostRequest(String url, HashMap<String, Object> headers, String jsonStrBody) throws IOException {
return httpPostRequest(url, headers, null, jsonStrBody);
}
/**
* post请求，请求头 + formdata参数
*/
public static HttpEntity httpPostRequest(String url, HashMap<String, Object> headers, Map<String, Object> params) throws IOException {
return httpPostRequest(url, headers, params, null);
}
/**
* post请求汇总方法：请求头，formdata参数，jsonbody参数
*/
private static HttpEntity httpPostRequest(String url, Map<String, Object> headers, Map<String, Object> params, String jsonStrBody) throws IOException {
HttpPost httpPost = new HttpPost(url);
if(!Objects.isNull(headers)){
for (Map.Entry<String, Object> param : headers.entrySet()) {
httpPost.addHeader(param.getKey(), String.valueOf(param.getValue()));
}
}
if (!Objects.isNull(params)){
ArrayList<NameValuePair> pairs = covertParams2NVPS(params);
httpPost.setEntity(new UrlEncodedFormEntity(pairs, UTF_8));
}
if(!Objects.isNull(jsonStrBody)){
StringEntity se = new StringEntity(jsonStrBody, UTF_8);
se.setContentType("text/json");
httpPost.setEntity(se);
}
return getEntity(httpPost);
}
/**
* 处理http请求，获取HttpEntity
*/
private static HttpEntity getEntity(HttpRequestBase request) throws IOException {
CloseableHttpClient httpClient = getHttpClient();
CloseableHttpResponse response = httpClient.execute(request);
int statusCode = response.getStatusLine().getStatusCode();
if (statusCode != HttpStatus.SC_OK) {
request.abort();
}
HttpEntity entity = response.getEntity();
// response.close();
// httpClient.close();
return entity;
}
/**
* 处理Http请求，获取String结果
*/
public static String getResultOfString(HttpEntity httpEntity) throws IOException {
String result = EntityUtils.toString(httpEntity, UTF_8);
return result;
}
/**
* 处理Http请求，获取JSONObject结果
*/
public static JSONObject getResultOfJSONObject(HttpEntity httpEntity) throws IOException {
String result = EntityUtils.toString(httpEntity, UTF_8);
result = StringEscapeUtils.unescapeJava(result);
JSONObject jsonObject = JSON.parseObject(result);
return jsonObject;
}
/**
* 转换成http参数对
*
* @param params
* @return
*/
private static ArrayList<NameValuePair> covertParams2NVPS(Map<String, Object> params) {
ArrayList<NameValuePair> pairs = new ArrayList<>();
for (Map.Entry<String, Object> param : params.entrySet()) {
pairs.add(new BasicNameValuePair(param.getKey(), String.valueOf(param.getValue())));
}
return pairs;
}
}
HttClient工具类
标签：HttpEntity,封装,String,url,http,static,import,工具,HttpClient 来源： https://www.cnblogs.com/Wang-py/p/15682879.html