redis 管道不适用于 go-redis maxRetries

Golang小白一枚，正在不断学习积累知识，现将学习到的知识记录一下，也是将我的所得分享给大家！而今天这篇文章《redis 管道不适用于 go-redis maxRetries》带大家来了解一下##content_title##，希望对大家的知识积累有所帮助，从而弥补自己的不足，助力实战开发！

我正在尝试使用 go-redis 客户端的 maxretries 选项。

package main

import (
    "context"
    "fmt"
    "log"
    "time"

    "github.com/go-redis/redis/v8"
)

func main() {
    db := redis.NewUniversalClient(&redis.UniversalOptions{
        Addrs:           []string{"localhost:6379"},
        PoolTimeout:     time.Duration(10) * time.Minute,
        MaxRetries:      3,
        MinRetryBackoff: 5 * time.Second,
        MaxRetryBackoff: 5 * time.Second,
    })

    ctx := context.Background()
    var i int64

    /*for i = 0; i <= 10000; i += 100 {
        time.Sleep(time.Second * 2)
        fmt.Println("i : ", i)
        test, err := db.HIncrBy(ctx, "testkv", "test", i).Result()
        log.Println("Increment result ", test, err)
        val, valerr := db.HGet(ctx, "testkv", "test").Result()
        log.Println("The new value of test is ", val, valerr)
    }*/

    for i = 0; i <= 10000; i += 100 {
        time.Sleep(time.Second * 2)
        fmt.Println("i : ", i)
        pipe := db.Pipeline()
        testRes := pipe.HIncrBy(ctx, "testkv", "test", i)
        valRes := pipe.HGet(ctx, "testkv", "test")
        _, err := pipe.Exec(ctx)
        pipe.Close()
        log.Println("Pipe Err: ", err)

        test, err := testRes.Result()
        log.Println("Increment result ", test, err)
        val, valerr := valRes.Result()
        log.Println("The new value of test is ", val, valerr)
    }
}

上面注释的代码没有管道。在这种情况下，当循环正在执行时，如果 redis 关闭，我会看到命令的执行被阻塞，直到 15 秒（由于重试），然后执行下一个命令。一旦 redis 启动，循环就会继续并成功执行命令。在管道场景中不会发生这种阻塞情况。任何帮助表示赞赏。谢谢。

正确答案

根据此问题 cluster client doesn't retry on pipeline read timeouts，重试策略不适用于管道。

好了，本文到此结束，带大家了解了《redis 管道不适用于 go-redis maxRetries》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多Golang知识！