Mengapa cache redis saya hanya mengembalikan data separa

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.

Kandungan soalan

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" }

Penyelesaian

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.

Tetapan

Arahan yang saya gunakan ialah:

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

Sekarang, mari bertukar kepada kod.

Program

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):

1. Tidak banyak yang perlu diperkatakan dalam pemulaan pelanggan. Kami memulakan pelanggan menunjuk ke contoh tempatan
2. Kemudian kami menyediakan pangkalan data dengan beberapa data palsu
3. Kami cuba mendapatkan data daripada contoh redis. Jika ia ditemui, kami mencetaknya dan menamatkan program
4. Jika data tidak ditemui dalam cache, maka kami mendapatkannya dari pangkalan data
5. Akhir sekali, jika kita mendapat data daripada pangkalan data, adalah selamat untuk mengandaikan bahawa kita harus meletakkannya dalam cache juga

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!