Go语言中可移植地检测网络错误：深度解析与实践

package main

import (
    "fmt"
    "net"
    "syscall" // 引入 syscall 包
    "time"

    "github.com/miekg/dns" // 示例中使用的第三方DNS库
)

// checkErr 函数用于演示如何分类网络错误
func checkErr(err error) {
    if err == nil {
        fmt.Println("Ok")
        return
    }

    // 1. 检测超时错误
    if netError, ok := err.(net.Error); ok && netError.Timeout() {
        fmt.Println("Timeout")
        return
    }

    // 后续将添加其他错误类型的检测
    fmt.Printf("Other error: %v\n", err)
}

func main() {
    var c dns.Client
    m := new(dns.Msg)

    // 模拟超时错误：连接一个不存在的DNS服务器，并设置短超时
    c.DialTimeout = 100 * time.Millisecond // 设置一个短的拨号超时
    m.SetQuestion("3com.br.", dns.TypeSOA)
    _, _, err := c.Exchange(m, "ns1.nonexistent-dns-server.com.:53") // 尝试连接一个不存在的服务器
    checkErr(err)

    // 模拟其他错误，将在后续部分处理
    m.SetQuestion("example.com.", dns.TypeSOA)
    _, _, err = c.Exchange(m, "idontexist.br.:53") // 模拟未知主机
    checkErr(err)

    m.SetQuestion("acasadocartaocuritiba.blog.br.", dns.TypeSOA)
    _, _, err = c.Exchange(m, "127.0.0.1:65535") // 模拟连接被拒绝（假设本地没有服务监听此端口）
    checkErr(err)
}

// checkErr 函数的更新版本，加入对 net.OpError 的处理
func checkErr(err error) {
    if err == nil {
        fmt.Println("Ok")
        return
    }

    if netError, ok := err.(net.Error); ok && netError.Timeout() {
        fmt.Println("Timeout")
        return
    }

    // 2. 检测 net.OpError 以识别操作类型
    if opError, ok := err.(*net.OpError); ok {
        switch opError.Op {
        case "dial":
            // 进一步检查 opError.Err 以区分未知主机或连接被拒绝等
            // 在这里，通常是DNS解析失败或路由问题
            fmt.Printf("Dial error (e.g., Unknown host or network unreachable): %v\n", opError.Err)
        case "read":
            // 连接建立后读取数据失败，可能是连接被重置或关闭
            fmt.Printf("Read error (e.g., Connection reset by peer): %v\n", opError.Err)
        case "write":
            // 连接建立后写入数据失败
            fmt.Printf("Write error: %v\n", opError.Err)
        default:
            fmt.Printf("Operation error (%s): %v\n", opError.Op, opError.Err)
        }
        return
    }

    fmt.Printf("Other error: %v\n", err)
}

// checkErr 函数的最终版本，结合了 net.Error, net.OpError 和 syscall.Errno
func checkErr(err error) {
    if err == nil {
        fmt.Println("Ok")
        return
    }

    // 1. 检测超时错误
    if netError, ok := err.(net.Error); ok && netError.Timeout() {
        fmt.Println("Timeout")
        return
    }

    // 使用类型 switch 结构化错误处理逻辑
    switch t := err.(type) {
    case *net.OpError:
        // 2. 检测 net.OpError 以识别操作类型
        switch t.Op {
        case "dial":
            // 对于拨号错误，进一步检查其内部错误
            if sysErr, ok := t.Err.(syscall.Errno); ok {
                if sysErr == syscall.ECONNREFUSED {
                    fmt.Println("Connection refused (Dial)") // 拨号时遇到连接拒绝
                    return
                }
                // 更多 syscall 错误判断...
            }
            // 如果不是特定的 syscall 错误，则可能是未知主机或网络不可达等
            fmt.Printf("Unknown host or network unreachable: %v\n", t.Err)
        case "read":
            // 对于读取错误，进一步检查其内部错误
            if sysErr, ok := t.Err.(syscall.Errno); ok {
                if sysErr == syscall.ECONNREFUSED {
                    fmt.Println("Connection refused (Read)") // 连接建立后读取时遇到连接拒绝
                    return
                }
                // 更多 syscall 错误判断...
            }
            fmt.Printf("Read error: %v\n", t.Err)
        case "write":
            fmt.Printf("Write error: %v\n", t.Err)
        default:
            fmt.Printf("Operation error (%s): %v\n", t.Op, t.Err)
        }
    case syscall.Errno:
        // 3. 直接检测 syscall.Errno
        if t == syscall.ECONNREFUSED {
            fmt.Println("Connection refused (Direct Syscall Error)")
            return
        }
        // 可以添加更多 syscall 错误码的判断
        fmt.Printf("Syscall error: %v\n", t)
    default:
        // 无法识别的其他错误
        fmt.Printf("Other error: %v\n", err)
    }
}

func main() {
    var c dns.Client
    m := new(dns.Msg)

    // 模拟超时错误
    c.DialTimeout = 100 * time.Millisecond
    m.SetQuestion("timeout.example.", dns.TypeSOA)
    _, _, err := c.Exchange(m, "ns1.nonexistent-dns-server.com.:53")
    fmt.Print("Scenario 1 (Timeout): ")
    checkErr(err)

    // 模拟未知主机错误 (通常表现为 dial 阶段的 OpError 且内部错误非特定 syscall)
    c.DialTimeout = 5 * time.Second // 恢复正常超时
    m.SetQuestion("unknownhost.example.", dns.TypeSOA)
    _, _, err = c.Exchange(m, "idontexist.br.:53") // 尝试连接一个不存在的域名
    fmt.Print("Scenario 2 (Unknown Host): ")
    checkErr(err)

    // 模拟连接被拒绝错误 (通常表现为 dial 阶段的 OpError 包含 syscall.ECONNREFUSED)
    m.SetQuestion("connrefused.example.", dns.TypeSOA)
    _, _, err = c.Exchange(m, "127.0.0.1:65535") // 尝试连接一个本地不存在的端口
    fmt.Print("Scenario 3 (Connection Refused): ")
    checkErr(err)

    // 模拟一个成功的操作
    m.SetQuestion("google.com.", dns.TypeSOA)
    _, _, err = c.Exchange(m, "8.8.8.8:53") // 使用Google Public DNS
    fmt.Print("Scenario 4 (Success): ")
    checkErr(err)
}

Scenario 1 (Timeout): Timeout
Scenario 2 (Unknown Host): Unknown host or network unreachable: lookup idontexist.br. on [::1]:53: no such host
Scenario 3 (Connection Refused): Connection refused (Dial)
Scenario 4 (Success): Ok