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 postgresdocker 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)
}
}
讓我們仔細看看每個部分（按編號評論劃分）：
在這兩種情況下，我們都使用相同的欄位來取得相同數量的資料。因此，如果您堅持這個範例並將其調整為您的模型和項目類型（我的不是網頁項目），您應該會很好。如果您仍然遇到問題，請告訴我。謝謝！
以上是為什麼我的redis快取只回傳部分數據的詳細內容。更多資訊請關注PHP中文網其他相關文章！
