BindException/在负载下使用 HttpClient 时打开太多文件

Question

我有 1000 个专用 Java 线程，每个线程每秒轮询一个相应的 url。

public class Poller { 
    public static Node poll(Node node) { 
        GetMethod method =  null; 
        try { 
            HttpClient client = new HttpClient(new SimpleHttpConnectionManager(true)); 
            ......
        } catch (IOException ex) { 
            ex.printStackTrace(); 
        } finally { 
            method.releaseConnection(); 
        } 
    } 
} 

线程每隔一秒运行一次：

for (int i=0; i <1000; i++) { 
    MyThread thread = threads.get(i) // threads  is a static field 
    if(thread.isAlive()) { 
        // If the previous thread is still running, let it run. 
    } else { 
        thread.start(); 
    } 
}

问题是，如果我每隔一秒运行一次作业，我就会收到如下随机异常：

java.net.BindException: Address already in use 
 INFO httpclient.HttpMethodDirector: I/O exception (java.net.BindException) caught when processing request: Address already in use 
 INFO httpclient.HttpMethodDirector: Retrying request 

但如果我每 2 秒或更长时间运行一次作业，一切都会正常运行。

我什至尝试使用 shutdown() 关闭 SimpleHttpConnectionManager() 的实例，但没有效果。

如果我执行 netstat，我会看到数千个处于 TIME_WAIT 状态的 TCP 连接，这意味着它们已被关闭并正在清除。

因此，为了限制连接数，我尝试使用 HttpClient 的单个实例，并像这样使用它：

  public class MyHttpClientFactory { 
        private static MyHttpClientFactory instance = new HttpClientFactory(); 
        private MultiThreadedHttpConnectionManager connectionManager; 
        private HttpClient client; 

        private HttpClientFactory() { 
                init(); 
        } 

        public static HttpClientFactory getInstance() { 
                return instance; 
        } 

        public void init() { 
                connectionManager = new MultiThreadedHttpConnectionManager(); 
                HttpConnectionManagerParams managerParams = new HttpConnectionManagerParams(); 
                managerParams.setMaxTotalConnections(1000); 
                connectionManager.setParams(managerParams); 
                client = new HttpClient(connectionManager); 
        } 

        public HttpClient getHttpClient() { 
                if (client != null) { 
                        return client; 
                } else { 
                    init(); 
                    return client; 
                } 
        } 
}

但是，在运行了整整 2 小时后，它开始抛出“打开文件太多”，最终根本无法执行任何操作。

ERROR java.net.SocketException: Too many open files
INFO httpclient.HttpMethodDirector: I/O exception (java.net.SocketException) caught when processing request: Too many open files
INFO httpclient.HttpMethodDirector: Retrying request

我应该能够增加允许的连接数量并使其正常工作，但我只会延长邪恶的时间。知道在上述情况下使用 HttpClient 的最佳实践是什么吗？

顺便说一句，我仍然使用 HttpClient3.1。

Answer 1

以 sudo 或 root 身份编辑 /etc/security/limits.conf 文件。在文件末尾“# End of File”上方输入以下值：
* 软诺文件 65535
* 硬诺文件 65535
这会将打开文件的数量设置为无限。

Answer 2

几个月前，这件事发生在我们身上。首先，仔细检查以确保您每次都确实调用了releaseConnection()。但即便如此，操作系统实际上也不会立即回收所有 TCP 连接。解决方案是使用 Apache HTTP 客户端的 多线程HttpConnectionManager。这会池化并重用连接。

请参阅 http://hc.apache.org/httpclient-3.x/performance .html 了解更多性能提示。

更新：哎呀，我没有阅读下面的代码示例。如果您正在执行releaseConnection()并使用MultiThreadedHttpConnectionManager，请考虑操作系统对每个进程打开文件的限制是否设置得足够高。我们也遇到了这个问题，需要稍微扩大限制。

Answer 3

第一个错误没有任何问题。您刚刚耗尽了可用的经验端口。每个TCP连接可以处于TIME_WAIT状态2分钟。您生成 2000 个/秒。迟早，套接字找不到任何未使用的本地端口，您将收到该错误。 TIME_WAIT正是为此目的而设计的。如果没有它，您的系统可能会劫持以前的连接。

第二个错误意味着您打开了太多套接字。在某些系统上，打开文件数有 1K 的限制。也许您只是由于延迟的套接字和其他打开的文件而达到了该限制。在 Linux 上，您可以使用

  ulimit -n 2048

但这受系统范围最大值的限制来更改此限制。