pkg/db/redis.go

package db

import (
	"WarpGPT/pkg/env"
	"WarpGPT/pkg/logger"
	"context"
	"github.com/redis/go-redis/v9"
)

func GetRedisClient() (*redis.Client, error) {

	redisClient := redis.NewClient(&redis.Options{
		Addr:           env.E.RedisAddress,
		Password:       env.E.RedisPasswd,
		DB:             env.E.RedisDB,
		MaxRetries:     3,
		MaxActiveConns: 20,
	})

	_, err := redisClient.Ping(context.Background()).Result()
	if err != nil {
		return nil, err
	}
	logger.Log.Info("成功连接到Redis")

	return redisClient, nil
}