go - Redigo:当 Redis 服务器关闭时快速失败

Question

当我连接的 redis 服务器出现故障时，我正在努力让 go 快速失败，我想要一个强大的解决方案。

我正在使用 redigo我正在像这样设置一个连接池:

// This has other stuff in it in the code, use it as a 
// central repository for things we want in memory
type State struct{
    redisPool *redis.Pool
}

func (state *State) GetRedisConn() redis.Conn {
    return state.redisPool.Get()
}

func main() {
    state.redisPool = &redis.Pool{
        MaxIdle:     200,
        MaxActive:   9000,
        IdleTimeout: time.Minute,
        Dial: func() (redis.Conn, error) {
            return redis.Dial("tcp", *redisAddress,
                redis.DialConnectTimeout(1*time.Second),
                redis.DialReadTimeout(100*time.Millisecond),
                redis.DialWriteTimeout(100*time.Millisecond),
            )
        },
    }
}

然后请求新连接并像这样使用它们:

t0 := time.Now()

conn := state.GetRedisConn()
if conn != nil && conn.Err() == nil {
    defer conn.Close()
    // Do stuff
else {
    log.Printf("no redis probably")
}

log.Println(time.Now().Sub(t0).Seconds())

当 redis 启动时，这很好用，事情发生在几毫秒内。当我使用 redis 时，我的第 75 个百分位数上升到 7+ 秒，我的第 99 个百分位数上升到 10 秒(我可以在普罗米修斯上看到这一点)

我做错了什么？为什么这不会更快超时？我的印象是 redis.DialConnectTimeout(1*time.Second) 会将问题限制在 1 秒，但事实并非如此。

编辑:事实证明这是由于我在普罗米修斯中犯了一个错误，将桶设置得太大，所以当 redis 在一秒钟后超时时，我的桶设置为 1s 桶和 10s bucket，所以我的请求(刚刚超过 1s)最终进入了 10s 的 bucket，从而扭曲了结果。不过，我相信这个讨论在某些时候会对某些人有用。

Answer 1

失败后的速率限制拨号尝试:

func main() {
    var (
       nextDial time.Time
       mu sync.Mutex
    )
    state.redisPool = &redis.Pool{
        MaxIdle:     200,
        MaxActive:   9000,
        IdleTimeout: time.Minute,
        Dial: func() (redis.Conn, error) {
            mu.Lock()   // Dial can be called concurrently
            defer mu.Unlock()
            if time.Now().Before(nextDial) {
               return nil, errors.New("waiting for dial")
            }
            c, err := redis.Dial("tcp", *redisAddress,
                redis.DialConnectTimeout(1*time.Second),
                redis.DialReadTimeout(100*time.Millisecond),
                redis.DialWriteTimeout(100*time.Millisecond),
            )
            if err == nil {
               nextDial = time.Time{}
            } else {
               nextDial = time.Now().Add(time.Second) // don't attempt dial for one second
            }
            return c, err
        },
    }
}