利用Redis和Golang构建分布式缓存系统：如何快速读写数据

import (
    "github.com/go-redis/redis/v8"
    "context"
)

func NewRedisClient() *redis.Client {
    rdb := redis.NewClient(&redis.Options{
        Addr:     "localhost:6379",
        Password: "", // Redis密码
        DB:       0,  // 使用默认数据库
    })

    return rdb
}

func GetFromCache(ctx context.Context, key string) (string, error) {
    rdb := NewRedisClient()

    val, err := rdb.Get(ctx, key).Result()

    if err == redis.Nil {
        return "", nil
    } else if err != nil {
        return "", err
    }

    return val, nil
}

func SetToCache(ctx context.Context, key string, value string, expiration time.Duration) error {
    rdb := NewRedisClient()

    err := rdb.Set(ctx, key, value, expiration).Err()

    if err != nil {
        return err
    }

    return nil
}

func DeleteFromCache(ctx context.Context, key string) error {
    rdb := NewRedisClient()

    err := rdb.Del(ctx, key).Err()

    if err != nil {
        return err
    }

    return nil
}

func GetDataFromDatabase(ctx context.Context, key string) (string, error) {
    // 从数据库中获取数据，例如通过SQL查询
    val, err := queryDataFromDatabase(key)

    if err != nil {
        return "", err
    }

    // 将数据保存到缓存中
    err = SetToCache(ctx, key, val, time.Minute*10)

    if err != nil {
        return "", err
    }

    return val, nil
}

func GetData(ctx context.Context, key string) (string, error) {
    // 尝试从缓存中获取数据
    val, err := GetFromCache(ctx, key)

    if err != nil {
        return "", err
    }

    if val != "" {
        // 缓存命中，直接返回数据
        return val, nil
    }

    // 缓存未命中，从数据库获取数据并保存到缓存中
    return GetDataFromDatabase(ctx, key)
}