我有一个Asp.Net Core + EF Core REST服务。我为要调用SP的数据库创建了一个DbContext类。该方法几乎看起来像:
public IQueryable<xxx> Getxxxs()
{
return Set<xxx>().FromSql("pr_Getxxx");
}
这一切都有效,但是每次调用SP都没有任何意义,因为SP返回的数据很少发生变化。我想让数据陈旧,每24小时说一次。
在Core中有没有首选模式?我看到他们有.AddCaching扩展方法,但这似乎会被注入到控制器中?那么它的控制器工作要缓存吗?我认为它的线程安全,所以我不需要做任何锁定或类似的东西?看起来像竞争条件,如果一个线程正在检查项目是否已加载到缓存中,另一个可能正在插入它,等等?
好吧,你可以申请decorator pattern。这不是.NET Core特有的,只是一种常见的模式。
public class MyModel
{
public string SomeValue { get; set; }
}
public interface IMyRepository
{
IEnumerable<MyModel> GetModel();
}
public class MyRepository : IMyRepository
{
public IEnumerable<MyModel> GetModel()
{
return Set<MyModel>().FromSql("pr_GetMyModel");
}
}
public class CachedMyRepositoryDecorator : IMyRepository
{
private readonly IMyRepository repository;
private readonly IMemoryCache cache;
private const string MyModelCacheKey = "myModelCacheKey";
private MemoryCacheEntryOptions cacheOptions;
// alternatively use IDistributedCache if you use redis and multiple services
public CachedMyRepositoryDecorator(IMyRepository repository, IMemoryCache cache)
{
this.repository = repository;
this.cache = cache;
// 1 day caching
cacheOptions = new MemoryCacheEntryOptions()
.SetAbsoluteExpiration(relative: TimeSpan.FromDays(1));
}
public IEnumerable<MyModel> GetModel()
{
// Check cache
var value = cache.Get<IEnumerable<MyModel>>("myModelCacheKey");
if(value==null)
{
// Not found, get from DB
value = Set<MyModel>().FromSql("pr_GetMyModel").ToArray();
// write it to the cache
cache.Set("myModelCacheKey", value, cacheOptions);
}
return value;
}
}
由于ASP.NET Core DI不支持拦截器或装饰器,因此您的DI注册将变得更加冗长。或者使用支持装饰器注册的第三方IoC容器。
services.AddScoped<MyRepository>();
services.AddScoped<IMyRepository, CachedMyRepositoryDecorator>(
provider => new CachedMyRepositoryDecorator(
provider.GetService<MyRepository>(),
provider.GetService<IMemoryCache>()
));
这样做的好处是,您可以清楚地分离关注点,并可以通过将DI配置更改为轻松禁用缓存
services.AddScoped<IMyRepository,MyRepository>();
有一个二级缓存扩展可以做你想要的。它被称为qazxsw poi(是的,它是由我创建的,因为我有类似的问题)。
这里有一个扩展用法的示例:
EntityFrameworkCore.Cacheable
var cacheableQuery = cacheableContext.Books
.FromSql("pr_Getxxx")
.Cacheable(TimeSpan.FromHours(24));
方法调用将第一个结果存储到内存高速缓存中,如果再次调用相同的linq表达式,则返回高速缓存的结果24小时。