|
|
|
|
@ -5,29 +5,17 @@ import (
|
|
|
|
|
"dsBaseRpc/Utils/ConfigUtil"
|
|
|
|
|
"dsBaseRpc/Utils/LogUtil"
|
|
|
|
|
"github.com/go-redis/redis/v7"
|
|
|
|
|
redigoRedis "github.com/gomodule/redigo/redis"
|
|
|
|
|
"time"
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
var (
|
|
|
|
|
// 定义redis链接池
|
|
|
|
|
RedisClient *redis.Client
|
|
|
|
|
//这个是为了使用OAuth2类库，引入的redis池，也是没办法之举~
|
|
|
|
|
Pool *redigoRedis.Pool
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
func init() {
|
|
|
|
|
// 从配置文件获取redis的ip以及db
|
|
|
|
|
var redisHost = ConfigUtil.RedisIp + ":" + ConfigUtil.RedisPort
|
|
|
|
|
Pool = &redigoRedis.Pool{
|
|
|
|
|
Dial: func() (redigoRedis.Conn, error) {
|
|
|
|
|
conn, err := redigoRedis.Dial("tcp", redisHost)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return nil, err
|
|
|
|
|
}
|
|
|
|
|
return conn, nil
|
|
|
|
|
},
|
|
|
|
|
}
|
|
|
|
|
//这个是以后项目中广泛使用的redis池
|
|
|
|
|
RedisClient = redis.NewClient(&redis.Options{
|
|
|
|
|
Addr: redisHost, // Redis地址
|
|
|
|
|
|
