如何优雅地处理 Golang 中的 Broken Pipe 错误-Golang-PHP中文网

如何优雅地处理 Golang 中的 Broken Pipe 错误

DDD

发布： 2025-09-07 12:07:16

原创

700人浏览过

如何优雅地处理 golang 中的 broken pipe 错误

当使用 Golang 进行网络编程，尤其是通过 io.Copy 函数将数据写入 TCP 连接时，可能会遇到 write tcp [local address]->[remote address]: broken pipe 错误。这通常发生在远程主机在数据传输过程中突然断开连接时。由于 io.Copy 返回的是一个 error 接口，我们需要一种方法来区分 "broken pipe" 错误和其他可能的错误，以便进行适当的处理。

识别 Broken Pipe 错误

broken pipe 错误实际上是由操作系统返回的 EPIPE 错误码引起的。在 Golang 的 syscall 包中，EPIPE 被定义为一个常量。因此，我们可以直接将 error 接口与 syscall.EPIPE 进行比较。

import (
    "io"
    "net"
    "syscall"
)

func handleConnection(conn net.Conn) {
    defer conn.Close()

    // 模拟向连接写入数据，可能会触发 broken pipe 错误
    _, err := io.Copy(conn, conn) // 这里只是一个示例，实际应用中应该是从其他地方读取数据写入 conn

    if err != nil {
        if err == syscall.EPIPE {
            // 忽略 broken pipe 错误
            println("Broken pipe error encountered, ignoring...")
        } else {
            // 处理其他类型的错误
            println("Encountered an error:", err.Error())
        }
    }
}

func main() {
    ln, err := net.Listen("tcp", ":8080")
    if err != nil {
        println("Error listening:", err.Error())
        return
    }
    defer ln.Close()

    println("Listening on :8080")
    for {
        conn, err := ln.Accept()
        if err != nil {
            println("Error accepting:", err.Error())
            continue
        }
        go handleConnection(conn)
    }
}

登录后复制

在上述代码中，我们首先使用 io.Copy 函数尝试将数据写入连接。如果发生错误，我们检查该错误是否等于 syscall.EPIPE。如果是，我们就可以安全地忽略该错误，因为这仅仅表示远程主机已经断开连接。对于其他类型的错误，我们则需要进行相应的处理，例如记录日志或返回错误信息。

立即学习“go语言免费学习笔记（深入）”；

获取 Errno 值（可选）

动态WEB网站中的PHP和MySQL：直观的QuickPro指南第2版

动态WEB网站中的PHP和MySQL详细反映实际程序的需求，仔细地探讨外部数据的验证(例如信用卡卡号的格式)、用户登录以及如何使用模板建立网页的标准外观。动态WEB网站中的PHP和MySQL的内容不仅仅是这些。书中还提到如何串联JavaScript与PHP让用户操作时更快、更方便。还有正确处理用户输入错误的方法，让网站看起来更专业。另外还引入大量来自PEAR外挂函数库的强大功能，对常用的、强大的包

508

查看详情

虽然直接比较 error 接口和 syscall.EPIPE 已经足够区分 broken pipe 错误，但如果你需要获取实际的 errno 值，可以使用类型断言。

import (
    "io"
    "net"
    "syscall"
)

func handleConnection(conn net.Conn) {
    defer conn.Close()

    // 模拟向连接写入数据，可能会触发 broken pipe 错误
    _, err := io.Copy(conn, conn) // 这里只是一个示例，实际应用中应该是从其他地方读取数据写入 conn

    if err != nil {
        if e, ok := err.(syscall.Errno); ok {
            errno := uintptr(e)
            if errno == uintptr(syscall.EPIPE) {
                // 忽略 broken pipe 错误
                println("Broken pipe error encountered, ignoring...")
            } else {
                println("Encountered an error with errno:", errno)
            }
        } else {
            // 处理其他类型的错误
            println("Encountered an error:", err.Error())
        }
    }
}

func main() {
    ln, err := net.Listen("tcp", ":8080")
    if err != nil {
        println("Error listening:", err.Error())
        return
    }
    defer ln.Close()

    println("Listening on :8080")
    for {
        conn, err := ln.Accept()
        if err != nil {
            println("Error accepting:", err.Error())
            continue
        }
        go handleConnection(conn)
    }
}

登录后复制

在这个例子中，我们使用类型断言 err.(syscall.Errno) 来尝试将 error 接口转换为 syscall.Errno 类型。如果转换成功，我们就可以获取到 errno 值，并进行进一步的判断。

注意事项