Smart.StackRedis 4.2.2

Smart.StackRedis

English | 中文

<a name="english"></a>

English

Smart.StackRedis is a Redis helper library built on StackExchange.Redis. It provides dependency injection support, key prefixing, JSON serialization, Redis data type modules, distributed lock helpers, counters, transactions, and pub/sub with re-subscription after connection restore. It supports .NET 8, 9, and 10.

Installation

dotnet add package Smart.StackRedis

Registration

using Microsoft.Extensions.DependencyInjection;
using Smart.StackRedis;

services.AddSmartRedis(new RedisOptions
{
    Server = "127.0.0.1:6379,password=password,abortConnect=false",
    Prefix = "prod:",
    ConnectTimeout = 15000,
    SyncTimeout = 5000,
    AbortOnConnectFail = false,
    ConnectRetry = 3
});

Examples

public class UserService
{
    private readonly SmartRedisService _redis;

    public UserService(SmartRedisService redis)
    {
        _redis = redis;
    }

    public Task<bool> CacheUserAsync(User user)
    {
        return _redis.String.SetAsync($"users:{user.Id}", user, TimeSpan.FromHours(1));
    }

    public Task<User?> GetUserAsync(string userId)
    {
        return _redis.String.GetAsync<User>($"users:{userId}");
    }
}

await redis.Hash.SetAsync("profiles:1", "name", "Tom");
string? name = await redis.Hash.GetAsync("profiles:1", "name");

await redis.List.RightPushAsync("jobs", job);
Job? next = await redis.List.LeftPopAsync<Job>("jobs");

await redis.Set.AddAsync("tags", "redis", "cache");
string[] tags = await redis.Set.MembersAsync("tags");

bool locked = await redis.Lock.TakeAsync("order:1", "worker-1", expiry: 30);
try
{
    if (locked)
    {
        await ProcessOrderAsync();
    }
}
finally
{
    if (locked)
    {
        await redis.Lock.ReleaseAsync("order:1", "worker-1");
    }
}

await redis.Counter.InitialValueAsync("article:1:views", 0);
long views = await redis.Counter.IncrementAsync("article:1:views");
long current = await redis.Counter.CurrentValueAsync("article:1:views");

redis.SubscribeReceived += (channel, message) =>
{
    Console.WriteLine($"Received message on {channel}: {message}");
};

await redis.Subscribe.SubscribeAsync("notifications");
await redis.Subscribe.PublishAsync("notifications", "hello");

Modules

<a name="chinese"></a>

中文

Smart.StackRedis 是基于 StackExchange.Redis 的 Redis 工具库，提供依赖注入、键前缀、JSON 序列化、Redis 数据类型模块、分布式锁、计数器、事务和发布订阅能力，并在连接恢复后自动重新订阅。兼容 .NET 8/9/10。

安装

dotnet add package Smart.StackRedis

注册

using Microsoft.Extensions.DependencyInjection;
using Smart.StackRedis;

services.AddSmartRedis(new RedisOptions
{
    Server = "127.0.0.1:6379,password=password,abortConnect=false",
    Prefix = "prod:",
    ConnectTimeout = 15000,
    SyncTimeout = 5000,
    AbortOnConnectFail = false,
    ConnectRetry = 3
});

示例

public class UserService
{
    private readonly SmartRedisService _redis;

    public UserService(SmartRedisService redis)
    {
        _redis = redis;
    }

    public Task<bool> CacheUserAsync(User user)
    {
        return _redis.String.SetAsync($"users:{user.Id}", user, TimeSpan.FromHours(1));
    }

    public Task<User?> GetUserAsync(string userId)
    {
        return _redis.String.GetAsync<User>($"users:{userId}");
    }
}

await redis.Hash.SetAsync("profiles:1", "name", "Tom");
string? name = await redis.Hash.GetAsync("profiles:1", "name");

await redis.List.RightPushAsync("jobs", job);
Job? next = await redis.List.LeftPopAsync<Job>("jobs");

await redis.Set.AddAsync("tags", "redis", "cache");
string[] tags = await redis.Set.MembersAsync("tags");

bool locked = await redis.Lock.TakeAsync("order:1", "worker-1", expiry: 30);
try
{
    if (locked)
    {
        await ProcessOrderAsync();
    }
}
finally
{
    if (locked)
    {
        await redis.Lock.ReleaseAsync("order:1", "worker-1");
    }
}

await redis.Counter.InitialValueAsync("article:1:views", 0);
long views = await redis.Counter.IncrementAsync("article:1:views");
long current = await redis.Counter.CurrentValueAsync("article:1:views");

redis.SubscribeReceived += (channel, message) =>
{
    Console.WriteLine($"在 {channel} 收到消息: {message}");
};

await redis.Subscribe.SubscribeAsync("notifications");
await redis.Subscribe.PublishAsync("notifications", "hello");

模块

Developed by zenglei