chunhao_invest/bootstrap/redis.go

package bootstrap

import (
	"context"
	"designs/config"
	"designs/global"
	"github.com/go-redis/redis/v8"
	"go.uber.org/zap"
)

func InitializeRedis() *redis.Client {
	client := redis.NewClient(&redis.Options{
		Addr:     config.Get("redis.host") + ":" + config.Get("redis.port"),
		Password: config.Get("redis.password"), // no password set
		DB:       config.GetInt("redis.db"),    // use default DB

		//Addr:     "localhost:6379", // Redis 服务器地址和端口
		//Password: "",               // Redis 访问密码，如果没有可以为空字符串
		//DB:       0,                // 使用的 Redis 数据库编号，默认为 0
	})
	_, err := client.Ping(context.Background()).Result()
	if err != nil {
		global.App.Log.Error("Redis connect ping failed, err:", zap.Any("err", err))
		return nil
	}
	return client
}

func UnInitializeRedis(client *redis.Client) {
	if client != nil {
		client.Close()
	}
}