Rabbit.Common.Redis 1.1.0

Rabbit.Common.Redis

Redis 缓存组件，支持二级缓存（内存 + Redis）。

安装

dotnet add package Rabbit.Common.Redis

依赖

• Rabbit.Common.Lite
• FreeRedis 1.5.5
• Microsoft.Extensions.Caching.Memory 10.0.1

功能

• 二级缓存: 内存缓存 + Redis 分布式缓存
• 连接管理: 支持多 Redis 实例
• 自动同步: 内存缓存与 Redis 自动同步

快速开始

1. 配置 Redis

using Rabbit.Common.Redis;

// 单实例
services.AddFreeRedisConfigure(
    "127.0.0.1:6379,password=123456,defaultDatabase=1"
);

// 多实例（使用 [FromKeyedServices] 注入）
services.AddFreeRedisMapConfigure(
    "SessionRedis",
    "127.0.0.1:6379,password=123456,defaultDatabase=2"
);
services.AddFreeRedisMapConfigure(
    "OrderRedis",
    "127.0.0.1:6379,password=123456,defaultDatabase=3"
);

2. 使用缓存服务（单实例）

注意：ICacheService 仅支持单实例场景，提供内存 + Redis 二级缓存。

public class UserService
{
    private readonly ICacheService _cache;

    public UserService(ICacheService cache)
    {
        _cache = cache;
    }

    public User GetUser(long id)
    {
        return _cache.StringGetOrAdd(
            $"user:{id}",
            () => _db.GetUser(id),
            TimeSpan.FromMinutes(5)
        );
    }

    public void SetUser(User user)
    {
        _cache.StringSet($"user:{user.Id}", user, TimeSpan.FromMinutes(5));
    }

    public void RemoveUser(long id)
    {
        _cache.Remove($"user:{id}");
    }
}

3. 直接使用 RedisClient

多实例场景请直接使用 IRedisClient

单实例

public class OrderService
{
    private readonly IRedisClient _redis;

    public OrderService(IRedisClient redis)
    {
        _redis = redis;
    }

    public void SetOrder(Order order)
    {
        _redis.Set("order:1", order.JsonSerialize(), 3600);
    }
}

多实例

using Microsoft.Extensions.DependencyInjection;

public class OrderService
{
    private readonly IRedisClient _session;
    private readonly IRedisClient _order;

    public OrderService(
        [FromKeyedServices("SessionRedis")] IRedisClient session,
        [FromKeyedServices("OrderRedis")] IRedisClient order)
    {
        _session = session;
        _order = order;
    }

    public void SetOrder(Order order)
    {
        _session.Set("session:1", order.JsonSerialize(), 3600);
        _order.Set("order:1", order.JsonSerialize(), 3600);
    }
}

API 参考

ICacheService

连接字符串格式

127.0.0.1:6379,password=123456,defaultDatabase=1

参数说明：

• password: Redis 密码
• defaultDatabase: 默认数据库（0-15）
• ssl: 是否使用 SSL
• connectTimeout: 连接超时（毫秒）

许可证

MIT