在Beego中使用Redis实现数据缓存

go get github.com/gomodule/redigo/redis

redis_host = localhost
redis_port = 6379
redis_password = 
redis_db = 0

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

redis_host := beego.AppConfig.String("redis_host")
redis_port := beego.AppConfig.String("redis_port")
redis_password := beego.AppConfig.String("redis_password")
redis_db := beego.AppConfig.String("redis_db")
redis_pool := &redis.Pool{
    MaxIdle:     3,
    MaxActive:   5,
    IdleTimeout: 240 * time.Second,
    Dial: func() (redis.Conn, error) {
        c, err := redis.Dial("tcp", fmt.Sprintf("%s:%s", redis_host, redis_port))
        if err != nil {
            return nil, err
        }
        if redis_password != "" {
            if _, err := c.Do("AUTH", redis_password); err != nil {
                c.Close()
                return nil, err
            }
        }
        if redis_db != "" {
            if _, err := c.Do("SELECT", redis_db); err != nil {
                c.Close()
                return nil, err
            }
        }
        return c, nil
    },
}
defer redis_pool.Close()

conn := redis_pool.Get()
defer conn.Close()

key := "cache_key"
value := "cache_value"
expiration := 1800 // 单位为秒，表示缓存时间为30分钟
_, err := conn.Do("SET", key, value, "EX", expiration)
if err != nil {
    // 处理错误
}

conn := redis_pool.Get()
defer conn.Close()

key := "cache_key"
value, err := redis.String(conn.Do("GET", key))
if err == redis.ErrNil {
    // 缓存不存在
} else if err != nil {
    // 处理错误
} else {
    // 使用缓存数据
}

conn := redis_pool.Get()
defer conn.Close()

key := "cache_key"
_, err := conn.Do("DEL", key)
if err != nil {
    // 处理错误
}