Golang新手怎样操作Redis 使用go-redis连接与数据存取

github.com/go-redis/redis/v8

redis.NewClient

client.Set(ctx, key, value, expiration)

client.Get(ctx, key)

package main

import (
    "context"
    "fmt"
    "time"

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

var ctx = context.Background()

func main() {
    rdb := redis.NewClient(&redis.Options{
        Addr:     "localhost:6379", // Redis 服务器地址
        Password: "",               // 没有密码，留空
        DB:       0,                // 默认 DB 0
    })

    // PING 测试连接
    pong, err := rdb.Ping(ctx).Result()
    if err != nil {
        fmt.Println("连接 Redis 失败:", err)
        return
    }
    fmt.Println("连接 Redis 成功:", pong)

    // 存一个键值对
    err = rdb.Set(ctx, "mykey", "Hello from Go!", 0).Err() // 0 表示永不过期
    if err != nil {
        fmt.Println("写入 Redis 失败:", err)
        return
    }
    fmt.Println("成功写入 mykey")

    // 取出键值对
    val, err := rdb.Get(ctx, "mykey").Result()
    if err == redis.Nil {
        fmt.Println("mykey 不存在")
    } else if err != nil {
        fmt.Println("读取 Redis 失败:", err)
        return
    } else {
        fmt.Println("mykey 的值是:", val)
    }

    // 存一个带过期时间的键
    err = rdb.Set(ctx, "temp_key", "This will expire", 10*time.Second).Err()
    if err != nil {
        fmt.Println("写入 temp_key 失败:", err)
        return
    }
    fmt.Println("成功写入 temp_key，10秒后过期")
}

NewClient

redis.Options

CPU 核数 * 2

CPU 核数 * 4

ReadTimeout

WriteTimeout

ctx

request.Context()

// 最佳实践的连接配置
rdb := redis.NewClient(&redis.Options{
    Addr:         "your_redis_host:6379",
    Password:     "your_password",
    DB:           0,
    PoolSize:     100,             // 连接池大小，根据实际并发调整
    MinIdleConns: 10,              // 最小空闲连接数
    DialTimeout:  5 * time.Second, // 连接超时
    ReadTimeout:  3 * time.Second, // 读取超时
    WriteTimeout: 3 * time.Second, // 写入超时
    PoolTimeout:  4 * time.Second, // 从连接池获取连接的超时
    IdleTimeout:  5 * time.Minute, // 空闲连接的关闭时间
})

type User struct {
    ID   string `json:"id"`
    Name string `json:"name"`
    Email string `json:"email"`
}

// 存储 User 对象
user := User{ID: "123", Name: "Alice", Email: "alice@example.com"}
jsonData, _ := json.Marshal(user)
err = rdb.Set(ctx, "user:123", jsonData, 0).Err()

// 读取 User 对象
val, err := rdb.Get(ctx, "user:123").Result()
if err == nil {
    var retrievedUser User
    json.Unmarshal([]byte(val), &retrievedUser)
    fmt.Printf("Retrieved user: %+v\n", retrievedUser)
}

HSet

HGet

HMSet

HMGet

// 存储 User 对象到 Hash
user := User{ID: "123", Name: "Alice", Email: "alice@example.com"}
// 使用 HMSet 批量设置 Hash 字段
// go-redis 提供了 HSet 方法，可以直接传入 map[string]interface{} 或 key-value 对
err = rdb.HSet(ctx, "user:123_hash", "id", user.ID, "name", user.Name, "email", user.Email).Err()
if err != nil {
    fmt.Println("存储 Hash 失败:", err)
}

// 读取 User 对象从 Hash
// 使用 HGetAll 获取所有字段
result, err := rdb.HGetAll(ctx, "user:123_hash").Result()
if err == nil {
    var retrievedUser User
    retrievedUser.ID = result["id"]
    retrievedUser.Name = result["name"]
    retrievedUser.Email = result["email"]
    fmt.Printf("Retrieved user from Hash: %+v\n", retrievedUser)
}

// 只更新一个字段
err = rdb.HSet(ctx, "user:123_hash", "name", "Alicia").Err()

LPush

RPop

SAdd

SMembers

ZAdd

ZRange

*redis.Cmd

Err()

Get

redis.Nil

val, err := rdb.Get(ctx, "non_existent_key").Result()
if err == redis.Nil {
    fmt.Println("键不存在，这很正常。")
} else if err != nil {
    fmt.Println("读取失败，可能网络问题或 Redis 宕机:", err)
    // 记录日志，触发告警等
} else {
    fmt.Println("成功读取:", val)
}

github.com/cenkalti/backoff

import (
    "github.com/cenkalti/backoff/v4" // 导入 backoff 库
)

// 示例：带指数退避的重试
operation := func() error {
    err := rdb.Set(ctx, "retry_key", "data", 0).Err()
    if err != nil {
        fmt.Println("尝试写入失败:", err)
    }
    return err
}

// 创建一个指数退避策略
b := backoff.NewExponentialBackOff()
b.MaxElapsedTime = 30 * time.Second // 最长重试时间

err = backoff.Retry(operation, b)
if err != nil {
    fmt.Println("多次重试后写入仍失败:", err)
} else {
    fmt.Println("写入成功 (可能经过重试)。")
}

github.com/sony/gobreaker