Go 专门判断超时错误

// Timeout
type Timeout struct {
    Connect   time.Duration
    ReadWrite time.Duration
}

// TimeoutDialer
func TimeoutDialer(timeout *Timeout) func(net, addr string) (c net.Conn, err error) {
    return func(netw, addr string) (net.Conn, error) {    
        conn, err := net.DialTimeout(netw, addr, timeout.Connect)
        if err != nil {
            return nil, err
        }
        conn.SetDeadline(time.Now().Add(timeout.ReadWrite))
        return conn, nil
    }
}

// HttpClient
func HttpClient(config Config) *http.Client {
    to := &Timeout{
        Connect:   time.Duration(config.MaxWait) * time.Second,
        ReadWrite: time.Duration(config.MaxWait) * time.Second,
    }

    return &http.Client{
        Transport: &http.Transport{
            Dial: TimeoutDialer(to),
        },
    }
}

if err, ok := err.(net.Error); ok && err.Timeout() {

switch err := err.(type) {
case net.Error:
    if err.Timeout() {
        fmt.Println("This was a net.Error with a Timeout")
    }
case *url.Error:
    fmt.Println("This is a *url.Error")
    if err, ok := err.Err.(net.Error); ok && err.Timeout() {
        fmt.Println("and it was because of a timeout")
    }
}

if err != nil && strings.Contains(err.Error(), "use of closed network connection") {
    fmt.Println("Could be from a Transport.CancelRequest")
}

Go相关问答推荐

调用API时使用nginx作为反向代理时从nginx获取502坏网关

GORM Find(&；Room)操作使用空数据而不是实际数据填充 struct

使用ciph.AEAD.Seal()查看内存使用情况

如何根据中间件的请求设置上下文值？获取 go-staticcheck 问题

在 Go 中将元数据从一个 JPEG 复制到另一个

我应该先解锁然后再广播吗？

Go Template if 条件

Go 中的 Azure JWT 验证不起作用

闭包所处的环境范围是什么？

使用 Grafana alert 在几分钟内重复alert

assert： mock： I don't know what to return because the method call was unexpected 在 Go 中编写单元测试时出错

使用自定义处理程序 nats golang 保留订阅方法

如何使用带有方法的字符串枚举作为通用参数？

如何将具有嵌入式 struct 的 struct 展平为 json

Go 泛型：自引用接口约束

每次有人进入我的网站时如何运行特定功能？

Go GCP 同时模拟两个服务帐户

Go：用于 XML 解码的嵌套 struct 中的提升字段

如何正确判断 io.Reader 是否为零？

Golang API 的 HTTPS