項(xiàng)目依賴地址go-redis

https://github.com/go-redis/redis

文檔地址

https://pkg.go.dev/github.com/go-redis/redis/v8@v8.11.4#example-Client.Pipeline

• 對于看go項(xiàng)目的文檔我也是暈暈的,但是找到大概應(yīng)該可以通過example下面來解決問題

docker安裝redis

docker run --name redis507 -p 6379:6379 -d redis:5.0.7

docker run -it --network host --rm redis:5.0.7 redis-cli 【此步驟可以通過界面工具如：quickredis...等來查看連接】

redis連接

func initClient() (err error) {
    rdb = redis.NewClient(&redis.Options{
        Addr:     "localhost:6379",
        Password: "",  // no password set
        DB:       0,   // use default DB
        PoolSize: 100, // 連接池大小
    })

    ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
    defer cancel()

    _, err = rdb.Ping(ctx).Result()
    return err
}

操作string

func rdsString() {
    ctx := context.Background()
    if err := initClient(); err != nil {
        return
    }

    err := rdb.Set(ctx, "key1", "value1", 0).Err()
    if err != nil {
        panic(err)
    }

    val, err := rdb.Get(ctx, "jzredis").Result()
    if err != nil {
        panic(err)
    }
    fmt.Println("key1", val)
}

切換數(shù)據(jù)庫

func changeDb(){
//切換數(shù)據(jù)庫
    pipe := rdb.Pipeline()
    _ = pipe.Select(ctx, 3)
    _, _ = pipe.Exec(ctx)
    err = rdb.Set(ctx, "key3", "我是key3數(shù)據(jù)庫請查看", 0).Err()
    if err != nil {
        panic(err)
    }
}

操作hash

func hsetTest()  {
    ctx := context.Background()
    if err := initClient(); err != nil {
        return
    }
    err := rdb.HSet(ctx, "testhset", map[string]interface{}{"org": 12345, "name": "test123"}).Err()
    if err != nil {
        panic(err)
    }

    fmt.Print("success")
}

操作列表

func listpushTest()  {
    ctx := context.Background()
    if err := initClient(); err != nil {
        return
    }
    for i := 0; i < 10; i++ {
        err := rdb.LPush(ctx, "listtest", i).Err()
        if err != nil {
            panic(err)
        }
    }

    fmt.Print("success")
}

func lPop()  {
    ctx := context.Background()
    if err := initClient(); err != nil {
        return
    }
    retstring, err := rdb.LPop(ctx, "listtest").Result()
    fmt.Print(retstring)
    if err != nil {
        panic(err)
    }
    fmt.Print("success")
}

func rPop()  {
    ctx := context.Background()
    if err := initClient(); err != nil {
        return
    }
    llen,_ := rdb.LLen(ctx,"listtest").Result()
    for i := int64(0); i < llen; i++ {
        retstring, err := rdb.RPop(ctx, "listtest").Result()
        fmt.Println(retstring)
        if err != nil {
            panic(err)
        }
    }
}

到此常用的redis已經(jīng)記錄了，如果還需要可以根據(jù)文檔來時(shí)間的....