go-db/factory/redis/redis_factory.go

package redis

import (
	"context"
	"fmt"
	"time"

	"git.x2erp.com/qdy/go-base/config"
	"github.com/go-redis/redis/v8"
)

var ctx = context.Background()

// RedisFactory Redis客户端工厂
type RedisFactory struct {
	config config.IConfig
}

// NewRedisFactory 创建Redis客户端工厂
func NewRedisFactory() (*RedisFactory, error) {
	cfg := config.GetConfig()

	if err := config.GetInitError(); err != nil {
		return nil, fmt.Errorf("failed to load config: %v", err)
	}

	if !cfg.IsRedisConfigured() {
		return nil, fmt.Errorf("redis configuration is incomplete")
	}

	return &RedisFactory{config: cfg}, nil
}

// CreateRedisClient 创建Redis客户端
func (f *RedisFactory) CreateRedisClient() *RedisClient {
	redisConfig := f.config.GetRedis()

	client := redis.NewClient(&redis.Options{
		Addr:     fmt.Sprintf("%s:%d", redisConfig.Host, redisConfig.Port),
		Password: redisConfig.Password,
		DB:       redisConfig.DB,
		PoolSize: redisConfig.PoolSize,
	})

	return &RedisClient{
		client: client,
	}
}

// RedisClient Redis客户端
type RedisClient struct {
	client *redis.Client
}

// Set 写入字符串值
func (c *RedisClient) Set(key string, value interface{}, expiration time.Duration) error {
	return c.client.Set(ctx, key, value, expiration).Err()
}

// Get 读取字符串值
func (c *RedisClient) Get(key string) (string, error) {
	return c.client.Get(ctx, key).Result()
}

// HSet 写入哈希字段
func (c *RedisClient) HSet(key string, values ...interface{}) error {
	return c.client.HSet(ctx, key, values...).Err()
}

// HGet 读取哈希字段
func (c *RedisClient) HGet(key, field string) (string, error) {
	return c.client.HGet(ctx, key, field).Result()
}

// HGetAll 读取整个哈希
func (c *RedisClient) HGetAll(key string) (map[string]string, error) {
	return c.client.HGetAll(ctx, key).Result()
}

// LPush 列表左推入
func (c *RedisClient) LPush(key string, values ...interface{}) error {
	return c.client.LPush(ctx, key, values...).Err()
}

// RPop 列表右弹出
func (c *RedisClient) RPop(key string) (string, error) {
	return c.client.RPop(ctx, key).Result()
}

// Del 删除键
func (c *RedisClient) Del(keys ...string) error {
	return c.client.Del(ctx, keys...).Err()
}

// Exists 检查键是否存在
func (c *RedisClient) Exists(keys ...string) (int64, error) {
	return c.client.Exists(ctx, keys...).Result()
}

// Close 关闭连接
func (c *RedisClient) Close() error {
	return c.client.Close()
}