无效使用BasicClientConnManager：仍分配连接

Question

我正在打电话给REST URL，并试图衡量恢复响应所花费的时间。

我DefaultHttpClient为此目的是要从获得回复REST URL。

在下面的程序中，每个线程将在特定范围内工作。就像每个线程将在1 - 100第二个线程之间工作，101 - 200等等。

因此，在我下面的代码中，它第一次正常工作。但是，这是第二次在该行上抛出异常，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

我在这里做错什么吗？

是。如文档所述：

BasicClientConnectionManager是一个简单的连接管理器，一次仅维护一个连接。即使此类是线程安全的，也应仅由一个执行线程使用。BasicClientConnectionManager将努力将连接重新用于具有相同路由的后续请求。但是，如果持久连接的路由与连接请求的路由不匹配，它将关闭现有连接并针对给定的路由重新打开它。如果已经分配了连接，则抛出java.lang.IllegalStateException。

默认情况下，HttpClient使用BasicClientConnectionManager。

有关如何使用可处理多个线程中的请求的池连接管理器，请参阅“多线程请求执行”。