Http第三方调用接口类

柔光的暖阳◎ 2022-10-07 14:47 230阅读 0赞

public class HttpClientUtils {
    
        // 链接相关参数
        private static int socketTimeout = 15000;
        private static int connectTimeout = 15000;
        private static int connectionRequestTimeout = 15000;
        private static RequestConfig requestConfig = null;
        // 连接池相关参数
        private static int connMgrMaxTotal = 100;
        private static int connMgrMaxPerRoute = 50;
        private static PoolingHttpClientConnectionManager connMgr = null;
    
        static {
            requestConfig = RequestConfig.custom().setSocketTimeout(socketTimeout).setConnectTimeout(connectTimeout).setConnectionRequestTimeout(connectionRequestTimeout).build();
            connMgr = new PoolingHttpClientConnectionManager();
            connMgr.setDefaultMaxPerRoute(connMgrMaxPerRoute);
            connMgr.setMaxTotal(connMgrMaxTotal);
        }
    
    
        private static String doHttp(HttpRequestBase httpRequestBase) {
            CloseableHttpClient httpClient = null;
            CloseableHttpResponse response = null;
            String responseContent = null;
    
            try {
                // 创建默认的httpClient实例.
                String scheme = httpRequestBase.getURI().getScheme();
                if (scheme.equalsIgnoreCase("https")) {
                    PublicSuffixMatcher publicSuffixMatcher = PublicSuffixMatcherLoader.load(new URL(httpRequestBase.getURI().toString()));
                    DefaultHostnameVerifier hostnameVerifier = new DefaultHostnameVerifier(publicSuffixMatcher);
                    httpClient = HttpClients.custom().setSSLHostnameVerifier(hostnameVerifier).setConnectionManager(connMgr).build();
                } else if (scheme.equalsIgnoreCase("http")) {
                    httpClient = HttpClients.custom().setConnectionManager(connMgr).build();
                } else {
                    throw new IllegalArgumentException("url的scheme错误，必须是http或者https！ ");
                }
                httpRequestBase.setConfig(requestConfig);
                // 执行请求
                response = httpClient.execute(httpRequestBase);
                // 如果这里有必要获取的是其他资料都可以在这里进行逻辑处理
                responseContent = EntityUtils.toString(response.getEntity(), "UTF-8");
                return responseContent;
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                try {
                    if (response != null) {
                        response.close();
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
    
            return responseContent;
        }
    
    
        /**
         * sendHttpGet(url)
         * @param url
         * @return
         */
        public static String sendHttpGet(String url) {
            return doHttp(new HttpGet(url));
        }
    
    
        /**
         * sendHttpGet(url)
         * @param url
         * @return
         */
        public static String sendHttpWithHeaderGet(String url,Map<String,String> headers) {
            HttpGet httpGet = new HttpGet(url);
            if (headers != null){
                for (String key : headers.keySet()){
                    httpGet.setHeader(key,headers.get(key));
                }
            }
            return doHttp(httpGet);
        }
    
        /**
         * sendHttpGet()
         * @param url
         * @param param key1=value1&key2=value2&key3=value3
         * @return
         */
        public static String sendHttpGet(String url, String param) {
            HttpGet httpGet = new HttpGet(url + '?' + param);
            return doHttp(httpGet);
        }
    
        /**
         * sendHttpPost()
         * @param url
         * @param param key1=value1&key2=value2&key3=value3
         * @return
         */
        public static String sendHttpPost(String url, String param) {
            HttpPost httpPost = new HttpPost(url);
            try {
                StringEntity stringEntity = new StringEntity(param, "UTF-8");
                stringEntity.setContentType("application/x-www-form-urlencoded");
                httpPost.setEntity(stringEntity);
            } catch (Exception e) {
                e.printStackTrace();
            }
    
            return doHttp(httpPost);
        }
    
        /**
         * sendHttpGet
         * @param url
         * @param param 是个map<String, String>
         * @return
         */
        public static String sendHttpGet(String url, Map<String, String> param) {
            String paramStr = "";
            for (String key : param.keySet()) {
                String tmp = "";
                tmp = "&" + key + "=" + param.get(key);
                paramStr += tmp;
            }
            paramStr = paramStr.substring(1);
            HttpGet httpGet = new HttpGet(url + '?' + paramStr);
    
            return doHttp(httpGet);
        }
    
        /**
         * sendHttpPost
         * @param url
         * @param param 是个map<String,String>
         * @return
         */
        public static String sendHttpPost(String url, Map<String, String> param) {
            HttpPost httpPost = new HttpPost(url);
            List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>();
            for (String key : param.keySet()) {
                nameValuePairs.add(new BasicNameValuePair(key, param.get(key)));
            }
            try {
                httpPost.setEntity(new UrlEncodedFormEntity(nameValuePairs, "UTF-8"));
            } catch (Exception e) {
                e.printStackTrace();
            }
    
            return doHttp(httpPost);
        }
    
        public static String sendHttpPostJson(String url, String json) {
            HttpPost httpPost = new HttpPost(url);
            try {
                StringEntity stringEntity = new StringEntity(json, ContentType.create("application/json", "UTF-8"));
                httpPost.setEntity(stringEntity);
            } catch (Exception e) {
                e.printStackTrace();
            }
    
            return doHttp(httpPost);
        }
    
    
        public static String sendHttpPostJsonWithHeader(String url, String json,Map<String,String> headers) {
            HttpPost httpPost = new HttpPost(url);
            try {
                if (headers != null){
                    for (String key : headers.keySet()){
                        httpPost.setHeader(key,headers.get(key));
                    }
                }
                StringEntity stringEntity = new StringEntity(json, ContentType.create("application/json", "UTF-8"));
                httpPost.setEntity(stringEntity);
            } catch (Exception e) {
                e.printStackTrace();
            }
            return doHttp(httpPost);
        }
    
    }