HttpClient 4.5.2版本設置連接超時時間-CloseableHttpClient設置Timeout

HttpClient  4.5版本設置連接超時時間-CloseableHttpClient設置Timeout(區別於4.3.2)

 

HttpClient升級到4.5版本后，API有很多變化，HttpClient 4之后，API一直沒有太穩定，我感覺4.5版本抽象后，很多API應該快穩定了。

       使用HttpClient，一般都需要設置連接超時時間和獲取數據超時時間。這兩個參數很重要，目的是為了防止訪問其他http時，由於超時導致自己的應用受影響。

       4.5版本中，這兩個參數的設置都抽象到了RequestConfig中，由相應的Builder構建，具體的例子如下：

1.  
   CloseableHttpClient httpclient = HttpClients.createDefault();  
2.  
   HttpGet httpGet = new HttpGet("http://stackoverflow.com/");  
3.  
   RequestConfig requestConfig = RequestConfig.custom()  
4.  
           .setConnectTimeout(5000).setConnectionRequestTimeout(1000)  
5.  
           .setSocketTimeout(5000).build();  
6.  
   httpGet.setConfig(requestConfig);  
7.  
   CloseableHttpResponse response = httpclient.execute(httpGet);  
8.  
   System.out.println("得到的結果:" + response.getStatusLine());//得到請求結果  
9.  
   HttpEntity entity = response.getEntity();//得到請求回來的數據

setConnectTimeout：設置連接超時時間，單位毫秒。

setConnectionRequestTimeout：設置從connect Manager獲取Connection 超時時間，單位毫秒。這個屬性是新加的屬性，因為目前版本是可以共享連接池的。

setSocketTimeout：請求獲取數據的超時時間，單位毫秒。 如果訪問一個接口，多少時間內無法返回數據，就直接放棄此次調用。

===========================================

昨天遇到一個問題需要設置CloseableHttpClient的超時時間，查了官方文檔如下。

新建一個RequestConfig：

1.  
   RequestConfig defaultRequestConfig = RequestConfig.custom()
2.  
   .setSocketTimeout( 5000)
3.  
   .setConnectTimeout( 5000)
4.  
   .setConnectionRequestTimeout( 5000)
5.  
   .setStaleConnectionCheckEnabled( true)
6.  
   .build();

這個超時可以設置為客戶端級別，作為所有請求的默認值：

1.  
   CloseableHttpClient httpclient = HttpClients.custom()
2.  
   .setDefaultRequestConfig(defaultRequestConfig)
3.  
   .build();

Request不會繼承客戶端級別的請求配置，所以在自定義Request的時候，需要將客戶端的默認配置拷貝過去：

 

1.  
   HttpGet httpget = new HttpGet("http://www.apache.org/");
2.  
   RequestConfig requestConfig = RequestConfig.copy(defaultRequestConfig)
3.  
   .setProxy( new HttpHost("myotherproxy", 8080))
4.  
   .build();
5.  
   httpget.setConfig(requestConfig);

 倫理片 http://www.dotdy.com/  

4.3版本的超時是這樣的：

public static String httpPost(String url, String jsonString) {
    // 設置HTTP請求參數
String result = null;
    HttpClient httpClient = new DefaultHttpClient();
    HttpPost httpPost = new HttpPost(url);
    try {
        httpClient.getParams().setParameter(CoreConnectionPNames.CONNECTION_TIMEOUT, 10000);//設置請求超時時間 10s
StringEntity entity = new StringEntity(jsonString);
        entity.setContentEncoding("UTF-8");
        entity.setContentType("application/json");
        httpPost.setEntity(entity);
        HttpEntity resEntity = httpClient.execute(httpPost).getEntity();
        result = EntityUtils.toString(resEntity, "UTF-8");
    } catch (Exception e) {
        logger.error("http接口調用異常：url is::" + url, e);
        return null;
    } finally {
        httpClient.getConnectionManager().shutdown();
    }
    return result;
}

 

4.5.2版本是這樣的：

 public static String testTimeout(String url) {

        // 設置HTTP請求參數

        String result = null;

        CloseableHttpClient client = HttpClients.createDefault();

        HttpGet httpGet = new HttpGet(url);

        RequestConfig requestConfig = RequestConfig.custom()

                .setConnectTimeout(50000).setConnectionRequestTimeout(10000)

                .setSocketTimeout(50000).build();

        httpGet.setConfig(requestConfig);

        try {

            CloseableHttpResponse response = client.execute(httpGet);

            result = EntityUtils.toString(response.getEntity(), "UTF-8");

        } catch (ClientProtocolException e) {

            logger.error("http接口調用異常：url is::" + url, e);

            return null;

        } catch (Exception e) {

            logger.error("http接口調用異常：url is::" + url, e);

            return null;

        } finally {

            try {

                client.close();

            } catch (IOException e) {

                logger.error("http接口調用異常：url is::" + url, e);

            }

        }

        return result;

    }