golang write: broken pipe

当你在使用 Golang 写入数据时遇到 "broken pipe" 错误，这通常意味着写入数据的一方已经关闭了连接，而写入操作仍在进行。这种情况可能发生在以下几种情况下：

1. 当你尝试向一个已经关闭的连接（如网络连接或管道）写入数据时，就会出现 "broken pipe" 错误。

2. 另一个常见的情况是，在并发程序中，当一个 goroutine 尝试向一个已关闭的 channel 写入数据时，也会出现该错误。

为了解决这个问题，你可以在写入数据之前先检查连接是否仍然有效。在网络编程中，你可以使用 `net.Conn` 的 `Write` 方法之前调用 `net.Conn` 的 `SetWriteDeadline` 方法来设置写入操作的超时时间，并在写入之前检查错误。

示例代码如下所示：

conn.SetWriteDeadline(time.Now().Add(writeTimeout))
_, err := conn.Write(data)
if err != nil {
    if netErr, ok := err.(*net.OpError); ok && netErr.Timeout() {
        // 处理超时错误
    }
    // 处理其他错误
}

对于 channel 的情况，可以使用带有第二个返回值的写入操作来判断 channel 是否已经关闭。

示例代码如下所示：

select {
case ch <- data:
    // 写入成功
case <-time.After(writeTimeout):
    // 超时处理
case _, ok := <-ch:
    if !ok {
        // channel 已关闭
    }
}

通过这些方法，你可以提前检查连接或 channel 的状态，避免向已经关闭的连接或 channel 写入数据导致 "broken pipe" 错误的发生。