使用指南与最佳实践)
1. .NET 内存缓存基础概念在.NET开发中缓存是提升应用性能的关键技术之一。内存缓存(IMemoryCache)作为最直接的缓存形式将数据存储在应用进程的内存中避免了重复计算或数据库查询的开销。想象一下你每天都要从家到公司第一次走需要探索路线而之后就可以记住最佳路径 - 缓存的作用与此类似。内存缓存特别适合以下场景数据生成成本高如复杂计算或远程调用数据不经常变化快速访问比实时性更重要在ASP.NET Core中内存缓存通过Microsoft.Extensions.Caching.Memory包提供这是比传统的System.Runtime.Caching更现代、集成度更高的解决方案。2. 内存缓存实现与基本使用2.1 配置和注入缓存服务在ASP.NET Core中启用内存缓存非常简单。首先在Startup.cs中注册服务public void ConfigureServices(IServiceCollection services) { services.AddMemoryCache(); // 其他服务注册... }然后在需要使用的控制器或服务中通过构造函数注入public class ProductService { private readonly IMemoryCache _cache; public ProductService(IMemoryCache cache) { _cache cache; } }2.2 基本缓存操作缓存的核心操作可以概括为增删改查// 设置缓存最简单形式 _cache.Set(cache_key, cachedData); // 获取缓存 if(_cache.TryGetValue(cache_key, out MyData cachedData)) { // 使用缓存数据 } // 移除缓存 _cache.Remove(cache_key);实际项目中我们通常会使用更复杂但安全的模式public MyData GetExpensiveData() { const string cacheKey expensive_data; // 尝试从缓存获取 if(!_cache.TryGetValue(cacheKey, out MyData data)) { // 缓存不存在执行昂贵操作 data CalculateExpensiveData(); // 设置缓存选项 var cacheOptions new MemoryCacheEntryOptions() .SetSlidingExpiration(TimeSpan.FromMinutes(30)); _cache.Set(cacheKey, data, cacheOptions); } return data; }3. 缓存过期策略详解3.1 绝对过期 vs 滑动过期缓存过期策略是缓存设计的核心考虑因素// 绝对过期 - 固定时间后过期 var absoluteOptions new MemoryCacheEntryOptions() .SetAbsoluteExpiration(DateTime.Now.AddHours(1)); // 滑动过期 - 最后一次访问后一段时间过期 var slidingOptions new MemoryCacheEntryOptions() .SetSlidingExpiration(TimeSpan.FromMinutes(30)); // 组合使用 - 确保数据不会无限期保留 var combinedOptions new MemoryCacheEntryOptions() .SetSlidingExpiration(TimeSpan.FromMinutes(10)) .SetAbsoluteExpiration(TimeSpan.FromHours(1));3.2 基于令牌的过期更灵活的过期控制可以通过CancellationToken实现var cts new CancellationTokenSource(); var options new MemoryCacheEntryOptions() .AddExpirationToken(new CancellationChangeToken(cts.Token)); _cache.Set(token_based, data, options); // 当需要手动使缓存失效时 cts.Cancel();这种模式特别适合以下场景当底层数据发生变化时需要立即失效缓存实现跨多个缓存项的批量失效构建依赖其他缓存项的缓存关系4. 高级缓存控制与优化4.1 缓存大小限制与回收策略内存是有限资源合理控制缓存大小至关重要// 配置缓存大小限制 services.AddMemoryCache(options { options.SizeLimit 1024; // 设置总大小限制单位自定义 }); // 设置单个缓存项大小 var entryOptions new MemoryCacheEntryOptions() .SetSize(1); // 此项占用1个单位 _cache.Set(size_limited, data, entryOptions);当缓存达到限制时.NET会按照以下优先级回收缓存过期的项最近最少使用的项(LRU)低优先级的项4.2 缓存优先级设置通过设置优先级可以影响回收顺序var highPriorityOptions new MemoryCacheEntryOptions() .SetPriority(CacheItemPriority.High); var neverRemoveOptions new MemoryCacheEntryOptions() .SetPriority(CacheItemPriority.NeverRemove);优先级从低到高为LowNormal默认HighNeverRemove4.3 缓存回收回调可以在缓存项被移除时执行回调var options new MemoryCacheEntryOptions() .RegisterPostEvictionCallback((key, value, reason, state) { _logger.LogInformation($缓存 {key} 被移除原因: {reason}); }); _cache.Set(with_callback, data, options);移除原因(EvictionReason)包括Expired过期TokenExpired令牌过期Capacity容量限制Removed显式移除5. 缓存更新策略与实践5.1 后台服务定时更新使用IHostedService实现后台缓存刷新public class CacheRefreshService : BackgroundService { private readonly IMemoryCache _cache; private readonly TimeSpan _refreshInterval TimeSpan.FromMinutes(30); protected override async Task ExecuteAsync(CancellationToken stoppingToken) { while(!stoppingToken.IsCancellationRequested) { await RefreshCache(); await Task.Delay(_refreshInterval, stoppingToken); } } private async Task RefreshCache() { var newData await FetchDataFromSource(); _cache.Set(key, newData, new MemoryCacheEntryOptions { SlidingExpiration TimeSpan.FromHours(1) }); } }5.2 依赖项与级联更新构建缓存项之间的依赖关系// 创建父缓存项 var parentEntry _cache.CreateEntry(parent); parentEntry.Value DateTime.Now; parentEntry.Dispose(); // 必须调用Dispose // 创建依赖父项的缓存 var childOptions new MemoryCacheEntryOptions() .AddExpirationToken(new CancellationChangeToken( new CancellationTokenSource().Token)); _cache.Set(child, DateTime.Now, childOptions); // 当父项失效时手动使子项失效 var cts _cache.GetCancellationTokenSource(parent_dependency); cts.Cancel();5.3 读写锁与缓存击穿防护防止高并发下的缓存击穿问题private readonly SemaphoreSlim _cacheLock new SemaphoreSlim(1, 1); public async TaskMyData GetDataSafely() { if(_cache.TryGetValue(data, out MyData cachedData)) { return cachedData; } await _cacheLock.WaitAsync(); try { // 再次检查可能其他线程已经填充了缓存 if(_cache.TryGetValue(data, out cachedData)) { return cachedData; } // 从数据源获取 var freshData await FetchFromSource(); _cache.Set(data, freshData, new MemoryCacheEntryOptions { AbsoluteExpirationRelativeToNow TimeSpan.FromMinutes(30) }); return freshData; } finally { _cacheLock.Release(); } }6. 性能优化与问题排查6.1 缓存命中率监控良好的缓存设计应该保持高命中率public class CacheMonitor { private long _hits; private long _misses; public double HitRatio (double)_hits / (_hits _misses); public T GetOrAddT(string key, FuncT factory) { if(_cache.TryGetValue(key, out T value)) { Interlocked.Increment(ref _hits); return value; } Interlocked.Increment(ref _misses); value factory(); _cache.Set(key, value); return value; } }6.2 常见问题与解决方案问题1内存泄漏原因缓存无限增长解决设置合理的大小限制和过期策略问题2脏数据原因数据源变更后缓存未更新解决实现适当的失效机制或使用后台刷新问题3缓存雪崩原因大量缓存同时过期解决为过期时间添加随机偏移量// 添加随机偏移避免雪崩 var random new Random(); var expiration TimeSpan.FromMinutes(30) TimeSpan.FromSeconds(random.Next(0, 300));7. 实际应用案例7.1 电商产品目录缓存public class ProductCatalogService { private readonly IMemoryCache _cache; private readonly TimeSpan _defaultExpiration TimeSpan.FromHours(1); public ProductCatalogService(IMemoryCache cache) { _cache cache; } public async TaskProductCatalog GetCatalogAsync(int categoryId) { var cacheKey $catalog_{categoryId}; return await _cache.GetOrCreateAsync(cacheKey, async entry { entry.SetAbsoluteExpiration(_defaultExpiration) .SetPriority(CacheItemPriority.Normal); return await _database.GetCatalogAsync(categoryId); }); } public void InvalidateCatalogCache(int categoryId) { _cache.Remove($catalog_{categoryId}); } }7.2 API响应缓存中间件public class ResponseCachingMiddleware { private readonly RequestDelegate _next; private readonly IMemoryCache _cache; public ResponseCachingMiddleware(RequestDelegate next, IMemoryCache cache) { _next next; _cache cache; } public async Task Invoke(HttpContext context) { var cacheKey GenerateCacheKey(context.Request); if(_cache.TryGetValue(cacheKey, out string cachedResponse)) { await context.Response.WriteAsync(cachedResponse); return; } var originalBody context.Response.Body; using var newBody new MemoryStream(); context.Response.Body newBody; await _next(context); if(context.Response.StatusCode 200) { var response Encoding.UTF8.GetString(newBody.ToArray()); _cache.Set(cacheKey, response, new MemoryCacheEntryOptions { SlidingExpiration TimeSpan.FromMinutes(5) }); newBody.Position 0; await newBody.CopyToAsync(originalBody); } } private string GenerateCacheKey(HttpRequest request) { return ${request.Path}_{request.QueryString}; } }8. 缓存设计最佳实践缓存什么频繁访问但不常变化的数据计算成本高的结果远程服务响应避免缓存高度动态的数据用户特定数据除非量很大安全性要求极高的数据键设计原则使用有意义的键名包含所有影响值的参数保持一致性// 好的键设计 var cacheKey $user_{userId}_orders_{page}_{pageSize}; // 不好的键设计 var cacheKey orders; // 太模糊监控与调优监控缓存命中率根据使用模式调整过期时间定期检查内存使用情况9. 分布式缓存与内存缓存的比较虽然本文聚焦内存缓存但了解何时使用分布式缓存很重要特性内存缓存分布式缓存(如Redis)速度极快较快网络延迟扩展性单服务器多服务器共享数据共享仅进程内跨进程/服务器持久性进程终止即丢失可配置持久化复杂性简单需要额外基础设施在实际项目中经常组合使用两者内存缓存用于高频访问的临时数据分布式缓存用于共享的、更持久的数据10. 实战经验分享在多年使用.NET缓存的实践中我总结了以下宝贵经验缓存失效比缓存填充更重要 设计缓存系统时首先考虑的是数据变更时如何正确失效缓存而不是如何填充缓存。我曾遇到过一个生产问题因为缓存失效逻辑不完善导致用户看到的是前一天的数据。谨慎使用滑动过期 纯滑动过期可能导致热点数据永远不过期而冷数据被频繁淘汰。最佳实践是结合绝对过期使用.SetSlidingExpiration(TimeSpan.FromMinutes(10)) .SetAbsoluteExpiration(TimeSpan.FromHours(1))缓存空值也很有用 对于数据库查询返回null/空的情况也可以缓存短时间避免频繁查询if(data null) { _cache.Set(cacheKey, NULL, TimeSpan.FromMinutes(5)); }考虑使用Lazy缓存 防止并发请求同时重建缓存_cache.GetOrCreate(key, entry { entry.AbsoluteExpirationRelativeToNow TimeSpan.FromMinutes(30); return new LazyTaskMyData(async () await LoadDataAsync()); }).Value;缓存不是万能的 我曾见过过度依赖缓存导致系统复杂度陡增的案例。记住如果数据访问已经很快如简单的键值查询添加缓存可能反而降低性能。
.NET内存缓存(IMemoryCache)使用指南与最佳实践
发布时间：2026/7/17 19:35:42
1. .NET 内存缓存基础概念在.NET开发中缓存是提升应用性能的关键技术之一。内存缓存(IMemoryCache)作为最直接的缓存形式将数据存储在应用进程的内存中避免了重复计算或数据库查询的开销。想象一下你每天都要从家到公司第一次走需要探索路线而之后就可以记住最佳路径 - 缓存的作用与此类似。内存缓存特别适合以下场景数据生成成本高如复杂计算或远程调用数据不经常变化快速访问比实时性更重要在ASP.NET Core中内存缓存通过Microsoft.Extensions.Caching.Memory包提供这是比传统的System.Runtime.Caching更现代、集成度更高的解决方案。2. 内存缓存实现与基本使用2.1 配置和注入缓存服务在ASP.NET Core中启用内存缓存非常简单。首先在Startup.cs中注册服务public void ConfigureServices(IServiceCollection services) { services.AddMemoryCache(); // 其他服务注册... }然后在需要使用的控制器或服务中通过构造函数注入public class ProductService { private readonly IMemoryCache _cache; public ProductService(IMemoryCache cache) { _cache cache; } }2.2 基本缓存操作缓存的核心操作可以概括为增删改查// 设置缓存最简单形式 _cache.Set(cache_key, cachedData); // 获取缓存 if(_cache.TryGetValue(cache_key, out MyData cachedData)) { // 使用缓存数据 } // 移除缓存 _cache.Remove(cache_key);实际项目中我们通常会使用更复杂但安全的模式public MyData GetExpensiveData() { const string cacheKey expensive_data; // 尝试从缓存获取 if(!_cache.TryGetValue(cacheKey, out MyData data)) { // 缓存不存在执行昂贵操作 data CalculateExpensiveData(); // 设置缓存选项 var cacheOptions new MemoryCacheEntryOptions() .SetSlidingExpiration(TimeSpan.FromMinutes(30)); _cache.Set(cacheKey, data, cacheOptions); } return data; }3. 缓存过期策略详解3.1 绝对过期 vs 滑动过期缓存过期策略是缓存设计的核心考虑因素// 绝对过期 - 固定时间后过期 var absoluteOptions new MemoryCacheEntryOptions() .SetAbsoluteExpiration(DateTime.Now.AddHours(1)); // 滑动过期 - 最后一次访问后一段时间过期 var slidingOptions new MemoryCacheEntryOptions() .SetSlidingExpiration(TimeSpan.FromMinutes(30)); // 组合使用 - 确保数据不会无限期保留 var combinedOptions new MemoryCacheEntryOptions() .SetSlidingExpiration(TimeSpan.FromMinutes(10)) .SetAbsoluteExpiration(TimeSpan.FromHours(1));3.2 基于令牌的过期更灵活的过期控制可以通过CancellationToken实现var cts new CancellationTokenSource(); var options new MemoryCacheEntryOptions() .AddExpirationToken(new CancellationChangeToken(cts.Token)); _cache.Set(token_based, data, options); // 当需要手动使缓存失效时 cts.Cancel();这种模式特别适合以下场景当底层数据发生变化时需要立即失效缓存实现跨多个缓存项的批量失效构建依赖其他缓存项的缓存关系4. 高级缓存控制与优化4.1 缓存大小限制与回收策略内存是有限资源合理控制缓存大小至关重要// 配置缓存大小限制 services.AddMemoryCache(options { options.SizeLimit 1024; // 设置总大小限制单位自定义 }); // 设置单个缓存项大小 var entryOptions new MemoryCacheEntryOptions() .SetSize(1); // 此项占用1个单位 _cache.Set(size_limited, data, entryOptions);当缓存达到限制时.NET会按照以下优先级回收缓存过期的项最近最少使用的项(LRU)低优先级的项4.2 缓存优先级设置通过设置优先级可以影响回收顺序var highPriorityOptions new MemoryCacheEntryOptions() .SetPriority(CacheItemPriority.High); var neverRemoveOptions new MemoryCacheEntryOptions() .SetPriority(CacheItemPriority.NeverRemove);优先级从低到高为LowNormal默认HighNeverRemove4.3 缓存回收回调可以在缓存项被移除时执行回调var options new MemoryCacheEntryOptions() .RegisterPostEvictionCallback((key, value, reason, state) { _logger.LogInformation($缓存 {key} 被移除原因: {reason}); }); _cache.Set(with_callback, data, options);移除原因(EvictionReason)包括Expired过期TokenExpired令牌过期Capacity容量限制Removed显式移除5. 缓存更新策略与实践5.1 后台服务定时更新使用IHostedService实现后台缓存刷新public class CacheRefreshService : BackgroundService { private readonly IMemoryCache _cache; private readonly TimeSpan _refreshInterval TimeSpan.FromMinutes(30); protected override async Task ExecuteAsync(CancellationToken stoppingToken) { while(!stoppingToken.IsCancellationRequested) { await RefreshCache(); await Task.Delay(_refreshInterval, stoppingToken); } } private async Task RefreshCache() { var newData await FetchDataFromSource(); _cache.Set(key, newData, new MemoryCacheEntryOptions { SlidingExpiration TimeSpan.FromHours(1) }); } }5.2 依赖项与级联更新构建缓存项之间的依赖关系// 创建父缓存项 var parentEntry _cache.CreateEntry(parent); parentEntry.Value DateTime.Now; parentEntry.Dispose(); // 必须调用Dispose // 创建依赖父项的缓存 var childOptions new MemoryCacheEntryOptions() .AddExpirationToken(new CancellationChangeToken( new CancellationTokenSource().Token)); _cache.Set(child, DateTime.Now, childOptions); // 当父项失效时手动使子项失效 var cts _cache.GetCancellationTokenSource(parent_dependency); cts.Cancel();5.3 读写锁与缓存击穿防护防止高并发下的缓存击穿问题private readonly SemaphoreSlim _cacheLock new SemaphoreSlim(1, 1); public async TaskMyData GetDataSafely() { if(_cache.TryGetValue(data, out MyData cachedData)) { return cachedData; } await _cacheLock.WaitAsync(); try { // 再次检查可能其他线程已经填充了缓存 if(_cache.TryGetValue(data, out cachedData)) { return cachedData; } // 从数据源获取 var freshData await FetchFromSource(); _cache.Set(data, freshData, new MemoryCacheEntryOptions { AbsoluteExpirationRelativeToNow TimeSpan.FromMinutes(30) }); return freshData; } finally { _cacheLock.Release(); } }6. 性能优化与问题排查6.1 缓存命中率监控良好的缓存设计应该保持高命中率public class CacheMonitor { private long _hits; private long _misses; public double HitRatio (double)_hits / (_hits _misses); public T GetOrAddT(string key, FuncT factory) { if(_cache.TryGetValue(key, out T value)) { Interlocked.Increment(ref _hits); return value; } Interlocked.Increment(ref _misses); value factory(); _cache.Set(key, value); return value; } }6.2 常见问题与解决方案问题1内存泄漏原因缓存无限增长解决设置合理的大小限制和过期策略问题2脏数据原因数据源变更后缓存未更新解决实现适当的失效机制或使用后台刷新问题3缓存雪崩原因大量缓存同时过期解决为过期时间添加随机偏移量// 添加随机偏移避免雪崩 var random new Random(); var expiration TimeSpan.FromMinutes(30) TimeSpan.FromSeconds(random.Next(0, 300));7. 实际应用案例7.1 电商产品目录缓存public class ProductCatalogService { private readonly IMemoryCache _cache; private readonly TimeSpan _defaultExpiration TimeSpan.FromHours(1); public ProductCatalogService(IMemoryCache cache) { _cache cache; } public async TaskProductCatalog GetCatalogAsync(int categoryId) { var cacheKey $catalog_{categoryId}; return await _cache.GetOrCreateAsync(cacheKey, async entry { entry.SetAbsoluteExpiration(_defaultExpiration) .SetPriority(CacheItemPriority.Normal); return await _database.GetCatalogAsync(categoryId); }); } public void InvalidateCatalogCache(int categoryId) { _cache.Remove($catalog_{categoryId}); } }7.2 API响应缓存中间件public class ResponseCachingMiddleware { private readonly RequestDelegate _next; private readonly IMemoryCache _cache; public ResponseCachingMiddleware(RequestDelegate next, IMemoryCache cache) { _next next; _cache cache; } public async Task Invoke(HttpContext context) { var cacheKey GenerateCacheKey(context.Request); if(_cache.TryGetValue(cacheKey, out string cachedResponse)) { await context.Response.WriteAsync(cachedResponse); return; } var originalBody context.Response.Body; using var newBody new MemoryStream(); context.Response.Body newBody; await _next(context); if(context.Response.StatusCode 200) { var response Encoding.UTF8.GetString(newBody.ToArray()); _cache.Set(cacheKey, response, new MemoryCacheEntryOptions { SlidingExpiration TimeSpan.FromMinutes(5) }); newBody.Position 0; await newBody.CopyToAsync(originalBody); } } private string GenerateCacheKey(HttpRequest request) { return ${request.Path}_{request.QueryString}; } }8. 缓存设计最佳实践缓存什么频繁访问但不常变化的数据计算成本高的结果远程服务响应避免缓存高度动态的数据用户特定数据除非量很大安全性要求极高的数据键设计原则使用有意义的键名包含所有影响值的参数保持一致性// 好的键设计 var cacheKey $user_{userId}_orders_{page}_{pageSize}; // 不好的键设计 var cacheKey orders; // 太模糊监控与调优监控缓存命中率根据使用模式调整过期时间定期检查内存使用情况9. 分布式缓存与内存缓存的比较虽然本文聚焦内存缓存但了解何时使用分布式缓存很重要特性内存缓存分布式缓存(如Redis)速度极快较快网络延迟扩展性单服务器多服务器共享数据共享仅进程内跨进程/服务器持久性进程终止即丢失可配置持久化复杂性简单需要额外基础设施在实际项目中经常组合使用两者内存缓存用于高频访问的临时数据分布式缓存用于共享的、更持久的数据10. 实战经验分享在多年使用.NET缓存的实践中我总结了以下宝贵经验缓存失效比缓存填充更重要 设计缓存系统时首先考虑的是数据变更时如何正确失效缓存而不是如何填充缓存。我曾遇到过一个生产问题因为缓存失效逻辑不完善导致用户看到的是前一天的数据。谨慎使用滑动过期 纯滑动过期可能导致热点数据永远不过期而冷数据被频繁淘汰。最佳实践是结合绝对过期使用.SetSlidingExpiration(TimeSpan.FromMinutes(10)) .SetAbsoluteExpiration(TimeSpan.FromHours(1))缓存空值也很有用 对于数据库查询返回null/空的情况也可以缓存短时间避免频繁查询if(data null) { _cache.Set(cacheKey, NULL, TimeSpan.FromMinutes(5)); }考虑使用Lazy缓存 防止并发请求同时重建缓存_cache.GetOrCreate(key, entry { entry.AbsoluteExpirationRelativeToNow TimeSpan.FromMinutes(30); return new LazyTaskMyData(async () await LoadDataAsync()); }).Value;缓存不是万能的 我曾见过过度依赖缓存导致系统复杂度陡增的案例。记住如果数据访问已经很快如简单的键值查询添加缓存可能反而降低性能。
