1. redis操作需要引入 github.com/gomodule/redigo/redis 包
go get github.com/gomodule/redigo/redis
2.封装redis操作对象,使用时便可调用 redis的 地址、端口、密码 放配置文件,用config获取即可
package database
import (
"gin/config"
"time"
"github.com/gomodule/redigo/redis"
)
var RedisClient *redis.Pool
func init() {
// 建立连接池
RedisClient = &redis.Pool{
// 从配置文件获取maxidle以及maxactive,取不到则用后面的默认值
MaxIdle: 3, //最初的连接数量
// MaxActive:1000000, //最大连接数量
MaxActive: 0, //连接池最大连接数量,不确定可以用0(0表示自动定义),按需分配
IdleTimeout: 300 * time.Second, //连接关闭时间 300秒 (300秒不使用自动关闭)
Dial: func() (redis.Conn, error) { //要连接的redis数据库
c, err := redis.Dial("tcp", config.RedisHost+":"+config.RedisPort)
if err != nil {
return nil, err
}
if config.RedisPassword != "" {
if _, err := c.Do("AUTH", config.RedisPassword); err != nil {
c.Close()
return nil, err
}
}
return c, nil
},
}
}
3.redis存储数据和读取数据
//引入redis连接包 . "gin/database"
//存数据并设定过期时间(秒)
rc := RedisClient.Get()
defer rc.Close()
key := "aaabbbccc"
rc.Do("Set", key, "SUCCESS", "ex", 600)
// 引入 . "gin/database" 和 "github.com/gomodule/redigo/redis"
// 读取redis缓存数据
rc := RedisClient.Get()
defer rc.Close()
key := "aaabbb"
val, _ := redis.String(rc.Do("Get", key))
读取数据时,存入的数据类型可能是 int 或 string ,在存入时转成了interface{}类型, 可使用 redis包自带的方法进行对应转换,如果 string 就用 redis.String() int 就用redis.Int() 当然,其他类型还有一些其他的基础类型的转换方法 Int64 Uint64 Float64 Bytes Bool StringMap IntMap