2. 程式人生 > >HttpClient 傳送 HTTP、HTTPS 請求的簡單封裝

HttpClient 傳送 HTTP、HTTPS 請求的簡單封裝

阿新 • • 發佈：2018-12-20

序

最近這幾周，一直在忙同一個專案，剛開始是瞭解需求，需求有一定了解之後，就開始調第三方的介面。由於第三方給提供的文件很模糊，在調介面的時候，出了很多問題，一直在溝通協調，具體的無奈就不說了，由於介面的訪問協議是通過 HTTP 和 HTTPS 通訊的，因此封裝了一個簡單的請求工具類，由於時間緊迫，並沒有額外的時間對工具類進行優化和擴充套件，如果後續空出時間的話，我會對該工具類繼續進行優化和擴充套件的。

引用

首先說一下該類中需要引入的 jar 包，apache 的 httpclient 包，版本號為 4.5，如有需要的話，可以引一下。

程式碼

import org.apache.commons.io.IOUtils; import org.apache.http.HttpEntity; import org.apache.http.HttpResponse; import org.apache.http.HttpStatus; import org.apache.http.NameValuePair; import org.apache.http.client.HttpClient; import org.apache.http.client.config.RequestConfig; 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.ssl.SSLConnectionSocketFactory; import org.apache.http.conn.ssl.SSLContextBuilder; import org.apache.http.conn.ssl.TrustStrategy; import org.apache.http.conn.ssl.X509HostnameVerifier; import org.apache.http.entity.StringEntity; import org.apache.http.impl.client.CloseableHttpClient; import org.apache.http.impl.client.DefaultHttpClient; import org.apache.http.impl.client.HttpClients; import org.apache.http.impl.conn.PoolingHttpClientConnectionManager; import org.apache.http.message.BasicNameValuePair; import org.apache.http.util.EntityUtils;   import javax.net.ssl.SSLContext; import javax.net.ssl.SSLException; import javax.net.ssl.SSLSession; import javax.net.ssl.SSLSocket; import java.io.IOException; import java.io.InputStream; import java.nio.charset.Charset; import java.security.GeneralSecurityException; import java.security.cert.CertificateException; import java.security.cert.X509Certificate; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map;   /**  * HTTP 請求工具類  *  * @author : liii  * @version : 1.0.0  * @date : 2015/7/21  * @see : TODO  */ public class HttpUtil {     private static PoolingHttpClientConnectionManager connMgr;     private static RequestConfig requestConfig;     private static final int MAX_TIMEOUT = 7000;       static {         // 設定連線池         connMgr = new PoolingHttpClientConnectionManager();         // 設定連線池大小         connMgr.setMaxTotal(100);         connMgr.setDefaultMaxPerRoute(connMgr.getMaxTotal());           RequestConfig.Builder configBuilder = RequestConfig.custom();         // 設定連線超時         configBuilder.setConnectTimeout(MAX_TIMEOUT);         // 設定讀取超時         configBuilder.setSocketTimeout(MAX_TIMEOUT);         // 設定從連線池獲取連線例項的超時         configBuilder.setConnectionRequestTimeout(MAX_TIMEOUT);         // 在提交請求之前 測試連線是否可用         configBuilder.setStaleConnectionCheckEnabled(true);         requestConfig = configBuilder.build();     }       /**      * 傳送 GET 請求（HTTP），不帶輸入資料      * @param url      * @return      */     public static String doGet(String url) {         return doGet(url, new HashMap<String, Object>());     }       /**      * 傳送 GET 請求（HTTP），K-V形式      * @param url      * @param params      * @return      */     public static String doGet(String url, Map<String, Object> params) {         String apiUrl = url;         StringBuffer param = new StringBuffer();         int i = 0;         for (String key : params.keySet()) {             if (i == 0)                 param.append("?");             else                 param.append("&");             param.append(key).append("=").append(params.get(key));             i++;         }         apiUrl += param;         String result = null;         HttpClient httpclient = new DefaultHttpClient();         try {             HttpGet httpPost = new HttpGet(apiUrl);             HttpResponse response = httpclient.execute(httpPost);             int statusCode = response.getStatusLine().getStatusCode();               System.out.println("執行狀態碼 : " + statusCode);               HttpEntity entity = response.getEntity();             if (entity != null) {                 InputStream instream = entity.getContent();                 result = IOUtils.toString(instream, "UTF-8");             }         } catch (IOException e) {             e.printStackTrace();         }         return result;     }       /**      * 傳送 POST 請求（HTTP），不帶輸入資料      * @param apiUrl      * @return      */     public static String doPost(String apiUrl) {         return doPost(apiUrl, new HashMap<String, Object>());     }       /**      * 傳送 POST 請求（HTTP），K-V形式      * @param apiUrl API介面URL      * @param params 引數map      * @return      */     public static String doPost(String apiUrl, Map<String, Object> params) {         CloseableHttpClient httpClient = HttpClients.createDefault();         String httpStr = null;         HttpPost httpPost = new HttpPost(apiUrl);         CloseableHttpResponse response = null;           try {             httpPost.setConfig(requestConfig);             List<NameValuePair> pairList = new ArrayList<>(params.size());             for (Map.Entry<String, Object> entry : params.entrySet()) {                 NameValuePair pair = new BasicNameValuePair(entry.getKey(), entry                         .getValue().toString());                 pairList.add(pair);             }             httpPost.setEntity(new UrlEncodedFormEntity(pairList, Charset.forName("UTF-8")));             response = httpClient.execute(httpPost);             System.out.println(response.toString());             HttpEntity entity = response.getEntity();             httpStr = EntityUtils.toString(entity, "UTF-8");         } catch (IOException e) {             e.printStackTrace();         } finally {             if (response != null) {                 try {                     EntityUtils.consume(response.getEntity());                 } catch (IOException e) {                     e.printStackTrace();                 }             }         }         return httpStr;     }       /**      * 傳送 POST 請求（HTTP），JSON形式      * @param apiUrl      * @param json json物件      * @return      */     public static String doPost(String apiUrl, Object json) {         CloseableHttpClient httpClient = HttpClients.createDefault();         String httpStr = null;         HttpPost httpPost = new HttpPost(apiUrl);         CloseableHttpResponse response = null;           try {             httpPost.setConfig(requestConfig);             StringEntity stringEntity = new StringEntity(json.toString(),"UTF-8");//解決中文亂碼問題             stringEntity.setContentEncoding("UTF-8");             stringEntity.setContentType("application/json");             httpPost.setEntity(stringEntity);             response = httpClient.execute(httpPost);             HttpEntity entity = response.getEntity();             System.out.println(response.getStatusLine().getStatusCode());             httpStr = EntityUtils.toString(entity, "UTF-8");         } catch (IOException e) {             e.printStackTrace();         } finally {             if (response != null) {                 try {                     EntityUtils.consume(response.getEntity());                 } catch (IOException e) {                     e.printStackTrace();                 }             }         }         return httpStr;     }       /**      * 傳送 SSL POST 請求（HTTPS），K-V形式      * @param apiUrl API介面URL      * @param params 引數map      * @return      */     public static String doPostSSL(String apiUrl, Map<String, Object> params) {         CloseableHttpClient httpClient = HttpClients.custom().setSSLSocketFactory(createSSLConnSocketFactory()).setConnectionManager(connMgr).setDefaultRequestConfig(requestConfig).build();         HttpPost httpPost = new HttpPost(apiUrl);         CloseableHttpResponse response = null;         String httpStr = null;           try {             httpPost.setConfig(requestConfig);             List<NameValuePair> pairList = new ArrayList<NameValuePair>(params.size());             for (Map.Entry<String, Object> entry : params.entrySet()) {                 NameValuePair pair = new BasicNameValuePair(entry.getKey(), entry                         .getValue().toString());                 pairList.add(pair);             }             httpPost.setEntity(new UrlEncodedFormEntity(pairList, Charset.forName("utf-8")));             response = httpClient.execute(httpPost);             int statusCode = response.getStatusLine().getStatusCode();             if (statusCode != HttpStatus.SC_OK) {                 return null;             }             HttpEntity entity = response.getEntity();             if (entity == null) {                 return null;             }             httpStr = EntityUtils.toString(entity, "utf-8");         } catch (Exception e) {             e.printStackTrace();         } finally {             if (response != null) {                 try {                     EntityUtils.consume(response.getEntity());                 } catch (IOException e) {                     e.printStackTrace();                 }             }         }         return httpStr;     }       /**      * 傳送 SSL POST 請求（HTTPS），JSON形式      * @param apiUrl API介面URL      * @param json JSON物件      * @return      */     public static String doPostSSL(String apiUrl, Object json) {         CloseableHttpClient httpClient = HttpClients.custom().setSSLSocketFactory(createSSLConnSocketFactory()).setConnectionManager(connMgr).setDefaultRequestConfig(requestConfig).build();         HttpPost httpPost = new HttpPost(apiUrl);         CloseableHttpResponse response = null;         String httpStr = null;           try {             httpPost.setConfig(requestConfig);             StringEntity stringEntity = new StringEntity(json.toString(),"UTF-8");//解決中文亂碼問題             stringEntity.setContentEncoding("UTF-8");             stringEntity.setContentType("application/json");             httpPost.setEntity(stringEntity);             response = httpClient.execute(httpPost);             int statusCode = response.getStatusLine().getStatusCode();             if (statusCode != HttpStatus.SC_OK) {                 return null;             }             HttpEntity entity = response.getEntity();             if (entity == null) {                 return null;             }             httpStr = EntityUtils.toString(entity, "utf-8");         } catch (Exception e) {             e.printStackTrace();         } finally {             if (response != null) {                 try {                     EntityUtils.consume(response.getEntity());                 } catch (IOException e) {                     e.printStackTrace();                 }             }         }         return httpStr;     }       /**      * 建立SSL安全連線      *      * @return      */     private static SSLConnectionSocketFactory createSSLConnSocketFactory() {         SSLConnectionSocketFactory sslsf = null;         try {             SSLContext sslContext = new SSLContextBuilder().loadTrustMaterial(null, new TrustStrategy() {                   public boolean isTrusted(X509Certificate[] chain, String authType) throws CertificateException {                     return true;                 }             }).build();             sslsf = new SSLConnectionSocketFactory(sslContext, new X509HostnameVerifier() {                   @Override                 public boolean verify(String arg0, SSLSession arg1) {                     return true;                 }                   @Override                 public void verify(String host, SSLSocket ssl) throws IOException {                 }                   @Override                 public void verify(String host, X509Certificate cert) throws SSLException {                 }                   @Override                 public void verify(String host, String[] cns, String[] subjectAlts) throws SSLException {                 }             });         } catch (GeneralSecurityException e) {             e.printStackTrace();         }         return sslsf;     }         /**      * 測試方法      * @param args      */     public static void main(String[] args) throws Exception {       } }

相關推薦

HttpClient 傳送 HTTP、HTTPS 請求的簡單封裝

序 最近這幾周，一直在忙同一個專案，剛開始是瞭解需求，需求有一定了解之後，就開始調第三方的介面。由於第三方給提供的文件很模糊，在調介面的時候，出了很多問題，一直在溝通協調，具體的無奈就不說了，由於介面的訪問協議是通過 HTTP 和 HTTPS 通訊的，因此封裝了一個簡單的請

HttpClient 發送 HTTP、HTTPS 請求的簡單封裝

文檔 fault con load obj gpo n) content ble 序 近期這幾周。一直在忙同一個項目。剛開始是了解需求。需求有一定了解之後，就開始調第三方的接口。因為第三方給提供的文檔非常模糊，在調接口的

Charles抓web http、https請求，抓Android http、https請求

 為什麼要抓包？ 抓包：能幫助我們定位問題，是後端接口出現的問題，還是前段有問題 Windows下http請求 怎麼攔截請求? 選中要攔截的請求，滑鼠右鍵，點選breakpoints,設定斷點，即可攔截請求 下次再請求這個http路徑時，就自動跳出下面內容 怎麼修改請求 修改r

Java 傳送HTTP或HTTPS請求獲取網頁碼源（1）

閒來無事，封裝了一個簡單的工具類，用於向某個URL傳送請求並獲取響應的文字內容。傳送HTTP請求的方式比較簡單，但用來發送HTTPS請求卻不行的。 於是查了一些資料，根據前人經驗寫了這個工具類，能夠區分URL是HTTP型別還是HTTPS型別的，但對HTTPS方式的原理的研究尚淺，也只是拿

java傳送HTTP和HTTPS請求

HTTP請求沒什麼好說的，如果您將請求HTTPS請求，在開啟連結前請先繞過SSL驗證，如下為繞過驗證的工具類 package com.weavernorth.httpconn; import java.security.cert.CertificateE

HttpClient中post請求http、https示例

HttpClient中post請求http、https示例 【轉自https://www.cnblogs.com/Mr-Rocker/p/6229652.html】 點選加入QQ群 【】HttpClient 是 Apache Jakarta Common 下的子專案，可以

【Java工具七】java使用HttpClient的post請求http、https示例

package com.xxx.utils; import com.google.gson.Gson; import org.apache.commons.codec.binary.Base64; import org.apache.commons.httpclien

java中使用Apache HttpClient傳送Http請求，並獲取返回結果

傳送http請求可以寫成一個工具類，HttpClient可以使用連線池建立，這樣的好處是我們可以自己定義一些配置，比如請求超時時間，最大連線數等等。 public class HttpUtil { private static CloseableHttpClient http

HTTP傳送post、put請求，帶header、body的工具類，附呼叫測試demo

HTTP請求方法（可直接copy至你的工具類，屢試不爽） import com.alibaba.fastjson.JSONObject; import java.io.*; import java.ne

Java工具類--通過HttpClient傳送http請求

在寫網路程式的時候，經常會有從網址獲取資料的需求，上一篇解析JSON就需要從百度獲取天氣資料，本文介紹一種Java傳送http請求的工具–HttpClient。 ##HttpClient的介紹 The most essential function of Ht

JAVA傳送http get/post請求，呼叫http介面、方法

import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; impo

一個Https網站傳送Http的 ajax請求的解決方法

但是在https網站內傳送http的ajax請求報錯如下 可以看到是在https://127.0.0.1 請求http://kafka1:8080/api/hello便失敗。並且報錯 Mixed Content: The page at ‘https://1

httpclient傳送http請求設定網路超時時間

一、傳送的ApiClient方法 可以設定網路超時時間 /*** Eclipse Class Decompiler plugin, copyright (c) 2016 Chen Chao ([email protected]) ***/ pack

Android使用HttpClient以Post、Get請求伺服器傳送資料的方式（普通和json）

HttpParams params = new BasicHttpParams();//建立一個引數物件，用來儲存設定的各個引數 HttpProtocolParams.setContentCharset(params, "UTF-8");// 設定訊息所用的字符集 HttpProtocolParams.s

使用HttpClient 傳送 GET、POST、PUT、Delete請求及檔案上傳

  import java.io.File;  import java.io.IOException;    import java.io.UnsupportedEncodingException;    import java.nio.charset.Charset;  i

使用Retrofit進行Http、Https網路請求（快速上手）

1.配置gradle //註解包 compile 'com.jakewharton:butterknife:7.0.0' //Retrofit2所需要的包//這裡需要值得注意的是匯入的retrofit2包的版本必須要一致，否則就會報錯compile 'com.squareu

Java-簡單的 傳送http get/post請求 呼叫介面/方法

例子如下：1.請求引數srequestUrl 是你要傳送的介面引數用map 存起來 sRet 是返回值 如果傳送的介面有的話就寫 然後呼叫 NetUtils.requset請求 （介面，引數，get/post（選擇一種傳送方式））String sRequestUrl ="ht

使用User-Agent防止HttpClient傳送http請求時403 Forbidden和安全攔截

最近在訪問一個介面的時候被拒絕了。具體資訊如下 我們用程式訪問我的csdn部落格地址 解決方案就是在httpclient發出請求的時候在Header中設定一個User-Agent 具體如下 String userAgent = "Mozilla/

Android系列之網路（一）----使用HttpClient傳送HTTP請求（通過get方法獲取資料）

轉載地址：http://www.cnblogs.com/smyhvae/p/4004983.html  這個關於http的內容寫的比較好 一、HTTP協議初探： HTTP（Hypertext Transfer Protocol）中文 “超文字傳輸協議”，是一種為分散式，

Android系列之網路（三）----使用HttpClient傳送HTTP請求（分別通過GET和POST方法傳送資料）

 【正文】 在前兩篇文章中，我們學習到了和HTTP相關的基礎知識。文章連結如下： 一、GET和POST的對比： 在漫長的時間當中，其他的方法逐漸的退出了歷史舞臺，最常用的只剩下GET和POST方法。而之前已經講過了通過GET方法獲取資料，今天來學習一下如何分別通過