Exception à l'aide de HttpRequest.execute(): Invalid use of SingleClientConnManager: connexion continue d'être affectée

Vous avez besoin de consommer le corps de la réponse avant de pouvoir réutiliser la connexion pour une autre demande. Vous ne devriez pas seulement de lire l'état de la réponse, mais lire la réponse InputStream entièrement pour le dernier octet de laquelle vous ignorez les octets lus.

Une exception similaire message (depuis au moins Apache Jarkata Communes Client HTTP 4.2) est:

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

Cette exception peut se produire lorsque deux ou plusieurs threads interagir avec un seul org.apache.http.impl.client.DefaultHttpClient.

Comment pouvez-vous faire un 4.2 DefaultHttpClient instance de thread-safe (des threads dans le sens où deux ou plusieurs threads peuvent interagir avec elle, sans obtenir au-dessus de message d'erreur)? Fournir DefaultHttpClient avec une connexion de mise en commun des ClientConnectionManager dans la forme de org.apache.http.impl.conn.PoolingClientConnectionManager!

/* using
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
<version>4.2.2</version>
</dependency>
*/
import org.apache.http.HttpResponse;
import org.apache.http.HttpStatus;
import org.apache.http.params.HttpConnectionParams;
import org.apache.http.client.HttpClient;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.impl.conn.PoolingClientConnectionManager;
import org.apache.http.impl.conn.SchemeRegistryFactory;
import org.apache.http.params.HttpParams;
import org.apache.http.client.methods.HttpGet;
public class MyComponent {
private HttpClient client;
{
PoolingClientConnectionManager conMan = new PoolingClientConnectionManager( SchemeRegistryFactory.createDefault() );
conMan.setMaxTotal(200);
conMan.setDefaultMaxPerRoute(200);
client = new DefaultHttpClient(conMan);
//The following parameter configurations are not
//neccessary for this example, but they show how
//to further tweak the HttpClient
HttpParams params = client.getParams();
HttpConnectionParams.setConnectionTimeout(params, 20000);
HttpConnectionParams.setSoTimeout(params, 15000);
}
//This method can be called concurrently by several threads
private InputStream getResource(String uri) {
try {
HttpGet method = new HttpGet(uri);
HttpResponse httpResponse = client.execute(method);
int statusCode = httpResponse.getStatusLine().getStatusCode();
InputStream is = null;
if (HttpStatus.SC_OK == statusCode) {
logger.debug("200 OK Amazon request");
is = httpResponse.getEntity().getContent();
} else {
logger.debug("Something went wrong, statusCode is {}",
statusCode);
EntityUtils.consume(httpResponse.getEntity());
}
return is;
} catch (Exception e) {
logger.error("Something went terribly wrong", e);
throw new RuntimeException(e);
}
}
}

J'ai eu le même problème avec un jax-rs (resteasy) Response objet dans mes tests unitaires.
J'ai résolu ce problème avec un appel à response.releaseConnection();
Le releaseConnection()-Méthode est uniquement sur le resteasy ClientResponse objet, donc j'ai dû ajouter un cast de Response à ClientResponse.

Essayer cette

HttpResponse response = Client.execute(httpGet);
response.getEntity().consumeContent();
StatusLine statusLine = response.getStatusLine();
int statusCode = statusLine.getStatusCode();
if (statusCode == 200) {
//task
Log.i("Connection", "OK");
}else{
Log.i("Connection", "Down");
}