BasicClientConnManager的無效使用：仍然分配的連接

Question

我正在調用REST URL並嘗試測量獲取響應所花費的時間。

我正在使用DefaultHttpClient來獲得REST URL的響應。

在我的下面的程序中，每個線程將在一個特定的範圍內工作。像每個線程將工作之間1 - 100和第二個線程將工作之間101 - 200等

SO在我的下面的代碼，它第一次工作正常。但第二次，是在這條線httpclient.execute拋出異常的第二次原樣

java.lang.IllegalStateException: Invalid use of BasicClientConnManager: connection still allocated. 
Make sure to release the connection before allocating another one. 

有什麼不對，我在這裏做什麼？ -

下面是我的代碼 -

class Task implements Runnable { 

    private DefaultHttpClient httpclient = new DefaultHttpClient(); 
    private HttpGet httpGet; 
    private HttpResponse response; 

    @Override 
    public void run() { 

     try { 

      httpGet = new HttpGet(
        "http://localhost:8080/service/BEService/v1/get/USERID=10000/profile.ACCOUNT.SERVICE 
      httpGet.getRequestLine(); 

      for (int userId = id; userId < id + noOfTasks; userId++) { 

        long start = System.nanoTime(); 

        response = httpclient.execute(httpGet); 

        long end = System.nanoTime() - start; 
       } 
     } catch (Exception e) { 
      LOG.error("Threw a Exception in " + getClass().getSimpleName(), e); 
     } 
    } 
} 

更新的代碼： -

如果我做它像這個 -

東西

class Task implements Runnable { 

    private DefaultHttpClient httpclient = new DefaultHttpClient(); 
    private HttpGet httpGet; 
    private HttpResponse response; 

    @Override 
    public void run() { 

     try { 

      for (int userId = id; userId < id + noOfTasks; userId++) { 

       httpGet = new HttpGet("http://localhost:8080/service/BEService/v1/get/USERID=10000/profile.ACCOUNT.SERVICE"); 
       httpGet.getRequestLine(); 

       long start = System.nanoTime(); 

       response = httpclient.execute(httpGet); 

       long end = System.nanoTime() - start; 

       HttpEntity entity = response.getEntity(); 
       EntityUtils.consume(entity); 
       } 
     } catch (Exception e) { 
      LOG.error("Threw a Exception in " + getClass().getSimpleName(), e); 
     } 
    } 
} 

那麼它是好還是不好？

Answer 1

我在這裏做什麼錯了？

是的。正如the docs說：

BasicClientConnectionManager是一個簡單的連接管理器， 保持在同一時間只有一個連接。即使這個類是 線程安全的，它應該只被一個執行線程使用。 BasicClientConnectionManager將努力重複使用 連接用於具有相同路由的後續請求。但是，如果持續連接的路由與連接請求的 不匹配，它將關閉現有連接併爲給定的 路由重新打開它。如果連接已經被分配了 ，則拋出java.lang.IllegalStateException。

默認情況下，HttpClient使用BasicClientConnectionManager。

請參閱"Multithreaded request execution"關於如何使用可以跨多個線程處理請求的pooling connection manager。

Answer 2

假設您使用的是香草DefaultHttpClient（內部使用BasicClientConnectionManager），您首先需要使用未完成/最後一個響應。

EntityUtils.consumeQuietly(httpResponse.getEntity());

否則，您可以重新分配，每次DefaultHttpClient。

來源：Workaround to not shutdown DefaultHttpClient() each time after usage

Answer 3

這是我使用RestTemplate池的連接管理器配置。它在5個併發線程中運行得非常好。

<!-- RestTemplate --> 
<beans:bean id="restTemplateYT" class="org.springframework.web.client.RestTemplate"> 
    <beans:constructor-arg ref="httpRequestFactoryYT" /> 
</beans:bean> 

<beans:bean id="httpRequestFactoryYT" class="org.springframework.http.client.HttpComponentsClientHttpRequestFactory"> 
    <beans:constructor-arg> 
     <beans:bean class="org.apache.http.impl.client.DefaultHttpClient"> 
      <beans:constructor-arg> 
       <beans:bean class="org.apache.http.impl.conn.PoolingClientConnectionManager"/> 
      </beans:constructor-arg> 
     </beans:bean> 
    </beans:constructor-arg> 
    <beans:property name="connectTimeout" value="5000" /> 
</beans:bean> 

Spring版本：3.1.0