文章目录
package tv.huan.common.utils.http;
import com.alibaba.fastjson.JSONObject;
import org.apache.http.HttpEntity;
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.conn.ClientConnectionManager;
import org.apache.http.conn.scheme.Scheme;
import org.apache.http.conn.scheme.SchemeRegistry;
import org.apache.http.conn.ssl.SSLSocketFactory;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.protocol.HTTP;
import org.apache.http.util.EntityUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import javax.net.ssl.*;
import java.security.cert.CertificateException;
import java.security.cert.X509Certificate;
import java.util.ArrayList;
import java.util.List;
public class HttpsUtils {
private static final Logger log = LoggerFactory.getLogger(HttpsUtils.class);
public static String rhptGet(String url) {
HttpGet httpGet = new HttpGet(url);
SSLClient httpClient = null;
httpGet.addHeader("User-Agent", "Mozilla/5.0(Windows NT 6.1;Win64; x64; rv:50.0) Gecko/20100101 Firefox/50.0");
httpGet.addHeader("Content-type", "application/x-www-form-urlencoded");
httpGet.addHeader("other", "xxxxx");
JSONObject jsonObject = new JSONObject();
jsonObject.put("paramA", "xxxxxxx");
jsonObject.put("paramB", "123");
List<NameValuePair> list = new ArrayList<>();
list.add(new BasicNameValuePair("jsonData", jsonObject.toString()));
String respMsg = "";
try {
UrlEncodedFormEntity urlEncodedFormEntity = new UrlEncodedFormEntity(list, HTTP.UTF_8);
httpClient = new HttpsUtils().new SSLClient();
CloseableHttpResponse response = httpClient.execute(httpGet);
HttpEntity httpEntity = response.getEntity();
respMsg = EntityUtils.toString(httpEntity, "utf-8");
log.info("发送HTTPS的get请求获取到的响应为" + respMsg);
} catch (Exception e) {
log.error("发送HTTPS的get请求异常", e);
} finally {
if (httpClient != null) {
httpClient.close();
}
}
return respMsg;
}
public static String rhptPost(String url, String params) {
HttpPost post = new HttpPost(url);
SSLClient httpClient = null;
post.addHeader("User-Agent", "Mozilla/5.0(Windows NT 6.1;Win64; x64; rv:50.0) Gecko/20100101 Firefox/50.0");
post.addHeader("Content-type", "application/x-www-form-urlencoded");
post.addHeader("other", "xxxxx");
String respMsg = "";
try {
post.setEntity(new StringEntity(params, HTTP.UTF_8));
httpClient = new HttpsUtils().new SSLClient();
CloseableHttpResponse response = httpClient.execute(post);
HttpEntity httpEntity = response.getEntity();
respMsg = EntityUtils.toString(httpEntity, "utf-8");
log.info("发送HTTPS的post请求获取到的响应为" + respMsg);
} catch (Exception e) {
log.error("发送HTTPS的post请求异常", e);
} finally {
if (httpClient != null) {
httpClient.close();
}
}
return respMsg;
}
public static void enableSSL(DefaultHttpClient httpclient) {
TrustManager[] truseAllManager = new TrustManager[]{new X509TrustManager() {
public X509Certificate[] getAcceptedIssuers() {
return new X509Certificate[]{};
}
public void checkClientTrusted(X509Certificate[] chain, String authType) {
}
public void checkServerTrusted(X509Certificate[] chain, String authType) {
}
}};
try {
SSLContext sslcontext = SSLContext.getInstance("TLS");
sslcontext.init(null, truseAllManager, null);
SSLSocketFactory sf = new SSLSocketFactory(sslcontext);
sf.setHostnameVerifier(SSLSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER);
Scheme https = new Scheme("https", sf, 4433);
httpclient.getConnectionManager().getSchemeRegistry().register(https);
} catch (Exception e) {
e.printStackTrace();
}
}
class SSLClient extends DefaultHttpClient {
public SSLClient() throws Exception {
super();
SSLContext ctx = SSLContext.getInstance("TLS");
X509TrustManager tm = new X509TrustManager() {
@Override
public void checkClientTrusted(X509Certificate[] chain,
String authType) throws CertificateException {
}
@Override
public void checkServerTrusted(X509Certificate[] chain,
String authType) throws CertificateException {
}
@Override
public X509Certificate[] getAcceptedIssuers() {
return null;
}
};
ctx.init(null, new TrustManager[]{tm}, null);
SSLSocketFactory ssf = new SSLSocketFactory(ctx, SSLSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER);
ClientConnectionManager ccm = this.getConnectionManager();
SchemeRegistry sr = ccm.getSchemeRegistry();
sr.register(new Scheme("https", 443, ssf));
}
}
}
|