http https工具

作者: FIRE_d559 | 来源:发表于2018-08-30 18:32 被阅读0次

为了应付在web项目中调用其他http或https接口的需求，本文根据此文章部分内容改写为以下两个发起http以及https请求的工具类

引用工具前须导入依赖

      <dependency>
          <groupId>org.apache.httpcomponents</groupId>
          <artifactId>httpclient</artifactId>
          <version>4.5.5</version>
      </dependency>
      <!-- https://mvnrepository.com/artifact/org.apache.httpcomponents/httpmime -->
      <dependency>
          <groupId>org.apache.httpcomponents</groupId>
          <artifactId>httpmime</artifactId>
          <version>4.5.5</version>
      </dependency>

Http工具：

    public class HttpUtils {
    private static final CloseableHttpClient httpclient = HttpClients.createDefault();
    private static String  charset="utf-8";
    private static  String userAgent = "Mozilla/5.0 (Windows NT 6.2; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/54.0.2840.87 Safari/537.36";
    private static int socketTimeout=2000;
    private static int connectTimeout=2000;


    /**参数直接附在url上
     * @param url
     * @return String
     */
    public static String sendGet(String url) {
        return excuteHttpGet(url);
    }

    /**
     * map参数形式
     * @param url
     * @param params
     * @return String
     */
    public static String sendGet(String url,Map<String,String> params){
        url+="?";
        for (String key:params.keySet()) {
            url+=key+"="+params.get(key)+"&";
        }
        return excuteHttpGet(url);
    }

    /**
     * 发送HttpPost请求
     * @param url
     * @param map 参数
     * @return String
     */
    public static String sendPost(String url, Map<String, String> map) {
        // 设置参数
        List<NameValuePair> formparams = new ArrayList<NameValuePair>();
        for (Map.Entry<String, String> entry : map.entrySet()) {
            formparams.add(new BasicNameValuePair(entry.getKey(), entry.getValue()));
        }
        // 编码
        UrlEncodedFormEntity formEntity = new UrlEncodedFormEntity(formparams, Consts.UTF_8);
        // 取得HttpPost对象
        HttpPost httpPost = new HttpPost(url);
        // 防止被当成攻击添加的
        httpPost.setHeader("User-Agent", userAgent);
        // 参数放入Entity
        httpPost.setEntity(formEntity);
        return excuteHttpPost(httpPost);
    }

    /**发送HttpPost请求
     * @param url
     * @param file 参数为文件
     * @return String
     */
    public static String sendPost(String url, File file) {
        HttpPost httpPost = new HttpPost(url);
        // 防止被当成攻击添加的
        httpPost.setHeader("User-Agent", userAgent);
        MultipartEntityBuilder multipartEntity = MultipartEntityBuilder.create();
        multipartEntity.setMode(HttpMultipartMode.BROWSER_COMPATIBLE);
        multipartEntity.addPart("media", new FileBody(file));
        httpPost.setEntity(multipartEntity.build());
        return excuteHttpPost(httpPost);
    }
    /**
     * 发送HttpPost请求
     * @param url
     * @param jsonStr 参数为json字符串
     * @return String
     */
    public static String sendPost(String url, String jsonStr) {
        // 字符串编码
        StringEntity entity = new StringEntity(jsonStr, Consts.UTF_8);
        // 设置content-type
        entity.setContentType("application/json");
        HttpPost httpPost = new HttpPost(url);
        // 防止被当成攻击添加的
        httpPost.setHeader("User-Agent", userAgent);
        // 接收参数设置
        httpPost.setHeader("Accept", "application/json");
        httpPost.setEntity(entity);
        return excuteHttpPost(httpPost);
    }
    /**
     * 发送不带参数的HttpPost请求
     * @param url
     * @return String
     */
    public static String sendPost(String url) {
        // 得到一个HttpPost对象
        HttpPost httpPost = new HttpPost(url);
        // 防止被当成攻击添加的
        httpPost.setHeader("User-Agent", userAgent);
        return excuteHttpPost(httpPost);
    }

    /**
     * httpPost公用方法
     * @param httpPost
     * @return
     */
    private static  String excuteHttpPost(HttpPost httpPost){
        CloseableHttpResponse response = null;
        String result = null;
        RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(socketTimeout).setConnectTimeout(connectTimeout).build();//设置请求和传输超时时间
        httpPost.setConfig(requestConfig);
        try {
            // 执行post请求
            response = httpclient.execute(httpPost);
            // 得到entity
            HttpEntity entity = response.getEntity();
            // 得到字符串
            if (entity != null) {
                result = EntityUtils.toString(entity,charset);
            }
        } catch (IOException e) {
            System.out.println("IO异常："+e.getMessage());
        } finally {
            if (response != null) {
                try {
                    response.close();
                } catch (IOException e) {
                    System.out.println("关闭Response对象出现异常："+e.getMessage());
                }
            }
        }
        return result;
    }
    private static String excuteHttpGet(String url){
        String result=null;
        CloseableHttpResponse response = null;
        try {
            HttpGet httpGet = new HttpGet(url);
            httpGet.setHeader("User-Agent", userAgent);
            RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(socketTimeout).setConnectTimeout(connectTimeout).build();//设置请求和传输超时时间
            httpGet.setConfig(requestConfig);
            response = httpclient.execute(httpGet);
            HttpEntity entity = response.getEntity();
            if (entity != null) {
                result = EntityUtils.toString(entity,charset);
            }
        } catch (Exception e) {
            System.out.println(e.getMessage());
        } finally {
            if (response != null) {
                try {
                    response.close();
                } catch (IOException e) {
                    System.out.println("关闭Response对象出现异常："+e.getMessage());
                }
            }
        }
        return result;
    }

    /**
     * 默认utf-8
     * @param charset
     */
    public static void setCharset(String charset) {
        HttpUtils.charset = charset;
    }
    public static void setUserAgent(String userAgent) {
        HttpUtils.userAgent = userAgent;
    }

    /**
     * 默认2秒
     * @param socketTimeout
     */
    public static void setSocketTimeout(int socketTimeout) {
        HttpUtils.socketTimeout = socketTimeout;
    }

    /**
     * 默认2秒
     * @param connectTimeout
     */
    public static void setConnectTimeout(int connectTimeout) {
        HttpUtils.connectTimeout = connectTimeout;
    }
}

