package com.suning.epp.trt.util.r32epp;
import java.io.BufferedInputStream;
import java.io.IOException;
import java.net.URLDecoder;
import java.security.cert.CertificateException;
import java.security.cert.X509Certificate;
import java.util.List;
import javax.net.ssl.SSLContext;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.ssl.SSLContextBuilder;
import org.apache.http.ssl.TrustStrategy;
import org.apache.http.util.EntityUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class HttpsClientUtil {
private static final String UTF_8 = "UTF-8";
private HttpsClientUtil() {
}
private static final Logger log = LoggerFactory
.getLogger(HttpsClientUtil.class);
public static String post(List<BasicNameValuePair> params, String url,
String logPrefix) {
CloseableHttpClient httpClient = createSSLClientDefault(logPrefix);
try {
HttpPost post = createPost(params, url, logPrefix);
HttpResponse response = httpClient.execute(post);
HttpEntity entity = response.getEntity();
String body = EntityUtils.toString(entity);
return body;
} catch (Exception e) {
throw new EppRuntimeException(e);
} finally {
try {
httpClient.close();
} catch (IOException e) {
log.error(logPrefix, e);
}
}
}
public static CloseableHttpClient createSSLClientDefault(String logPrefix) {
try {
SSLContext sslContext = new SSLContextBuilder().loadTrustMaterial(
null, new TrustStrategy() {
// 信任所有
public boolean isTrusted(X509Certificate[] chain,
String authType) throws CertificateException {
return true;
}
}).build();
SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(
sslContext);
return HttpClients.custom().setSSLSocketFactory(sslsf).build();
} catch (Exception e) {
log.error(logPrefix, e);
}
return HttpClients.createDefault();
}
private static HttpPost createPost(List<BasicNameValuePair> params,
String url, String logPrefix) throws Exception {
HttpPost post = new HttpPost(url);
HttpEntity httpEntity = new UrlEncodedFormEntity(params, UTF_8);
post.setEntity(httpEntity);
printParams(url, logPrefix, httpEntity);
return post;
}
private static void printParams(String url, String logPrefix,
HttpEntity httpEntity) throws IOException {
BufferedInputStream bif = null;
try {
bif = new BufferedInputStream(httpEntity.getContent());
byte[] byteArr = new byte[(int) httpEntity.getContentLength()];
byte tmpByte[] = new byte[1024];
int totalCounts = 0;
int size = bif.read(tmpByte);
while (size > 0) {
System.arraycopy(tmpByte, 0, byteArr, totalCounts, size);
totalCounts = totalCounts + size;
size = bif.read(tmpByte);
}
log.info(logPrefix + "HTTP请求：{}?{}", url,
URLDecoder.decode(new String(byteArr, UTF_8), UTF_8));
} catch (Exception e) {
log.error(logPrefix, e);
} finally {
if (bif != null) {
bif.close();
}
}
}
}