Освобождение соединения HttpClient 4.1.x для последовательного выполнения с одним экземпляром HttpClient - PullRequest
1 голос
/ 19 августа 2011

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

Неправильное использование SingleClientConnManager: соединение все еще выделено

public String detectGooglePost(String text) throws SystemException {

        List<NameValuePair> qParams = new ArrayList<NameValuePair>();
        qParams.add(new BasicNameValuePair("key", key));

        List<NameValuePair> bodyParams = new ArrayList<NameValuePair>();
        bodyParams.add(new BasicNameValuePair("q", text));

        HttpPost httpPost = new HttpPost(createURI(qParams));
        httpPost.addHeader("X-HTTP-Method-Override", "GET");
        try {
            httpPost.setEntity(new UrlEncodedFormEntity(bodyParams));
        } catch (UnsupportedEncodingException e) {
            throw new SystemException("Problem when buidling Google request entity", e);
        }

        String language = getLanguage(httpPost);
        return language;
    }

    private String getLanguage(HttpUriRequest request) throws SystemException {

        HttpResponse response;
        try {
            response = httpclient.execute(request);
        } catch (Exception e) {
            throw new SystemException("Problem when executing Google request", e);
        }

        int sc = response.getStatusLine().getStatusCode();
        if (sc != HttpStatus.SC_OK)
            throw new SystemException("google status code : " + sc);

        StringBuilder builder = getBuilder(response);
        String language = processJson(builder.toString());

        return language;
    }

    private StringBuilder getBuilder(HttpResponse response) throws SystemException {
        HttpEntity entity = response.getEntity();
        if (entity == null)
            throw new SystemException("response entity null");

        StringBuilder builder = new StringBuilder();
        BufferedReader in = null;
        String str;
        try {
            in = new BufferedReader(new InputStreamReader(entity.getContent()));
            while ((str = in.readLine()) != null)
                builder.append(str);
        } catch (IOException e) {
            throw new SystemException("Reading input stream of http google response entity problem", e);
        } finally {
                    IOUtils.closeQuietly(in);
        }
        if (builder.length() == 0)
            throw new SystemException("content stream of response entity empty has zero length");
        return builder;
    }

Как следуетЯ освобождаю связь?Поток читается и закрывается.Но при повторном вызове метода detectGooglePost (text) (singleton-экземпляр HttpClient) эта ошибка выдается.

1 Ответ

1 голос
/ 20 августа 2011

Человек это должно работать, попробуйте это:

    HttpResponse response;
    String responseBody;
    try {
        response = httpclient.execute(request);
        int sc = response.getStatusLine().getStatusCode();
        if (sc != HttpStatus.SC_OK)
            throw new SystemException("google status code : " + sc);

        HttpEntity entity = response.getEntity();
        if (entity == null)
            throw new SystemException("response entity null");
        responseBody = EntityUtils.toString(entity);
    } catch (Exception e) {
        request.abort();
        throw new SystemException("Problem when executing Google request", e);
    }
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...