Cara menggunakan konteks dalam Go untuk melaksanakan muat semula automatik cache hasil permintaan

Cara menggunakan konteks dalam Pergi untuk melaksanakan penyegaran automatik cache hasil permintaan

Abstrak:
Dalam pembangunan aplikasi web, untuk meningkatkan pengalaman pengguna, kadangkala kita perlu cache hasil beberapa permintaan untuk mengurangkan akses kepada pangkalan data atau lain-lain perkhidmatan. Walau bagaimanapun, tempoh sah data cache adalah masalah Cache tamat tempoh boleh menyebabkan pengguna mendapatkan data tamat tempoh, mengakibatkan paparan dan operasi yang salah. Dalam artikel ini, kami akan meneroka cara menggunakan pakej konteks Go untuk melaksanakan fungsi muat semula automatik cache hasil permintaan untuk memastikan ketepatan masa data cache.

1. Apakah pakej konteks bahasa Go menyediakan pakej konteks sebagai alat untuk memindahkan maklumat konteks antara coroutine. Jenis Konteks dalam pakej konteks menyediakan beberapa kaedah dan sifat untuk mengawal dan membatalkan pelaksanaan coroutine. Apabila memproses permintaan web, kami boleh menghantar maklumat konteks permintaan melalui pakej konteks dan mengawal pelaksanaan beberapa operasi yang berkaitan.
   
Melaksanakan cache hasil permintaan
2. Pertama, kita perlu menentukan struktur cache untuk menyimpan keputusan permintaan dan masa tamat tempohnya. Kodnya adalah seperti berikut:
   

type CacheItem struct {
    result      interface{}
    expireAt    time.Time
}

type Cache struct {
    cacheMap    map[string]CacheItem
    mutex       sync.RWMutex
}

Dalam kod di atas, kami menggunakan peta untuk menyimpan item cache, dengan kuncinya ialah pengecam unik yang berkaitan dengan permintaan dan nilainya ialah butiran item cache (seperti hasil dan tamat tempoh masa). Untuk memastikan keselamatan serentak, kami menggunakan kunci mutex.

Seterusnya, kita perlu menulis fungsi untuk mendapatkan data cache. Fungsi ini mula-mula menyemak sama ada hasil permintaan wujud dalam cache dan menentukan sama ada ia telah tamat tempoh. Jika hasil cache wujud dan belum tamat tempoh, data cache dikembalikan terus. Jika tidak, kita perlu membuat permintaan sebenar dan cache hasilnya. Kodnya adalah seperti berikut:

func (c *Cache) Get(key string) interface{} {
    c.mutex.RLock()
    defer c.mutex.RUnlock()

    item, ok := c.cacheMap[key]
    if ok && item.expireAt.After(time.Now()) {
        return item.result
    }

    // 发起请求并更新缓存
    result := makeRequest(key)
    c.cacheMap[key] = CacheItem{result: result, expireAt: time.Now().Add(time.Minute)}

    return result
}

Dalam kod di atas, kami menggunakan kunci baca untuk membaca item cache untuk memastikan keselamatan serentak. Jika item cache wujud dan belum tamat tempoh, keputusan cache dikembalikan secara langsung, jika tidak, kami memulakan permintaan sebenar dan menyimpan hasil permintaan dalam cache.

Segarkan semula cache
3. Untuk memastikan ketepatan masa data cache, kami perlu memuat semula cache dengan kerap. Dalam Go, kami boleh menggunakan fungsi WithDeadline bagi pakej konteks untuk menetapkan tarikh akhir dan secara automatik membatalkan operasi yang sepadan selepas tamat masa. Kami boleh menggunakan ciri ini untuk memuat semula cache secara automatik. Kodnya adalah seperti berikut:
   

func (c *Cache) RefreshCache(ctx context.Context, key string) {
    ticker := time.NewTicker(time.Minute)
    defer ticker.Stop()

    for {
        select {
        case <-ticker.C:
            result := makeRequest(key)
            c.mutex.Lock()
            c.cacheMap[key] = CacheItem{result: result, expireAt: time.Now().Add(time.Minute)}
            c.mutex.Unlock()
        case <-ctx.Done():
            return
        }
    }
}

Dalam kod di atas, kami menggunakan objek Ticker untuk kerap memanggil fungsi makeRequest untuk mengemas kini cache Pada masa yang sama, kami menggunakan pernyataan pilih untuk mendengar isyarat pembatalan konteks untuk keluar gelung muat semula selepas konteks dibatalkan.

Contoh Penggunaan
4. Seterusnya, kami akan menggunakan aplikasi web mudah untuk menunjukkan cara menggunakan pelaksanaan cache di atas. Kod tersebut adalah seperti berikut:
   

package main

import (
    "context"
    "fmt"
    "net/http"
    "sync"
    "time"
)

type CacheItem struct {
    result   interface{}
    expireAt time.Time
}

type Cache struct {
    cacheMap map[string]CacheItem
    mutex    sync.RWMutex
}

func makeRequest(key string) interface{} {
    // 模拟请求耗时
    time.Sleep(time.Second)
    return fmt.Sprintf("result for %s", key)
}

func (c *Cache) Get(key string) interface{} {
    c.mutex.RLock()
    defer c.mutex.RUnlock()

    item, ok := c.cacheMap[key]
    if ok && item.expireAt.After(time.Now()) {
        return item.result
    }

    result := makeRequest(key)
    c.cacheMap[key] = CacheItem{result: result, expireAt: time.Now().Add(time.Minute)}

    return result
}

func (c *Cache) RefreshCache(ctx context.Context, key string) {
    ticker := time.NewTicker(time.Minute)
    defer ticker.Stop()

    for {
        select {
        case <-ticker.C:
            result := makeRequest(key)
            c.mutex.Lock()
            c.cacheMap[key] = CacheItem{result: result, expireAt: time.Now().Add(time.Minute)}
            c.mutex.Unlock()
        case <-ctx.Done():
            return
        }
    }
}

func main() {
    cache := &Cache{cacheMap: make(map[string]CacheItem)}

    http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
        ctx, cancel := context.WithDeadline(context.Background(), time.Now().Add(time.Second*5))
        defer cancel()

        key := r.URL.Path

        result := cache.Get(key)
        fmt.Fprintf(w, "%s: %s", key, result)

        // 启动刷新缓存的协程
        go cache.RefreshCache(ctx, key)
    })

    http.ListenAndServe(":8080", nil)
}

Dalam kod contoh di atas, kami mentakrifkan pelayan HTTP mudah Apabila permintaan diterima, kaedah Dapatkan yang dicache dipanggil untuk mendapatkan data dan dikembalikan kepada klien. Pada masa yang sama, kami menggunakan pakej konteks untuk mencipta konteks dengan tarikh akhir 5 saat dan menyerahkannya kepada kaedah RefreshCache untuk mengawal masa muat semula cache.

Kesimpulan:

Artikel ini memperkenalkan cara menggunakan pakej konteks Go untuk melaksanakan fungsi muat semula automatik cache hasil permintaan. Dengan menggunakan struktur cache dan kunci mutex untuk memastikan keselamatan serentak, dan menggunakan ciri pakej konteks untuk menyegarkan semula cache secara kerap, kami hanya boleh cache hasil permintaan dan memastikan ketepatan masa data. Kod sampel di atas hanyalah demonstrasi mudah Penggunaan sebenar mungkin memerlukan pengubahsuaian dan pengoptimuman yang sesuai berdasarkan keperluan khusus.

Atas ialah kandungan terperinci Cara menggunakan konteks dalam Go untuk melaksanakan muat semula automatik cache hasil permintaan. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!