Java 套接字：没有可用的缓冲区空间（达到最大连接数？）

Question

我有一个大问题。我开发了一个客户端-服务器应用程序。客户端线程向服务器发送一个序列化的对象，服务器返回一个序列化的对象。目前我正在使用一台服务器和 10 个客户端线程，大约 30 秒后，我从每个客户端线程（IOException）收到错误消息：

没有可用的缓冲区空间（已达到最大连接数？）：连接

如果我在 netstat 中查看，那么我会看到创建了很多连接，而且它还在不断增长，所有连接都处于 TIME_WAIT 状态。

我不知道为什么。我每次在 finally 块中关闭服务器和客户端中的套接字。这是一些代码：

在我的 socketHandlerThread 中的服务器中：

ServerSocket serverSocket = new ServerSocket(port);
serverSocket.setSoTimeout(5000);
while(true) {
       Socket socket = serverSocket.accept();
}

然后将新套接字放在 LinkedBlockingQueue 上，工作线程获取套接字并执行以下操作：

try {
      outputStream = new ObjectOutputStream(new BufferedOutputStream(socket.getOutputStream()));
      outputStream.flush();
      inStream = new ObjectInputStream(new BufferedInputStream(socket.getInputStream()));
      ClientRequest clientRequest = (ClientRequest) inStream.readObject();
...
      outputStream.writeObject(serverResponse);
      outputStream.flush();
} catch....
} finally {
                if (inStream != null) {
                    inStream.close();
                }
                if (outputStream != null) {
                    outputStream.close();
                }
                if (socket != null) {
                    socket.close();
                }
}

在客户端我有以下代码：

    try {
        socket = new Socket(host, port);
        outputStream = new ObjectOutputStream(new BufferedOutputStream(socket.getOutputStream()));
        outputStream.flush();
        inputStream = new ObjectInputStream(new BufferedInputStream(socket.getInputStream()));
        outputStream.writeObject(request);
        outputStream.flush();
        Object serverResponse = inputStream.readObject();
   } catch....
   } finally {
            if (inputStream != null) {
                inputStream.close();
            }
            if (outputStream != null) {
                outputStream.close();
            }
            if (socket != null) {
                socket.close();
            }
   }

有人可以帮忙吗？我真的不知道我犯了什么错误。我似乎没有关闭套接字，但我不知道为什么。

可能是我将套接字放在服务器端的队列中以便以某种方式复制套接字的问题吗？

编辑：如果我将客户端和服务器分别放在运行 Linux AMI 的不同 Amazon EC2 经典实例上，那么它可以工作。这可能是 Windows 的问题，还是仅仅是我在同一台机器（我的本地电脑）上运行客户端和服务器的问题？

有人看到我的代码中有错误吗？

Edit2：如上所述，它在 EC2 实例上有效，但如果我使用 netstat，它仍然显示很多行说 TIME_WAIT。

以下是截图：

https://drive.google.com/file/d/0BzERdJrwWrNCWjhReGhpR2FBMUU/view?usp=sharing

https://drive.google.com/file/d/0BzERdJrwWrNCOG1TWGo5YmxlaTg/view?usp=sharing

第一个屏幕截图来自 Windows。 “WARTEND”的意思是“WAITING”（德语）。

第二个屏幕截图来自 Amazon EC2（左侧是客户端机器，右侧是服务器机器）。

Answer 1

TIME-WAIT 输入之后两端的连接都关闭。出于数据完整性原因，它会持续几分钟。

如果缓冲区问题是由于服务器的 TIME-WAIT 状态引起的，解决方案是让服务器成为最先收到关闭的对等方。这会将 TIME-WAIT 状态转移到客户端，它是良性的。

您可以通过将服务器端请求处理放入一个循环中来做到这一点，这样它就可以处理每个连接的多个请求，并且服务器只有在它到达流结束时才关闭套接字。

for (;;)
{
    try
    {
        ClientRequest clientRequest = (ClientRequest) inStream.readObject();
        ...
        outputStream.writeObject(serverResponse);
        outputStream.flush();
    }
    catch (EOFException exc)
    {
        break;
    }
}

如果你在客户端实现连接池，你将大大减少连接数，这将进一步减少缓冲区问题的发生率。