為什麼我的redis快取只回傳部分數據-Golang-PHP中文網

為什麼我的redis快取只回傳部分數據

php小編香蕉在使用redis快取時，可能會遇到一個常見問題：為什麼我的redis快取只回傳部分資料？這個問題可能有多種原因，包括快取設定不當、快取鍵名衝突、快取過期等。在解決這個問題之前，我們需要仔細檢查程式碼和配置，確保快取的正常運作。本文將為您分析可能的原因，並提供解決方案，幫助您解決這個問題，確保redis快取返回完整的資料。

問題內容

此函數檢查 postgres 與 redis 快取的實作情況當我發出 get 請求時，第一個結果會傳回所有數據，但是當我發出下一個結果時，資料的某些欄位遺失

func (usr *UserImplementation) GetAllUsers(ctx context.Context) ([]models.User, error) {
 
    cachedUsers, err := databaseapi.Redis_CacheDB_Api()
    if err != nil {
        return nil, fmt.Errorf("error connecting to Redis cache: %v", err)
    }
 
    // pipe := cachedUsers.TxPipeline()
 
    cachedData, err := cachedUsers.Get(ctx, "users").Result()
    if err != nil && err != redis.Nil {
        return nil, fmt.Errorf("error retrieving cached data: %v", err)
    }
 
    if cachedData != "" {
        // Data found in the cache, return the cached data
        var cachedUsers []models.User
        err := json.Unmarshal([]byte(cachedData), &cachedUsers)
        if err != nil {
            return nil, fmt.Errorf("error unmarshaling cached data: %v", err)
        }
        return cachedUsers, nil
    }
 
    users, err := usr.pg.Postgres_DB_Api().DB.GetAllUsers(ctx)
    if err != nil {
        return nil, fmt.Errorf("error: %v", err.Error())
    }
 
    cacheData, err := json.Marshal(users)
    if err != nil {
        return nil, fmt.Errorf("error marshaling data for caching: %v", err)
    }
 
    expiration := time.Hour
 
    err = cachedUsers.Set(ctx, "users", string(cacheData), expiration).Err()
    if err != nil {
        return nil, fmt.Errorf("error caching data: %v", err)
    }
 
    return models.DatabaseUsersToUsers(users), nil
 
}

登入後複製

這是我的使用者結構：type user struct { id uuid.uuid json:"id" 名字字串 json:"first_name" 姓氏字串 json:"last_name" 其他名稱字串 json:"other_name" 使用者名稱字串 json:"user_name" 密碼字串 json:"密碼" 電子郵件字串 json:"email" 設定檔圖像字串 json:"profile_image" 狀態字串 json:"status" isadmin bool json:"is_admin" 角色字串 json:"角色" 性別字串 json:"性別" 電話號碼字串 json:"phone_number" createdat time.時間 json:"created_at" updatedat time.時間 json:"updated_at" }

解決方法

我整理了一個小範例來嘗試幫助您。作為前提，我簡化了您的範例，只是為了提供此處重要的內容。由於程式的某些部分尚未共享，我不得不做一些猜測。如果這個例子沒有用，請讓我知道缺少什麼，我會更新我的答案。讓我們從我使用 docker 在本地運行 postgres/redis 的命令開始。

設定

我使用的命令是：

docker run -d -p 54322:5432 -e postgres_password=postgres postgres
docker run -d --name redis-stack -p 6379:6379 -p 8001:8001 redis/redis-stack:latest

#現在，讓我們切換到程式碼。

程式

package main
 
import (
    "context"
    "encoding/json"
    "fmt"
    "time"
 
    "github.com/redis/go-redis/v9"
    "gorm.io/driver/postgres"
    "gorm.io/gorm"
)
 
type user struct {
    ID        int    `json:"id"`
    FirstName string `json:"first_name"`
    LastName  string `json:"last_name"`
}
 
func main() {
    // 1. instantiate clients
    dsn := "host=localhost port=54322 user=postgres password=postgres"
    db, err := gorm.Open(postgres.Open(dsn))
    if err != nil {
        panic(err)
    }
    redisClient := redis.NewClient(&redis.Options{
        Addr:     ":6379",
        Password: "",
        DB:       0,
    })
 
    // 2. automigrate objects & seed dummy data
    db.AutoMigrate(&user{})
    db.Create(&user{ID: 1, FirstName: "John", LastName: "Doe"})
    db.Create(&user{ID: 2, FirstName: "Suzy", LastName: "White"})
 
    // 3. attempt to retrieve from cache
    var users []user
    cachedUsers, err := redisClient.Get(context.Background(), "users").Result()
    if err != nil && err != redis.Nil {
        panic(fmt.Errorf("err retrieving cached data: %v", err))
    }
    if cachedUsers != "" {
        if err := json.Unmarshal([]byte(cachedUsers), &users); err != nil {
            panic(fmt.Errorf("err while unmarshaling data: %v", err))
        }
        fmt.Println("users taken from Redis")
        for _, v := range users {
            fmt.Println(v)
        }
        return
    }
 
    // 4. retrieve from the DB
    if err := db.Model(&user{}).Find(&users).Error; err != nil {
        panic(fmt.Errorf("err while retrieving from DB: %v", err))
    }
 
    // 5. set the key within the cache
    rawUsers, err := json.Marshal(users)
    if err != nil {
        panic(fmt.Errorf("err while marshaling users: %v", err))
    }
    if err := redisClient.Set(context.Background(), "users", rawUsers, time.Minute*15).Err(); err != nil {
        panic(fmt.Errorf("err while setting key in cache: %v", err))
    }
    fmt.Println("users taken from DB")
    for _, v := range users {
        fmt.Println(v)
    }
}