package com.ltkj.web.wxUtils;
|
|
|
import org.apache.http.HttpEntity;
|
import org.apache.http.HttpResponse;
|
import org.apache.http.NameValuePair;
|
import org.apache.http.client.ClientProtocolException;
|
import org.apache.http.client.HttpClient;
|
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 com.ltkj.web.wxUtils.HttpClientUtils;
|
import org.apache.http.conn.ssl.DefaultHostnameVerifier;
|
import org.apache.http.conn.util.PublicSuffixMatcher;
|
import org.apache.http.conn.util.PublicSuffixMatcherLoader;
|
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.springframework.stereotype.Component;
|
import java.io.*;
|
import java.net.HttpURLConnection;
|
import java.net.URL;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Map;
|
|
|
/**
|
* httpClient 工具类
|
*
|
* @create 2019-02-10 下午 2:49
|
*/
|
@Component
|
public class HttpClientUtils {
|
|
/**
|
* 默认参数设置
|
* setConnectTimeout：设置连接超时时间，单位毫秒。
|
* setConnectionRequestTimeout：设置从connect Manager获取Connection 超时时间，单位毫秒。
|
* setSocketTimeout：请求获取数据的超时时间，单位毫秒。访问一个接口，多少时间内无法返回数据，就直接放弃此次调用。 暂时定义15分钟
|
*/
|
private RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(600000).setConnectTimeout(600000).setConnectionRequestTimeout(600000).build();
|
|
/**
|
* 静态内部类---作用：单例产生类的实例
|
*
|
* @author Administrator
|
*/
|
private static class LazyHolder {
|
private static final HttpClientUtils INSTANCE = new HttpClientUtils();
|
|
}
|
|
HttpClientUtils() {
|
}
|
|
public static HttpClientUtils getInstance() {
|
return LazyHolder.INSTANCE;
|
}
|
|
/**
|
* 发送 post请求
|
*
|
* @param httpUrl 地址
|
*/
|
public String sendHttpPost(String httpUrl) {
|
HttpPost httpPost = new HttpPost(httpUrl);// 创建httpPost
|
return sendHttpPost(httpPost);
|
}
|
|
/**
|
* 发送 post请求
|
*
|
* @param httpUrl 地址
|
* @param params 参数(格式:key1=value1&key2=value2)
|
*/
|
public String sendHttpPost(String httpUrl, String params) {
|
HttpPost httpPost = new HttpPost(httpUrl);// 创建httpPost
|
try {
|
//设置参数
|
StringEntity stringEntity = new StringEntity(params, "UTF-8");
|
stringEntity.setContentType("application/x-www-form-urlencoded");
|
httpPost.setEntity(stringEntity);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return sendHttpPost(httpPost);
|
}
|
|
|
public static String sendPost(String httpUrl, Map<String, Object> maps) {
|
|
try {
|
// 1. 创建 URL 对象
|
URL url = new URL(httpUrl);
|
// 2. 创建 HttpURLConnection 对象
|
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
|
|
// 3. 设置请求方法为 POST
|
connection.setRequestMethod("POST");
|
|
// 4. 设置 Content-Type 头部字段
|
connection.setRequestProperty("Content-Type", "application/json");
|
|
// 5. 设置其他请求头部字段（可选）
|
// connection.setRequestProperty("Authorization", "Bearer token");
|
// connection.setRequestProperty("User-Agent", "Mozilla/5.0");
|
|
// 6. 向服务器发送数据
|
String requestBody = maps.toString();
|
byte[] postData = requestBody.getBytes("UTF-8");
|
connection.setDoOutput(true);
|
try (OutputStream outputStream = connection.getOutputStream()) {
|
outputStream.write(postData);
|
}
|
|
// 7. 获取响应码
|
int responseCode = connection.getResponseCode();
|
|
// 8. 获取响应数据
|
try (BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream()))) {
|
String line;
|
StringBuilder response = new StringBuilder();
|
while ((line = reader.readLine()) != null) {
|
response.append(line);
|
}
|
System.out.println(response.toString());
|
connection.disconnect();
|
return response.toString();
|
}
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
|
return null;
|
}
|
|
/**
|
* 发送 post请求
|
*
|
* @param httpUrl 地址
|
* @param maps 参数
|
*/
|
public String sendHttpPost(String httpUrl, Map<String, String> maps) {
|
HttpPost httpPost = new HttpPost(httpUrl);// 创建httpPost
|
// 创建参数队列
|
List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>();
|
for (String key : maps.keySet()) {
|
nameValuePairs.add(new BasicNameValuePair(key, maps.get(key)));
|
}
|
try {
|
httpPost.setEntity(new UrlEncodedFormEntity(nameValuePairs, "UTF-8"));
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return sendHttpPost(httpPost);
|
}
|
|
|
/**
|
* 发送Post请求
|
*
|
* @param httpPost
|
* @return
|
*/
|
private String sendHttpPost(HttpPost httpPost) {
|
CloseableHttpClient httpClient = null;
|
CloseableHttpResponse response = null;
|
HttpEntity entity = null;
|
String responseContent = null;
|
try {
|
// 创建默认的httpClient实例
|
httpClient = HttpClients.createDefault();
|
httpPost.setConfig(requestConfig);
|
// 执行请求
|
long execStart = System.currentTimeMillis();
|
response = httpClient.execute(httpPost);
|
long execEnd = System.currentTimeMillis();
|
System.out.println("=================执行post请求耗时：" + (execEnd - execStart) + "ms");
|
long getStart = System.currentTimeMillis();
|
entity = response.getEntity();
|
responseContent = EntityUtils.toString(entity, "UTF-8");
|
long getEnd = System.currentTimeMillis();
|
System.out.println("=================获取响应结果耗时：" + (getEnd - getStart) + "ms");
|
} catch (Exception e) {
|
e.printStackTrace();
|
} finally {
|
try {
|
// 关闭连接,释放资源
|
if (response != null) {
|
response.close();
|
}
|
if (httpClient != null) {
|
httpClient.close();
|
}
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
return responseContent;
|
}
|
|
/**
|
* 发送 get请求
|
*
|
* @param httpUrl
|
*/
|
public String sendHttpGet(String httpUrl) {
|
HttpGet httpGet = new HttpGet(httpUrl);// 创建get请求
|
return sendHttpGet(httpGet);
|
}
|
|
/**
|
* 发送 get请求Https
|
*
|
* @param httpUrl
|
*/
|
public String sendHttpsGet(String httpUrl) {
|
HttpGet httpGet = new HttpGet(httpUrl);// 创建get请求
|
return sendHttpsGet(httpGet);
|
}
|
|
/**
|
* 发送Get请求
|
*
|
* @param httpGet
|
* @return
|
*/
|
private String sendHttpGet(HttpGet httpGet) {
|
CloseableHttpClient httpClient = null;
|
CloseableHttpResponse response = null;
|
HttpEntity entity = null;
|
String responseContent = null;
|
try {
|
// 创建默认的httpClient实例.
|
|
|
httpClient = HttpClients.createDefault();
|
|
httpGet.setConfig(requestConfig);
|
// 执行请求
|
response = httpClient.execute(httpGet);
|
entity = response.getEntity();
|
responseContent = EntityUtils.toString(entity, "UTF-8");
|
} catch (Exception e) {
|
e.printStackTrace();
|
} finally {
|
try {
|
// 关闭连接,释放资源
|
if (response != null) {
|
response.close();
|
}
|
if (httpClient != null) {
|
httpClient.close();
|
}
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
return responseContent;
|
}
|
|
/**
|
* 发送Get请求Https
|
*
|
* @param httpGet
|
* @return
|
*/
|
private String sendHttpsGet(HttpGet httpGet) {
|
CloseableHttpClient httpClient = null;
|
CloseableHttpResponse response = null;
|
HttpEntity entity = null;
|
String responseContent = null;
|
try {
|
// 创建默认的httpClient实例.
|
PublicSuffixMatcher publicSuffixMatcher = PublicSuffixMatcherLoader.load(new URL(httpGet.getURI().toString()));
|
DefaultHostnameVerifier hostnameVerifier = new DefaultHostnameVerifier(publicSuffixMatcher);
|
httpClient = HttpClients.custom().setSSLHostnameVerifier(hostnameVerifier).build();
|
httpGet.setConfig(requestConfig);
|
// 执行请求
|
response = httpClient.execute(httpGet);
|
entity = response.getEntity();
|
responseContent = EntityUtils.toString(entity, "UTF-8");
|
} catch (Exception e) {
|
e.printStackTrace();
|
} finally {
|
try {
|
// 关闭连接,释放资源
|
if (response != null) {
|
response.close();
|
}
|
if (httpClient != null) {
|
httpClient.close();
|
}
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
return responseContent;
|
}
|
|
/**
|
* 发送xml数据
|
*
|
* @param url
|
* @param xmlData
|
* @return
|
* @throws ClientProtocolException
|
* @throws IOException
|
*/
|
public static HttpResponse sendXMLDataByPost(String url, String xmlData)
|
throws ClientProtocolException, IOException {
|
HttpClient httpClient = HttpClients.createDefault();
|
HttpPost httppost = new HttpPost(url);
|
StringEntity entity = new StringEntity(xmlData);
|
httppost.setEntity(entity);
|
httppost.setHeader("Content-Type", "text/xml;charset=UTF-8");
|
HttpResponse response = httpClient.execute(httppost);
|
return response;
|
}
|
|
/**
|
* 获得响应HTTP实体内容
|
*
|
* @param response
|
* @return
|
* @throws IOException
|
* @throws UnsupportedEncodingException
|
*/
|
public static String getHttpEntityContent(HttpResponse response) throws IOException, UnsupportedEncodingException {
|
HttpEntity entity = response.getEntity();
|
if (entity != null) {
|
InputStream is = entity.getContent();
|
BufferedReader br = new BufferedReader(new InputStreamReader(is, "UTF-8"));
|
String line = br.readLine();
|
StringBuilder sb = new StringBuilder();
|
while (line != null) {
|
sb.append(line + "\n");
|
line = br.readLine();
|
}
|
return sb.toString();
|
}
|
return "";
|
}
|
|
|
}
|
