Исключение с использованием HttpRequest.execute(): недопустимое использование SingleClientConnManager: соединение все еще выделено

Вам необходимо использовать тело ответа, прежде чем вы сможете повторно использовать соединение для другого запроса. Вы должны не только прочитать статус ответа, но и прочитать ответ InputStream полностью до последнего байта, при этом вы просто игнорируете прочитанные байты.

Я столкнулся с аналогичной проблемой при использовании HttpClient с Jetty для создания тестовой среды. Мне пришлось создать несколько запросов к Servlet от моего клиента, но при выполнении он выдавал одно и то же исключение.

Я нашел альтернативу на http://foo.jasonhudgins.com/2010/03/http-connections-revisited.html

Вы также можете использовать следующий метод для создания экземпляра вашего клиента.

public static DefaultHttpClient getThreadSafeClient()  {

    DefaultHttpClient client = new DefaultHttpClient();
    ClientConnectionManager mgr = client.getConnectionManager();
    HttpParams params = client.getParams();
    client = new DefaultHttpClient(new ThreadSafeClientConnManager(params, 

            mgr.getSchemeRegistry()), params);
    return client;
}

Аналогичное сообщение об исключении (по крайней мере, начиная с HTTP-клиента Apache Jarkata Commons 4.2):

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

Это исключение может произойти, когда два или более потока взаимодействуют с одним org.apache.http.impl.client.DefaultHttpClient.

Как можно сделать экземпляр 4.2 DefaultHttpClient потокобезопасным (потокобезопасным в том смысле, что два или более потока могут взаимодействовать с ним, не получая сообщения об ошибке выше)? Предоставьте DefaultHttpClient пул соединений ClientConnectionManager в виде 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);
        }
    }
}

Это часто задаваемый вопрос. Ответ BalusC правильный. Уловите HttpReponseException и вызовите HttpResponseException.ответ.игнорировать(). Если вам нужно прочитать сообщение об ошибке, используйте response.parseAsString(), если вы не знаете тип содержимого ответа, иначе, если вы знаете тип содержимого, используйте response.parseAs(MyType.class).

Простой фрагмент кода из YouTubeSample.java в youtube-jsonc-sample (хотя обычно вы хотите сделать что-то умнее в реальном приложении):

  } catch (HttpResponseException e) {
    System.err.println(e.response.parseAsString());
  }

Полное раскрытие: я являюсь владельцем google-api-java-client проект.

У меня была такая же проблема с объектом Response jax-rs (resteasy) в моих модульных тестах. Я решил эту проблему вызовом response.releaseConnection();. Метод releaseConnection() применим только к неактивному объекту ClientResponse, поэтому мне пришлось добавить приведение от Response к ClientResponse.

Попробуй это

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

Хорошо, у меня похожая проблема, все эти решения не работают, я тестировал на каком-то устройстве, проблема была в дате в устройстве, это был 2011 год вместо 2013 года, проверьте также, это может помочь.

Прочитайте InputStream следующим образом:

if( response.getStatusLine().getStatusCode() == 200 ) {
    HttpEntity entity = response.getEntity();
    InputStream content = entity.getContent();
    try {
        sb = new StringBuilder();
        BufferedReader bufferedReader = new BufferedReader( new InputStreamReader( content ), 8 );
        String line;
        while( ( line = bufferedReader.readLine() ) != null ) {
            sb.append( line );
        }
        bufferedReader.close();
        content.close();
    } catch( Exception ex ) {
        Log.e( "statusCode", ex.getMessage() + "" );
    }
}

просто используйте ответ, как показано ниже, это решит проблему

response.getEntity().consumeContent();