Menggunakan Redis dan Golang untuk membina sistem cache teragih: cara membaca dan menulis data dengan cepat-Redis-php.cn

Menggunakan Redis dan Golang untuk membina sistem cache teragih: cara membaca dan menulis data dengan cepat

WBOY

Lepaskan： 2023-07-31 22:42:50

asal

1488 orang telah melayarinya

Membina sistem cache teragih menggunakan Redis dan Golang: Cara membaca dan menulis data dengan cepat

Pengenalan:
Dalam pembangunan aplikasi moden, caching merupakan bahagian penting dalam meningkatkan prestasi dan mempercepatkan akses data. Sistem cache teragih boleh menyelesaikan masalah kependaman tinggi capaian data dengan berkesan dan menyediakan operasi baca dan tulis yang cekap. Artikel ini akan memperkenalkan cara menggunakan Redis dan Golang untuk membina sistem cache teragih yang mudah tetapi cekap dan memberikan contoh kod.

Persediaan
Pertama, kita perlu memasang persekitaran pembangunan Redis dan Golang. Anda boleh memuat turun versi terkini Redis dari tapak web rasmi dan memasang serta mengkonfigurasinya mengikut dokumentasi rasmi. Untuk Golang, anda boleh memuat turunnya dari laman web rasmi dan ikut arahan untuk memasangnya. Pastikan anda telah menetapkan pembolehubah persekitaran dengan betul.
Gunakan Redis sebagai cache
Redis ialah sistem storan struktur data dalam memori sumber terbuka yang turut menyokong kegigihan. Kami akan menggunakan Redis sebagai perkhidmatan caching kami. Di Golang, gunakan pustaka go-redis untuk menyambung dan mengendalikan Redis.

Mula-mula, kita perlu mengimport perpustakaan go-redis dalam projek Golang:

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

Salin selepas log masuk

Kemudian, kita perlu mencipta instance klien Redis:

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

    return rdb
}

Salin selepas log masuk

Di sini kita mencipta satu bernama NewRedisClient</code > Fungsi, yang mengembalikan contoh klien Redis. Dalam aplikasi sebenar, anda mungkin perlu menyesuaikannya mengikut konfigurasi anda sendiri. <code>NewRedisClient的函数，它返回一个Redis客户端实例。在实际的应用中，你可能需要根据自己的配置进行自定义。

缓存读写操作
在分布式缓存系统中，我们经常需要执行读写操作。下面是一些常见的读写操作的示例：

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
}

Salin selepas log masuk

在上述代码中，GetFromCache函数用于从缓存中获取值，SetToCache函数用于将值设置到缓存中，DeleteFromCache函数用于从缓存中删除值。这些函数使用了上一步中创建的Redis客户端实例进行操作。

使用缓存系统
现在我们已经有了一个简单的分布式缓存系统，我们可以在应用中使用它来提高读写数据的效率。下面是一个使用缓存系统的示例：

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

Salin selepas log masuk

在上述代码中，GetDataFromDatabase函数用于从数据库中获取数据，并通过SetToCache函数保存到缓存中。GetData函数尝试从缓存中获取数据，如果缓存命中，则直接返回数据；否则，调用GetDataFromDatabase

Dalam sistem cache teragih, kita selalunya perlu melakukan operasi baca dan tulis. Berikut ialah beberapa contoh operasi baca dan tulis biasa:

Dalam kod di atas, fungsi GetFromCache digunakan untuk mendapatkan nilai daripada cache dan SetToCache fungsi digunakan untuk menetapkan nilai Tetapkan ke dalam cache, fungsi DeleteFromCache digunakan untuk memadam nilai daripada cache. Fungsi ini beroperasi menggunakan contoh klien Redis yang dibuat dalam langkah sebelumnya.

GetDataFromDatabase

SetToCache

GetData

GetDataFromDatabase

Atas ialah kandungan terperinci Menggunakan Redis dan Golang untuk membina sistem cache teragih: cara membaca dan menulis data dengan cepat. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!