如何确保我的 HttpClient 4.1 不会泄漏套接字？
2022-09-04 03:15:55
我的服务器使用来自内部 Web 服务的数据来构造其响应，基于每个请求。我正在使用Apache HttpClient 4.1来发出请求。每个初始请求将产生对 Web 服务的大约 30 个请求。其中，4 - 8个将最终将插槽卡在CLOSE_WAIT中，这些插槽永远不会被释放。最终，这些卡住的套接字超过了我的ulimit，我的进程用完了文件描述符。
我不想只是提出我的ulimit（1024），因为这只会掩盖问题。
我迁移到HttpClient的原因是java.net.HttpUrlConnection的行为方式相同。
我尝试过根据每个请求移动到 SingleClientConnManager，并在其上调用 client.getConnectionManager（）.shutdown（），但套接字仍然卡住。
我应该尝试解决这个问题，以便在没有运行请求的情况下最终得到0个打开的套接字，还是应该专注于请求持久性和池化？
为了清楚起见，我包括了一些可能相关的细节：
操作系统： Ubuntu 10.10
JRE： 1.6.0_22
语言： Scala 2.8
示例代码：
val cleaner = Executors.newScheduledThreadPool(1)
private val client = {
val ssl_ctx = SSLContext.getInstance("TLS")
val managers = Array[TrustManager](TrustingTrustManager)
ssl_ctx.init(null, managers, new java.security.SecureRandom())
val sslSf = new org.apache.http.conn.ssl.SSLSocketFactory(ssl_ctx, SSLSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER)
val schemeRegistry = new SchemeRegistry()
schemeRegistry.register(new Scheme("https", 443, sslSf))
val connection = new ThreadSafeClientConnManager(schemeRegistry)
object clean extends Runnable{
override def run = {
connection.closeExpiredConnections
connection.closeIdleConnections(30, SECONDS)
}
}
cleaner.scheduleAtFixedRate(clean,10,10,SECONDS)
val httpClient = new DefaultHttpClient(connection)
httpClient.getCredentialsProvider().setCredentials(new AuthScope(AuthScope.ANY), new UsernamePasswordCredentials(username,password))
httpClient
}
val get = new HttpGet(uri)
val entity = client.execute(get).getEntity
val stream = entity.getContent
val justForTheExample = IOUtils.toString(stream)
stream.close()
测试：netstat -a |grep {myInternalWebServiceName} |格雷普CLOSE_WAIT
（列出处于CLOSE_WAIT状态的进程的套接字）
发表评论讨论：
此代码现在演示了正确的用法。
