如何诊断泄漏的http连接(org.apache.http.impl.conn.tsccm.ConnPoolByRoute)

Pie*_*e D 4 java connection-pooling amazon-web-services apache-httpclient-4.x

我有一个在 Amazon EC2 上运行的多线程 java 程序。它使用 org.apache.http.impl.client.DefaultHttpClient 通过 HttpPost 和 HttpGet 从供应商查询和获取数据项。同时,它使用 AWS 的 Java SDK 将检索到的数据项推送到 S3。

运行几天后,我出现了通常伴随 http 连接泄漏的症状:

org.apache.http.conn.ConnectionPoolTimeoutException: Timeout waiting for connection
at org.apache.http.impl.conn.tsccm.ConnPoolByRoute.getEntryBlocking(ConnPoolByRoute.java:417)
at org.apache.http.impl.conn.tsccm.ConnPoolByRoute$1.getPoolEntry(ConnPoolByRoute.java:300)
at org.apache.http.impl.conn.tsccm.ThreadSafeClientConnManager$1.getConnection(ThreadSafeClientConnManager.java:224)
at org.apache.http.impl.client.DefaultRequestDirector.execute(DefaultRequestDirector.java:391)
at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:820)
at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:754)
at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:732)
Run Code Online (Sandbox Code Playgroud)

由于 AWS 和我对数据供应商的请求都使用 Http 连接,因此我不太确定我到底忘记了什么HttpEntity.consume(),或者S3ObjectInputStream.close()(除非是其他东西......)。

所以这是我的问题:有没有办法进行监控org.apache.http.impl.conn.tsccm.ConnPoolByRoute,以便至少我可以检测到何时开始泄漏连接/未正确使用的实体/http 流未关闭?(我有一种感觉,它只在某些条件下发生,例如,当抛出某些异常时,绕过我的代码中消耗 HttpEntities 的逻辑,关闭流等)关于如何诊断最终导致我的所有 http 的任何想法因 ConnectionPoolTimeoutException 而失败的连接将是最受欢迎的。我不想在尝试解决问题的根本原因之间等待 4 天以上。

小智 5

如果您使用注释,则可以使用和PoolingClientConnectionManager方法为您提供一个 PoolStats 对象,其中包含您要监视的数据。getTotalStats()getStats(final HttpRoute route)

只需从 httpclient 获取 ConnectionManager:

PoolingClientConnectionManager poolManager = (PoolingClientConnectionManager) httpClient.getConnectionManager();
Run Code Online (Sandbox Code Playgroud)