当前位置：首页 > news >正文

.net web 中如何优雅地使用 redis？

news 2025/7/23 5:17:50

在 .NET Web 应用中优雅地使用 Redis

Redis 是一个高性能的键值存储系统，在 .NET Web 应用中可以用来实现缓存、会话存储、消息队列等功能。以下是优雅使用 Redis 的几个关键方面：

1. 选择合适的客户端库

推荐使用 StackExchange.Redis，它是 .NET 中最流行的 Redis 客户端：

// 安装 NuGet 包
Install-Package StackExchange.Redis

2. 配置和连接管理

单例模式管理连接

public static class RedisConnectorHelper
{private static Lazy<ConnectionMultiplexer> lazyConnection = new Lazy<ConnectionMultiplexer>(() =>{return ConnectionMultiplexer.Connect("your_redis_server:6379");});public static ConnectionMultiplexer Connection => lazyConnection.Value;
}

在 ASP.NET Core 中使用依赖注入

// Startup.cs
public void ConfigureServices(IServiceCollection services)
{services.AddStackExchangeRedisCache(options =>{options.Configuration = "your_redis_server:6379";options.InstanceName = "SampleInstance_";});// 或者直接注册 ConnectionMultiplexerservices.AddSingleton<IConnectionMultiplexer>(_ => ConnectionMultiplexer.Connect("your_redis_server:6379"));
}

3. 缓存实现

基本缓存操作

public class RedisCacheService
{private readonly IDatabase _cache;public RedisCacheService(IConnectionMultiplexer redis){_cache = redis.GetDatabase();}public async Task SetAsync<T>(string key, T value, TimeSpan? expiry = null){var serializedValue = JsonSerializer.Serialize(value);await _cache.StringSetAsync(key, serializedValue, expiry);}public async Task<T> GetAsync<T>(string key){var value = await _cache.StringGetAsync(key);return value.HasValue ? JsonSerializer.Deserialize<T>(value) : default;}public async Task RemoveAsync(string key){await _cache.KeyDeleteAsync(key);}
}

分布式缓存接口

// 使用 IDistributedCache 接口
public class SomeService
{private readonly IDistributedCache _cache;public SomeService(IDistributedCache cache){_cache = cache;}public async Task<SomeData> GetData(){var cachedData = await _cache.GetStringAsync("cache_key");if (cachedData != null){return JsonSerializer.Deserialize<SomeData>(cachedData);}// 从数据库获取数据var data = await FetchFromDatabase();// 缓存数据await _cache.SetStringAsync("cache_key", JsonSerializer.Serialize(data),new DistributedCacheEntryOptions{AbsoluteExpirationRelativeToNow = TimeSpan.FromMinutes(30)});return data;}
}

4. 高级用法

发布/订阅模式

// 发布消息
var sub = redis.GetSubscriber();
await sub.PublishAsync("messages", "Hello World!");// 订阅消息
var sub = redis.GetSubscriber();
await sub.SubscribeAsync("messages", (channel, message) => 
{Console.WriteLine((string)message);
});

使用 Lua 脚本

var script = "return redis.call('GET', KEYS[1])";
var prepared = LuaScript.Prepare(script);
var result = await _cache.ScriptEvaluateAsync(prepared, new { KEYS = new RedisKey[] { "key" } });

管道和批量操作

var batch = _cache.CreateBatch();
var task1 = batch.StringSetAsync("key1", "value1");
var task2 = batch.StringSetAsync("key2", "value2");
batch.Execute();
await Task.WhenAll(task1, task2);

5. 最佳实践

连接管理：保持连接复用，不要频繁创建和销毁连接
序列化：选择高效的序列化方式（如 MessagePack 或 System.Text.Json）
键设计：使用合理的键命名规范（如 type:id:field）
过期策略：为缓存设置合理的过期时间
错误处理：实现重试机制和熔断策略
性能监控：监控 Redis 的性能指标和命中率
集群支持：生产环境考虑使用 Redis 集群

6. 在 ASP.NET Core 中的集成

会话存储

services.AddSession(options =>
{options.IdleTimeout = TimeSpan.FromMinutes(30);options.Cookie.HttpOnly = true;options.Cookie.IsEssential = true;
});
services.AddDistributedRedisCache(options =>
{options.Configuration = "your_redis_server:6379";options.InstanceName = "Session_";
});

响应缓存

services.AddResponseCaching();
services.AddDistributedRedisCache(options =>
{options.Configuration = "your_redis_server:6379";options.InstanceName = "ResponseCache_";
});// 在控制器中使用
[ResponseCache(Duration = 60)]
public IActionResult Index()
{return View();
}