Go에서 컨텍스트를 사용하여 요청 결과 캐시의 자동 새로 고침을 구현하는 방법

Go에서 컨텍스트를 사용하여 요청 결과 캐시의 자동 새로 고침을 구현하는 방법

요약:
웹 애플리케이션 개발에서 사용자 경험을 향상시키기 위해 때로는 데이터베이스 또는 기타 액세스를 줄이기 위해 일부 요청의 결과를 캐시해야 합니다. 서비스. 그러나 캐시된 데이터의 유효 기간이 문제가 됩니다. 캐시가 만료되면 사용자가 만료된 데이터를 얻게 되어 잘못된 표시 및 작동이 발생할 수 있습니다. 이 기사에서는 캐시된 데이터의 적시성을 보장하기 위해 Go의 컨텍스트 패키지를 사용하여 요청 결과 캐시의 자동 새로 고침 기능을 구현하는 방법을 살펴보겠습니다.

1. 컨텍스트 패키지란 무엇인가요? Go 언어는 코루틴 간에 컨텍스트 정보를 전송하는 도구로 컨텍스트 패키지를 제공합니다. 컨텍스트 패키지의 Context 유형은 코루틴 실행을 제어하고 취소하기 위한 몇 가지 메서드와 속성을 제공합니다. 웹 요청을 처리할 때 컨텍스트 패키지를 통해 요청의 컨텍스트 정보를 전달하고 일부 관련 작업의 실행을 제어할 수 있습니다.
   
요청 결과 캐싱 구현
2. 먼저 요청 결과와 만료 시간을 저장할 캐시 구조를 정의해야 합니다. 코드는 다음과 같습니다.
   

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

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

위 코드에서는 맵을 사용하여 캐시 항목을 저장합니다. 여기서 키는 요청과 관련된 고유 식별자이고 값은 캐시 항목 세부정보(예: 결과 및 만료)입니다. 시간). 동시성 안전을 보장하기 위해 뮤텍스 잠금을 사용합니다.

다음으로 캐시 데이터를 가져오는 함수를 작성해야 합니다. 이 함수는 먼저 요청 결과가 캐시에 존재하는지 확인하고 만료되었는지 여부를 확인합니다. 캐시된 결과가 존재하고 만료되지 않은 경우 캐시된 데이터가 직접 반환됩니다. 그렇지 않으면 실제 요청을 수행하고 결과를 캐시해야 합니다. 코드는 다음과 같습니다.

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
}

위 코드에서는 동시성 안전을 보장하기 위해 읽기 잠금을 사용하여 캐시 항목을 읽습니다. 캐시 항목이 존재하고 만료되지 않은 경우 캐시 결과가 직접 반환됩니다. 그렇지 않으면 실제 요청을 시작하고 요청 결과를 캐시에 저장합니다.

캐시 새로 고침
3. 캐시된 데이터의 적시성을 보장하려면 정기적으로 캐시를 새로 고쳐야 합니다. Go에서는 컨텍스트 패키지의 WithDeadline 함수를 사용하여 기한을 설정하고 시간 초과 후 해당 작업을 자동으로 취소할 수 있습니다. 이 기능을 사용하여 캐시를 자동으로 새로 고칠 수 있습니다. 코드는 다음과 같습니다.
   

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

위 코드에서는 Ticker 객체를 사용하여 makeRequest 함수를 정기적으로 호출하여 캐시를 업데이트하는 동시에 select 문을 사용하여 컨텍스트 취소 신호를 수신하여 종료합니다. 컨텍스트가 취소된 후 새로 고침 루프.

사용 예
4. 다음으로 간단한 웹 애플리케이션을 사용하여 위의 캐시 구현을 사용하는 방법을 보여드리겠습니다. 코드는 다음과 같습니다.
   

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

위 예제 코드에서는 요청이 수신되면 캐시된 Get 메서드가 호출되어 데이터를 얻고 클라이언트에 반환됩니다. 동시에 컨텍스트 패키지를 사용하여 기한이 5초인 컨텍스트를 생성하고 이를 RefreshCache 메서드에 전달하여 캐시 새로 고침 시간을 제어합니다.

결론:

이 글에서는 Go의 컨텍스트 패키지를 사용하여 요청 결과 캐시의 자동 새로 고침 기능을 구현하는 방법을 소개합니다. 캐시 구조와 뮤텍스를 사용하여 동시성 안전성을 보장하고 컨텍스트 패키지의 기능을 사용하여 정기적으로 캐시를 새로 고치면 요청 결과를 간단히 캐시하고 데이터의 적시성을 보장할 수 있습니다. 위의 샘플 코드는 단순한 데모일 뿐이며 실제 사용에는 특정 요구 사항에 따라 적절한 수정 및 최적화가 필요할 수 있습니다.

위 내용은 Go에서 컨텍스트를 사용하여 요청 결과 캐시의 자동 새로 고침을 구현하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!