2

操作系统：Linux (Debian)
Java：Java(TM) SE 运行时环境（内部版本 1.7.0_05-b06）
Java：Java HotSpot(TM) 64 位服务器 VM（内部版本 23.1-b03，混合模式）
Apache http 客户端：v4。 2.3（最新）

我想创建一个具有多个客户端的 PoolingConnectionManager，每个客户端都有其唯一的本地地址 (ConnRoutePNames.LOCAL_ADDRESS)。
这些客户端将被多个工作人员使用（每个工作人员选择随机客户端并执行请求）。

问题是：当我为客户端设置本地地址时，经过一段时间（例如 1 分钟），我总是收到 java.net.BindException 消息“地址已在使用中”。

问题：是bug吗？

java.net.BindException: Address already in use
at java.net.PlainSocketImpl.socketBind(Native Method) ~[na:1.7.0_05]
at java.net.AbstractPlainSocketImpl.bind(AbstractPlainSocketImpl.java:376) ~[na:1.7.0_05]
at java.net.Socket.bind(Socket.java:627) ~[na:1.7.0_05]
at org.apache.http.conn.scheme.PlainSocketFactory.connectSocket(PlainSocketFactory.java:120) ~[httpclient-4.2.3.jar:4.2.3]
at org.apache.http.impl.conn.DefaultClientConnectionOperator.openConnection(DefaultClientConnectionOperator.java:180) ~[httpclient-4.2.3.jar:4.2.3]
at org.apache.http.impl.conn.ManagedClientConnectionImpl.open(ManagedClientConnectionImpl.java:294) ~[httpclient-4.2.3.jar:4.2.3]
at org.apache.http.impl.client.DefaultRequestDirector.tryConnect(DefaultRequestDirector.java:645) ~[httpclient-4.2.3.jar:4.2.3]
at org.apache.http.impl.client.DefaultRequestDirector.execute(DefaultRequestDirector.java:480) ~[httpclient-4.2.3.jar:4.2.3]
at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:906) ~[httpclient-4.2.3.jar:4.2.3]
at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:805) ~[httpclient-4.2.3.jar:4.2.3]
at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:784) ~[httpclient-4.2.3.jar:4.2.3]
at controllers.Test$Worker.run(Test.java:67) ~[test_2.9.1-1.0-SNAPSHOT.jar:1.0-SNAPSHOT]
at java.lang.Thread.run(Thread.java:722) [na:1.7.0_05]

代码（简化）：

public static void main(String[] args) throws UnknownHostException
{
    ClientConnectionManager connManager = buildConnectionManager(30);

    List<HttpClient> clients = new ArrayList<>();
    for(int i=0; i<8; ++i)
    {
        HttpClient client = buildClient(connManager, InetAddress.getByName("111.111.111." + (50 + i));
        clients.add(client);
    }

    for(int i=0; i<30; ++i)
    {
        new Thread(new Worker(clients)).start();
    }
}

public static ClientConnectionManager buildConnectionManager(Integer parallelism)
{
    PoolingClientConnectionManager connectionManager = new PoolingClientConnectionManager();
    connectionManager.setMaxTotal(parallelism);
    connectionManager.setDefaultMaxPerRoute(parallelism);

    return connectionManager;
}

public static HttpClient buildClient(ClientConnectionManager connectionManager, InetAddress localAddress)
{
    DefaultHttpClient httpClient = new DefaultHttpClient(connectionManager);
    HttpParams params = httpClient.getParams();
    params.setParameter(ConnRoutePNames.LOCAL_ADDRESS, localAddress);

    return httpClient;
}

private static class Worker implements Runnable
{
    private List<HttpClient> clients = null;

    public Worker(List<HttpClient> clients)
    {
        this.clients = clients;
    }

    public void run()
    {

        do
        {
            HttpGet httpGet = new HttpGet("http://google.com/robots.txt");
            HttpClient client = this.clients.get(new Random().nextInt(this.clients.size()));

            try
            {
                HttpResponse httpResponse = client.execute(httpGet);
                EntityUtils.consume(httpResponse.getEntity());

                logger.debug("Success request");
            }
            catch(IOException e)
            {
                httpGet.abort();
                logger.info("IO error", e);
            }
        }
        while(true);
    }
}
4

3 回答 3

3

此问题可能与您的 TCP 堆栈有关。我不认为这是 HttpClient 中的错误。您可以在这里找到解决方案： http ://planet.jboss.org/post/concurrent_high_throughput_performance_testing_with_jmeter

于 2013-01-21T10:04:05.597 回答
1

我能想到的唯一理论是 TCP/IP 堆栈用尽端口并开始为新连接分配相同的端口号，而旧连接尚未完全清理。我没有看到这个问题是 HttpClient 中的错误的证据。

于 2013-01-20T19:40:39.227 回答
0

感谢您的回答！
是的，问题出在 tcp/ip 堆栈上，但我不明白为什么 :)

所以，下面解释原因。

我创建了连接管理器（例如 size=10）、几个客户端（每个客户端都有其唯一的本地地址）和几个工作人员。
每个工作人员随机获取客户端并执行请求。
因此，一个客户端可能同时由多达 10 个工作人员并行执行。
在另一个时候，另一个客户端可以由多达 10 个工作人员并行执行。
这就是为什么管理器中的所有 10 个连接都不能保持活动状态，它们一直在关闭/创建。

对不起，打扰你！

于 2013-01-21T15:49:58.470 回答