Unix 域套接字上管道损坏的原因是什么？

Question

我有一个服务器应用程序，它接收请求并在 Unix 域套接字上转发它们。这在合理使用下可以完美运行，但是当我对几千个请求进行一些负载测试时，我收到了 Broken Pipe 错误。

我正在使用带有junixsocket 的Java 7来发送请求。我有很多并发请求，但我有一个 20 个工作线程池正在写入 unix 域套接字，所以没有太多并发打开连接的问题。

对于我打开的每个请求，发送和关闭与 Unix 域套接字的连接。

可能导致 Unix 域套接字上的管道损坏的原因是什么？

更新：

如果需要，放置代码示例：

byte[] mydata = new byte[1024];
//fill the data with bytes ...

AFUNIXSocketAddress socketAddress = new AFUNIXSocketAddress(new File("/tmp/my.sock"));
Socket socket = AFUNIXSocket.connectTo(socketAddress);
OutputStream out = new BufferedOutputStream(socket.getOutputStream());
InputStream in = new BufferedInputStream(socket.getInputStream()));

out.write(mydata);
out.flush();  //The Broken Pipe occurs here, but only after a few thousand times

//read the response back...

out.close();
in.close();
socket.close();

我有一个由 20 个工人组成的线程池，他们同时执行上述操作（因此最多 20 个并发连接到同一个 Unix 域套接字），每个连接都打开、发送和关闭。这适用于 10,000 个请求的突发负载测试，但是当我再放几千个请求时，我突然收到此错误，所以我想知道它是否来自某些操作系统限制。

请记住，这是一个 Unix 域套接字，而不是网络 TCP 套接字。

Answer 1

“管道损坏”意味着您已写入已被另一端关闭的连接。由于缓冲，它的检测有些异步。这基本上意味着您的应用程序协议中有错误。