Java ：java.io.IOException: Broken pipe
在 Java 中，java.io.IOException: Broken pipe 是一个常见的网络通信异常，通常发生在尝试向一个已经关闭的连接写入数据时。这种错误常见于客户端或服务器端主动关闭了连接，但另一端仍在尝试写入数据的情况。
1、异常含义
“Broken Pipe”（管道破裂）表示在进程间通信（如 Socket 通信）中，连接的一端已经关闭，而另一端仍在尝试向该连接写入数据。这就像一条输水管道，一端被堵住或关闭了，而另一端还在不断地注水，导致管道破裂。
2、常见场景
客户端主动关闭连接：例如用户刷新页面、关闭浏览器、点击“停止加载”等行为会导致客户端关闭连接。
网络超时或资源不足：当服务器处理时间较长，而客户端设置了较短的超时时间时，可能会提前关闭连接。
Nginx 或反向代理超时：如果使用了 Nginx 等代理服务器，其默认的 proxy_read_timeout 是 60 秒，若服务端响应时间超过此值，Nginx 会关闭连接，导致服务器端出现 Broken pipe 异常。
服务端处理时间过长：在大文件或流式响应场景中，若服务端处理时间超过客户端的超时时间，也可能引发该异常。
3、解决方案
检查连接状态：在向客户端写入数据前，应先确认客户端是否仍然连接。
使用异常处理机制捕获异常：通过 try-catch 捕获 SocketException 或 IOException，并根据具体错误信息（如 "Broken pipe"）进行处理。
增加超时设置：适当延长客户端和服务端的超时时间，避免因响应时间过长而导致连接被提前关闭。
优化响应负载：减少 API 响应的数据量，提高响应速度，降低 Broken pipe 的发生概率。
处理信号与资源管理：确保在关闭连接后及时释放资源，并注意对 SIGPIPE 信号的处理。
升级软件版本：对于某些特定环境（如 Doris），升级到支持修复的版本可以避免该问题。
4、示例代码
try {
outputStream.write(data);
} catch (IOException e) {
if ("Broken pipe".equals(e.getMessage()) || "Connection reset by peer".equals(e.getMessage())) {
// 记录日志并关闭资源
log.warn("客户端已断开连接，停止写入: {}", e.getMessage());
} else {
throw e;
}
}