Files
GoFilm/server/plugin/db/redis.go
2023-07-05 00:01:59 +08:00

38 lines
677 B
Go

package db
import (
"context"
"github.com/redis/go-redis/v9"
"server/config"
"time"
)
/*
redis 工具类
*/
var Rdb *redis.Client
var Cxt = context.Background()
// InitRedisConn 初始化redis客户端
func InitRedisConn() error {
Rdb = redis.NewClient(&redis.Options{
Addr: config.RedisAddr,
Password: config.RedisPassword,
DB: config.RedisDBNo,
PoolSize: 10, // 最大连接数
DialTimeout: time.Second * 10, // 超时时间
})
// 测试连接是否正常
_, err := Rdb.Ping(Cxt).Result()
if err != nil {
panic(err)
}
return nil
}
// CloseRedis 关闭redis连接
func CloseRedis() error {
return Rdb.Close()
}