Https工具类:

    public class HttpsUtils {
    private static final CloseableHttpClient httpsclient = createSSLClientDefault();
    private static String  charset="utf-8";
    private static  String userAgent = "Mozilla/5.0 (Windows NT 6.2; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/54.0.2840.87 Safari/537.36";
    private static int socketTimeout=2000;//超时时间
    private static int connectTimeout=2000; //超时时间

    public static CloseableHttpClient createSSLClientDefault(){
        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 (KeyManagementException e) {
            e.printStackTrace();
        } catch (NoSuchAlgorithmException e) {
            e.printStackTrace();
        } catch (KeyStoreException e) {
            e.printStackTrace();
        }
        return HttpClients.createDefault();
    }



    /**参数直接附在url上
     * @param url
     * @return String
     */
    public static String sendGet(String url) {
        return excuteHttpGet(url);
    }

    /**
     * map参数形式
     * @param url
     * @param params
     * @return String
     */
    public static String sendGet(String url,Map<String,String> params){
        url+="?";
        for (String key:params.keySet()) {
            url+=key+"="+params.get(key)+"&";
        }
        return excuteHttpGet(url);
    }

    /**
     * 发送HttpPost请求
     * @param url
     * @param map 参数
     * @return String
     */
    public static String sendPost(String url, Map<String, String> map) {
        // 设置参数
        List<NameValuePair> formparams = new ArrayList<NameValuePair>();
        for (Map.Entry<String, String> entry : map.entrySet()) {
            formparams.add(new BasicNameValuePair(entry.getKey(), entry.getValue()));
        }
        // 编码
        UrlEncodedFormEntity formEntity = new UrlEncodedFormEntity(formparams, Consts.UTF_8);
        // 取得HttpPost对象
        HttpPost httpPost = new HttpPost(url);
        // 防止被当成攻击添加的
        httpPost.setHeader("User-Agent", userAgent);
        // 参数放入Entity
        httpPost.setEntity(formEntity);
        return excuteHttpPost(httpPost);
    }

    /**发送HttpPost请求
     * @param url
     * @param file 参数为文件
     * @return String
     */
    public static String sendPost(String url, File file) {
        HttpPost httpPost = new HttpPost(url);
        // 防止被当成攻击添加的
        httpPost.setHeader("User-Agent", userAgent);
        MultipartEntityBuilder multipartEntity = MultipartEntityBuilder.create();
        multipartEntity.setMode(HttpMultipartMode.BROWSER_COMPATIBLE);
        multipartEntity.addPart("media", new FileBody(file));
        httpPost.setEntity(multipartEntity.build());
        return excuteHttpPost(httpPost);
    }
    /**
     * 发送HttpPost请求
     * @param url
     * @param jsonStr 参数为json字符串
     * @return String
     */
    public static String sendPost(String url, String jsonStr) {
        // 字符串编码
        StringEntity entity = new StringEntity(jsonStr, Consts.UTF_8);
        // 设置content-type
        entity.setContentType("application/json");
        HttpPost httpPost = new HttpPost(url);
        // 防止被当成攻击添加的
        httpPost.setHeader("User-Agent", userAgent);
        // 接收参数设置
        httpPost.setHeader("Accept", "application/json");
        httpPost.setEntity(entity);
        return excuteHttpPost(httpPost);
    }
    /**
     * 发送不带参数的HttpPost请求
     * @param url
     * @return String
     */
    public static String sendPost(String url) {
        // 得到一个HttpPost对象
        HttpPost httpPost = new HttpPost(url);
        // 防止被当成攻击添加的
        httpPost.setHeader("User-Agent", userAgent);
        return excuteHttpPost(httpPost);
    }

    /**
     * httpPost公用方法
     * @param httpPost
     * @return
     */
    private static  String excuteHttpPost(HttpPost httpPost){
        CloseableHttpResponse response = null;
        String result = null;
        RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(socketTimeout).setConnectTimeout(connectTimeout).build();//设置请求和传输超时时间
        httpPost.setConfig(requestConfig);
        try {
            // 执行post请求
            response = httpsclient.execute(httpPost);
            // 得到entity
            HttpEntity entity = response.getEntity();
            // 得到字符串
            if (entity != null) {
                result = EntityUtils.toString(entity,charset);
            }
        } catch (IOException e) {
            System.out.println("IO异常："+e.getMessage());
        } finally {
            if (response != null) {
                try {
                    response.close();
                } catch (IOException e) {
                    System.out.println("关闭Response对象出现异常："+e.getMessage());
                }
            }
        }
        return result;
    }
    private static String excuteHttpGet(String url){
        String result=null;
        CloseableHttpResponse response = null;
        try {
            HttpGet httpGet = new HttpGet(url);
            httpGet.setHeader("User-Agent", userAgent);
            RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(socketTimeout).setConnectTimeout(connectTimeout).build();//设置请求和传输超时时间
            httpGet.setConfig(requestConfig);
            response = httpsclient.execute(httpGet);
            HttpEntity entity = response.getEntity();
            if (entity != null) {
                result = EntityUtils.toString(entity,charset);
            }
        } catch (Exception e) {
            System.out.println(e.getMessage());
        } finally {
            if (response != null) {
                try {
                    response.close();
                } catch (IOException e) {
                    System.out.println("关闭Response对象出现异常："+e.getMessage());
                }
            }
        }
        return result;
    }

    /**
     * 默认utf-8
     * @param charset
     */
    public static void setCharset(String charset) {
        HttpsUtils.charset = charset;
    }
    public static void setUserAgent(String userAgent) {
        HttpsUtils.userAgent = userAgent;
    }

    /**
     * 默认2秒
     * @param socketTimeout
     */
    public static void setSocketTimeout(int socketTimeout) {
        HttpsUtils.socketTimeout = socketTimeout;
    }

    /**
     * 默认2秒
     * @param connectTimeout
     */
    public static void setConnectTimeout(int connectTimeout) {
        HttpsUtils.connectTimeout = connectTimeout;
    }
}

<center> Coding Blog Github Blog </center>

http https工具

相关文章

网友评论

延伸阅读

深度阅读

栏目导航

热点阅读