| | |
| | | |
| | | import okhttp3.*; |
| | | |
| | | import javax.net.ssl.*; |
| | | import java.io.IOException; |
| | | import java.security.SecureRandom; |
| | | import java.security.cert.X509Certificate; |
| | | import java.util.Map; |
| | | import java.util.Optional; |
| | | import java.util.concurrent.TimeUnit; |
| | |
| | | */ |
| | | public class HttpHandler { |
| | | |
| | | private static final Integer DEFAULT_TIMEOUT_SECONDS = 5; |
| | | private static final Integer DEFAULT_TIMEOUT_SECONDS = 10; |
| | | private static final MediaType MEDIA_TYPE = MediaType.parse("application/json;charset=utf-8"); |
| | | |
| | | private String uri; |
| | |
| | | * POST请求执行 |
| | | * @return the HttpHandler response |
| | | */ |
| | | public String doPostCloseSSL() throws IOException { |
| | | Request request; |
| | | Request.Builder headerBuilder = new Request.Builder(); |
| | | if (headers != null && headers.size()>0){ |
| | | for (Map.Entry<String, Object> entry : headers.entrySet()){ |
| | | headerBuilder.addHeader(entry.getKey(), String.valueOf(entry.getValue())); |
| | | } |
| | | } |
| | | if (json == null || "".equals(json)){ |
| | | FormBody.Builder builder = new FormBody.Builder(); |
| | | for (Map.Entry<String, Object> entry : params.entrySet()){ |
| | | builder.add(entry.getKey(), String.valueOf(entry.getValue())); |
| | | } |
| | | FormBody body = builder.build(); |
| | | request = headerBuilder |
| | | .url((https?"https://":"http://")+uri+path) |
| | | .post(body) |
| | | .build(); |
| | | } else { |
| | | RequestBody body = RequestBody.create(MEDIA_TYPE, json); |
| | | Request.Builder builder = headerBuilder.url((https?"https://":"http://")+uri+path); |
| | | builder.header("Content-Type", "application/json;charset=UTF-8"); |
| | | request = builder.post(body).build(); |
| | | |
| | | } |
| | | Call call = getClientCloseSSL(timeout, timeUnit).newCall(request); |
| | | Response response = call.execute(); |
| | | return response.body().string(); |
| | | |
| | | } |
| | | |
| | | /** |
| | | * GET请求执行 |
| | | * @return the HttpHandler response |
| | | */ |
| | | public String doGetCloseSSL() throws IOException { |
| | | String url = paramsToUrl(uri, path, params, https); |
| | | Request.Builder headerBuilder = new Request.Builder(); |
| | | if (headers != null && headers.size()>0){ |
| | | for (Map.Entry<String, Object> entry : headers.entrySet()){ |
| | | headerBuilder.addHeader(entry.getKey(), String.valueOf(entry.getValue())); |
| | | } |
| | | } |
| | | Request request = headerBuilder.url(url).build(); |
| | | Response response = getClientCloseSSL(timeout, timeUnit).newCall(request).execute(); |
| | | return response.isSuccessful() ? response.body().string() : null; |
| | | } |
| | | |
| | | /** |
| | | * POST请求执行 |
| | | * @return the HttpHandler response |
| | | */ |
| | | public String doPost() throws IOException { |
| | | Request request; |
| | | Request.Builder headerBuilder = new Request.Builder(); |
| | |
| | | request = builder.post(body).build(); |
| | | |
| | | } |
| | | Call call = getClient(timeout, timeUnit).newCall(request); |
| | | Call call = getClientCloseSSL(timeout, timeUnit).newCall(request); |
| | | Response response = call.execute(); |
| | | return response.body().string(); |
| | | |
| | |
| | | } |
| | | |
| | | /** |
| | | * 获取 okHttpClient |
| | | * @return the HttpHandler instance |
| | | */ |
| | | private OkHttpClient getClientCloseSSL(Integer timeout, TimeUnit timeUnit){ |
| | | return new OkHttpClient |
| | | .Builder() |
| | | .sslSocketFactory(getSSLSocketFactory()) |
| | | .hostnameVerifier(getHostnameVerifier()) |
| | | .connectTimeout(timeout, timeUnit) |
| | | .readTimeout(timeout, timeUnit) |
| | | .build(); |
| | | } |
| | | |
| | | |
| | | /** |
| | | * description 忽略https证书验证 |
| | | * |
| | | * @author yanzy |
| | | * @version 1.0 |
| | | * @date 2021/9/8 14:42 |
| | | */ |
| | | private static TrustManager[] getTrustManager() { |
| | | TrustManager[] trustAllCerts = new TrustManager[]{ |
| | | new X509TrustManager() { |
| | | @Override |
| | | public void checkClientTrusted(X509Certificate[] chain, String authType) { |
| | | } |
| | | |
| | | @Override |
| | | public void checkServerTrusted(X509Certificate[] chain, String authType) { |
| | | } |
| | | |
| | | @Override |
| | | public X509Certificate[] getAcceptedIssuers() { |
| | | return new X509Certificate[]{}; |
| | | } |
| | | } |
| | | }; |
| | | return trustAllCerts; |
| | | } |
| | | /** |
| | | * description 忽略https证书验证 |
| | | * |
| | | * @author yanzy |
| | | * @version 1.0 |
| | | * @date 2021/9/8 14:42 |
| | | */ |
| | | public static HostnameVerifier getHostnameVerifier() { |
| | | HostnameVerifier hostnameVerifier = new HostnameVerifier() { |
| | | @Override |
| | | public boolean verify(String s, SSLSession sslSession) { |
| | | return true; |
| | | } |
| | | }; |
| | | return hostnameVerifier; |
| | | } |
| | | |
| | | /** |
| | | * description 忽略https证书验证 |
| | | *`在这里插入代码片` |
| | | * @author yanzy |
| | | * @version 1.0 |
| | | * @date 2021/9/8 14:42 |
| | | */ |
| | | public static SSLSocketFactory getSSLSocketFactory() { |
| | | try { |
| | | SSLContext sslContext = SSLContext.getInstance("SSL"); |
| | | sslContext.init(null, getTrustManager(), new SecureRandom()); |
| | | return sslContext.getSocketFactory(); |
| | | } catch (Exception e) { |
| | | throw new RuntimeException(e); |
| | | } |
| | | } |
| | | /** |
| | | * Http协议报文建造者 |
| | | */ |
| | | public static class Builder { |