Apabila menggunakan cache redis, anda mungkin menghadapi masalah biasa: Mengapa cache redis saya hanya mengembalikan sebahagian daripada data? Masalah ini mungkin mempunyai pelbagai punca, termasuk tetapan cache yang tidak betul, konflik nama kunci cache, tamat tempoh cache, dsb. Sebelum menyelesaikan masalah ini, kita perlu menyemak kod dan konfigurasi dengan teliti untuk memastikan bahawa cache berfungsi dengan baik. Artikel ini akan menganalisis kemungkinan punca untuk anda dan menyediakan penyelesaian untuk membantu anda menyelesaikan masalah ini dan memastikan bahawa cache redis mengembalikan data yang lengkap.
Fungsi ini menyemak pelaksanaan postgres dan cache redis Apabila saya membuat permintaan dapatkan, hasil pertama mengembalikan semua data, tetapi apabila saya membuat hasil seterusnya, beberapa medan data hilang
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 }
Ini ialah struktur pengguna saya: taip struct pengguna {
id uuid.uuid json:"id"
Rentetan nama json:"first_name"
Rentetan nama akhir json:"last_name"
Rentetan nama lain json:"other_name"
Rentetan nama pengguna json:"user_name"
Rentetan kata laluan json:"密码"
Rentetan e-mel json:"email"
Rentetan imej profil json:"profile_image"
rentetan status json:"status"
isadmin bool json:"is_admin"
rentetan peranan json:"角色"
Rentetan jantina json:"性别"
Rentetan nombor telefon json:"phone_number"
dicipta pada masa json:"created_at"
dikemas kini pada masa json:"updated_at"
}
Saya mengumpulkan contoh kecil untuk mencuba dan membantu anda. Sebagai premis, saya telah memudahkan contoh anda hanya untuk memberikan perkara yang penting di sini. Memandangkan beberapa bahagian program masih belum dikongsi, saya perlu membuat beberapa tekaan. Jika contoh ini tidak berfungsi, sila beritahu saya apa yang tiada dan saya akan mengemas kini jawapan saya. Mari kita mulakan dengan arahan saya untuk menjalankan postgres/redis secara tempatan menggunakan docker.
Arahan yang saya gunakan ialah:
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
Sekarang, mari bertukar kepada kod.
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) } }
Mari kita lihat dengan lebih dekat setiap bahagian (dibahagikan dengan komen bernombor):
Dalam kedua-dua kes kami menggunakan medan yang sama untuk mendapatkan jumlah data yang sama. Jadi, jika anda berpegang pada contoh ini dan menyesuaikannya dengan model dan jenis projek anda (saya bukan projek web), anda sepatutnya baik-baik saja. Jika anda masih mempunyai masalah sila beritahu saya. Terima kasih!
Atas ialah kandungan terperinci Mengapa cache redis saya hanya mengembalikan data separa. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!