Uso non valido di BasicClientConnManager: connessione ancora allocata

Question

Sto effettuando una chiamata all'URL REST e cercando di misurare quanto tempo è necessario per ottenere la risposta.

Sto utilizzando DefaultHttpClient per ottenere la risposta dal REST URL.

Nel mio programma di seguito, ogni thread lavorerà su un determinato intervallo. Come ogni thread funzionerà tra 1 - 100 e il secondo thread funzionerà tra 101 - 200 ecc.

SO nel mio codice qui sotto, per la prima volta funziona bene. Ma per la seconda volta, si sta gettando eccezione su questa linea httpclient.execute per la seconda volta as-

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

qualcosa che non va che sto facendo qui? -

Qui di seguito è la mia code-

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); 
     } 
    } 
} 

Codice aggiornato: -

Se lo faccio qualcosa come questo-

012.351.

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); 
     } 
    } 
} 

quindi va bene o no?

Answer 1

C'è qualcosa di sbagliato che sto facendo qui?

Sì. Come indicato nel the docs:

BasicClientConnectionManager è una semplice gestione connessione che mantiene una sola connessione alla volta. Anche se questa classe è thread-safe, dovrebbe essere utilizzata solo da un thread di esecuzione. BasicClientConnectionManager si impegna a riutilizzare la connessione per le richieste successive con lo stesso percorso. Sarà, , tuttavia, chiudere la connessione esistente e riaprirla per il dato itinerario , se il percorso della connessione persistente non corrisponde a quello della richiesta di connessione. Se la connessione è già stata assegnata a , viene lanciata java.lang.IllegalStateException.

BasicClientConnectionManager viene utilizzato da HttpClient per impostazione predefinita.

Vedi "Multithreaded request execution" su come utilizzare un pooling connection manager in grado di gestire le richieste in più thread.

Answer 2

Supponendo che si stia utilizzando la vaniglia DefaultHttpClient (che utilizza BasicClientConnectionManager internamente), è necessario prima consumare la risposta in sospeso/ultima.

EntityUtils.consumeQuietly(httpResponse.getEntity());

Altrimenti, è possibile riallocare DefaultHttpClient ogni volta.

Fonte: Workaround to not shutdown DefaultHttpClient() each time after usage

Answer 3

Questa è la mia configurazione per RestTemplate utilizzo piscina connection manager. Funziona molto bene in altri 5 thread simultanei.

<!-- 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> 

versione Primavera: 3.1.0