Golang을 사용하여 RESTful API를 구축하고 캐싱을 사용하는 방법은 무엇입니까?

Golang으로 RESTful API를 구축할 때 캐시 통합: Gin을 사용하여 API를 생성하고, Redis 캐시를 통합하고, 캐시된 값을 관리하기 위해 캐시 레이어를 정의하고, Redis에서 데이터를 가져오고 설정합니다.

Golang을 사용하여 RESTful API를 구축할 때 캐싱을 통합하는 방법

RESTful API를 구축할 때 캐싱을 사용하면 성능을 크게 향상시키고 서버 부하를 줄이며 사용자 경험을 향상시킬 수 있습니다. 이 문서에서는 RESTful API를 구축하고 Golang을 사용하여 캐싱을 통합하는 방법을 안내합니다.

Gin을 사용하여 RESTful API 만들기

먼저 Gin 프레임워크를 사용하여 새로운 Golang RESTful API를 만듭니다.

import (
    "github.com/gin-gonic/gin"
)

func main() {
    r := gin.Default()
    r.GET("/api/v1/users", GetUsers)
    r.Run()
}

Redis Cache 통합

캐싱을 사용하려면 가용성이 높은 키-값인 Redis를 사용합니다. 가게 . Redis가 설치되어 실행 중인지 확인하세요.

Golang에서는 redigo 라이브러리를 사용하여 Redis에 연결할 수 있습니다.

import (
    "time"

    "github.com/gomodule/redigo/redis"
)

// redisPool is a global variable to manage the Redis connection pool.
var redisPool *redis.Pool

func init() {
    redisPool = &redis.Pool{
        MaxIdle:   10,
        MaxActive: 10,
        IdleTimeout: 30 * time.Second,
        Dial: func() (redis.Conn, error) {
            return redis.Dial("tcp", "localhost:6379")
        },
    }
}

Cache Layer

이제 캐시 관리를 위한 새 레이어를 정의해 보겠습니다. 이 레이어는 캐시된 값을 가져오고 설정하고 삭제하는 기능을 제공합니다.

import (
    "time"

    "github.com/gomodule/redigo/redis"
)

type Cache struct {
    pool *redis.Pool
}

func NewCache(pool *redis.Pool) *Cache {
    return &Cache{
        pool: pool,
    }
}

func (c *Cache) Get(key string) ([]byte, error) {
    conn := c.pool.Get()
    defer conn.Close()

    return redis.Bytes(conn.Do("GET", key))
}

func (c *Cache) Set(key string, value string) error {
    conn := c.pool.Get()
    defer conn.Close()

    _, err := conn.Do("SET", key, value)
    return err
}

func (c *Cache) Delete(key string) error {
    conn := c.pool.Get()
    defer conn.Close()

    _, err := conn.Do("DEL", key)
    return err
}

캐싱 사용

Gin 핸들러 함수에서는 캐싱 레이어를 사용하여 API 응답을 캐시할 수 있습니다. 다음은 수정된 GetUsers 핸들러 함수입니다.

func GetUsers(c *gin.Context) {
    // 获取 Redis 缓存
    key := "users"
    cachedBytes, err := cache.Get(key)
    if err != nil {
        // 缓存中没有值，从数据库中获取
        users, err := getUserFromDB()
        if err != nil {
            c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
            return
        }

        // 将 users 序列化为 JSON 并存储在缓存中
        userJSON, err := json.Marshal(users)
        if err != nil {
            c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
            return
        }

        err = cache.Set(key, string(userJSON))
        if err != nil {
            c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
            return
        }

        c.JSON(http.StatusOK, users)
    } else {
        // 从缓存中获取值，反序列化回 []User 类型
        var users []User
        err := json.Unmarshal(cachedBytes, &users)
        if err != nil {
            c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
            return
        }

        c.JSON(http.StatusOK, users)
    }
}

// getUserFromDB 从数据库中获取用户
func getUserFromDB() ([]User, error) {
    // 假设这是从数据库获取用户数据的模拟函数
    return []User{{ID: 1, Name: "John"}}, nil
}

이제 API는 먼저 캐시에서 응답을 가져오고, 값이 캐시에 없으면 데이터베이스에서 데이터를 가져와 캐시에 저장합니다. 이렇게 하면 중복 요청된 데이터베이스 쿼리가 크게 줄어들어 성능이 향상됩니다.

위 내용은 Golang을 사용하여 RESTful API를 구축하고 캐싱을 사용하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!