eta_bridge/init_serve/redis.go

package init_serve

import (
	"eta/eta_bridge/global"
	"eta/eta_bridge/utils"
	"fmt"
)

//func Redis() {
//	redisConf := global.CONFIG.Redis
//	client := redis.NewClient(&redis.Options{
//		Addr:     redisConf.Address,
//		Password: redisConf.Password,
//		DB:       redisConf.Db,
//		//PoolSize: 10, //连接池最大socket连接数，默认为10倍CPU数， 10 * runtime.NumCPU（暂不配置）
//	})
//	_, err := client.Ping(context.TODO()).Result()
//	if err != nil {
//		global.LOG.Error("redis 链接失败:", err)
//		panic("redis 链接失败:" + err.Error())
//	}
//
//	//全局赋值redis链接
//	global.Redis = client
//}
//
//func RedisTool() {
//	fmt.Println("init RedisTool start")
//	redisConf := global.CONFIG.Redis
//	fmt.Println(redisConf)
//	REDIS_CACHE := fmt.Sprintf(`{"key":"redis","conn":"%s","password":"%s"}`, redisConf.Address, redisConf.Password)
//	fmt.Println("REDIS_CACHE:" + REDIS_CACHE)
//	global.Rc, global.Re = cache.NewCache(REDIS_CACHE) //初始化缓存
//	if global.Re != nil {
//		fmt.Println(global.Re)
//		panic(global.Re)
//	}
//	fmt.Println("init RedisTool end")
//}

func Redis() {
	var conf string
	//switch global.CONFIG.Redis.ServeType {
	//case "cluster": // 集群
	//	conf = fmt.Sprintf(`{"key":"redis","conn":"%s","password":"%s"}`,global.CONFIG.Redis.Address, global.CONFIG.Redis.Password)
	//default: // 默认走单机
	//	redisClient, err = redis.InitStandaloneRedis(conf)
	//}
	conf = fmt.Sprintf(`{"key":"redis","conn":"%s","password":"%s"}`, global.CONFIG.Redis.Address, global.CONFIG.Redis.Password)
	redisClient, err := utils.InitRedis(global.CONFIG.Redis.ServeType, conf)

	if err != nil {
		fmt.Println("redis链接异常：", err)
		panic(any(err))
	}
	global.Rc = redisClient
}