beeblog/utils/redis.go

package utils

import (
	"fmt"
	"github.com/beego/beego/v2/server/web"
	"github.com/go-redis/redis"
)

const (
	REDIS_NETWORK = "tcp"
	REDIS_DB      = 7
)

type RedisClient struct {
}

func (r RedisClient) GetClient() *redis.Client {
	REDIS_HOST, _ := web.AppConfig.String("redisHost")
	REDIS_PORT, _ := web.AppConfig.String("redisPort")
	REDIS_PASSWORD, _ := web.AppConfig.String("redisPwd")
	options := redis.Options{
		Network:            REDIS_NETWORK,
		Addr:               fmt.Sprintf("%s:%s", REDIS_HOST, REDIS_PORT),
		Dialer:             nil,
		OnConnect:          nil,
		Password:           REDIS_PASSWORD,
		DB:                 REDIS_DB,
		MaxRetries:         0,
		MinRetryBackoff:    0,
		MaxRetryBackoff:    0,
		DialTimeout:        0,
		ReadTimeout:        0,
		WriteTimeout:       0,
		PoolSize:           0,
		MinIdleConns:       0,
		MaxConnAge:         0,
		PoolTimeout:        0,
		IdleTimeout:        0,
		IdleCheckFrequency: 0,
		TLSConfig:          nil,
	}
	// 新建一个client
	clientRedis := redis.NewClient(&options)
	return clientRedis
}

func (r RedisClient) CloseClient(client *redis.Client) {
	defer client.Close()
}