You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
47 lines
908 B
47 lines
908 B
package confignosql
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
|
|
"github.com/redis/go-redis/v9"
|
|
)
|
|
|
|
type RedisSetUpV9 struct {
|
|
RedisClusterV9 RedisConfitSetUp `mapstructure:"redisCluster" json:"redisCluster" yaml:"redisCluster"` //内网集群
|
|
}
|
|
|
|
/*
|
|
*
|
|
@ 作者: 秦东
|
|
@ 时间: 2023-12-13 11:14:06
|
|
@ 功能: 开启v9集群
|
|
@ 参数
|
|
|
|
#
|
|
|
|
@ 返回值
|
|
|
|
#
|
|
|
|
@ 方法原型
|
|
|
|
#
|
|
*/
|
|
func (r *RedisConfitSetUp) OpenRedisClan() (redisClient *redis.Client) {
|
|
fmt.Printf("开1启%v Redis库 %v\n", r.UrlPathList, r.Name)
|
|
for _, v := range r.UrlPathList {
|
|
redisClient = redis.NewClient(&redis.Options{
|
|
Addr: v,
|
|
Password: r.PassWord,
|
|
DB: 0,
|
|
})
|
|
pingLink, err := redisClient.Ping(context.Background()).Result()
|
|
if err == nil {
|
|
fmt.Printf("%v Redis集群链接成功！==%v===>%v\n", v, r.Name, pingLink)
|
|
return
|
|
}
|
|
}
|
|
fmt.Printf("%v Redis集群链接失败！==%v\n", r.UrlPathList, r.Name)
|
|
return
|
|
}
|
|
|