我有一个小型 Web 应用程序,它打开 TCP 套接字连接、发出命令、读取响应,然后关闭对特定 REST 端点的每个请求的连接。
我已经开始使用 Apache JMeter 对端点进行负载测试,并注意到运行一段时间后,我开始看到诸如“无法分配请求的地址”之类的错误,打开此连接的代码是:
def lookup(word: String): Option[String] = {
try {
val socket = new Socket(InetAddress.getByName("localhost"), 2222)
val out = new PrintStream(socket.getOutputStream)
val reader = new BufferedReader(new InputStreamReader(socket.getInputStream, "utf8"))
out.println("lookup " + word)
out.flush()
var curr = reader.readLine()
var response = ""
while (!curr.contains("SUCC") && !curr.contains("FAIL")) {
response += curr + "\n"
curr = reader.readLine()
}
socket.close()
curr match {
case code if code.contains(SUCCESS_CODE) => {
Some(response)
}
case _ => None
}
}
catch {
case e: Exception => println("Got an exception "+ e.getMessage); None
}
}
当我运行 netstat 时,我还看到许多以下 TIME_WAIT 连接状态,这对我来说意味着我用完了临时空间中的端口。
tcp6 0 0 localhost:54646 localhost:2222 TIME_WAIT
tcp6 0 0 localhost:54638 localhost:2222 TIME_WAIT
tcp6 0 0 localhost:54790 localhost:2222 TIME_WAIT
tcp6 0 0 localhost:54882 localhost:2222 TIME_WAIT
我想知道这个问题的最佳解决方案是什么。我当前的想法是创建一个连接池,其中与在端口上运行的该服务的连接2222
可以被不同的HTTP请求重用,而不是每次都创建新的请求。这是解决问题并使应用程序扩展更好的明智方法吗?引入似乎需要很大的开销,并且肯定会让我的应用程序变得更加复杂。
是否还有其他解决方案可以帮助该应用程序扩展并克服我没有看到的端口问题?我的 Web 应用程序在 Ubuntu Linux VM 中运行。
是的,创建连接池是一个很好的解决方案。然而,更简单的解决方案是让服务器而不是客户端关闭连接。在这种情况下,服务器的套接字(而不是客户端的套接字)最终将处于 TIME_WAIT 状态,因此客户端不会耗尽端口。在服务器端,处于 TIME_WAIT 状态的连接不会使服务器耗尽端口,因为它们都使用相同的本地端口。
为了确保服务器关闭连接,您需要从套接字(在客户端上)读取数据,直到达到文件结束条件。此时,在客户端关闭套接字是安全的,因为服务器已经关闭了它。当然,您需要确保服务器将关闭套接字,而不是等待新请求。
或者,如果您有 root 访问权限,则有一些sysctl您可以调整的选项:
-
net.ipv4.ip_local_port_range
– 临时端口范围。增加它以使更多端口可用于传出连接。
-
net.ipv4.tcp_tw_recycle
– 能够更快地回收处于 TIME_WAIT 状态的连接。
-
net.ipv4.tcp_tw_reuse
– 允许重用处于 TIME_WAIT 状态的连接。不建议。
请参阅手册页ip(7) and tcp(7)了解更多信息。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)