Asp.Net Core + EF Core中缓存数据的模式是什么？

Question

Asp.Net Core + EF Core中缓存数据的模式是什么？

15

我有一个Asp.Net Core + EF Core REST服务。我为我想调用存储过程的数据库创建了一个DbContext类。这个方法看起来很简单:

public IQueryable<xxx> Getxxxs()
{
    return Set<xxx>().FromSql("pr_Getxxx");
}

这一切都有效，但由于存储过程返回的数据很少改变，所以每次都调用SP没有任何意义。我想让数据过期，比如每24小时。

在Core中有没有首选的模式可以实现这个功能？我看到它们有 .AddCaching 扩展方法，但那似乎会注入到控制器中？所以是控制器的工作来缓存数据？我假设它是线程安全的，所以我不需要进行任何锁定或类似的操作？似乎存在竞态条件，如果一个线程正在检查项目是否已加载到缓存中，则另一个可能正在插入它等等？

- SledgeHammer

5

能否请您不要再称呼它为EF7？这个名称已经有6个月没有被官方使用了。它被称为EntityFramework Core，并被版本化为1.0，以明确它不是EF6的下一个版本。请参考此公告：http://www.hanselman.com/blog/ASPNET5IsDeadIntroducingASPNETCore10AndNETCore10.aspx。 - Tseng

这项服务是永久运行还是只在调用时运行并在之后终止？您需要以某种方式缓存结果和上次从数据库访问数据的时间戳。然而，数据库应该/可能会自己做很多这种缓存工作。 - Thomas R.

@ThomasRoskop，服务始终运行。Core的工作方式是在每个调用中创建控制器和上下文对象。它们具有MemoryCache，可以在X时间后过期。这似乎容易出现竞争条件。 - SledgeHammer

4个回答

6

您可以使用这个第三方包：https://github.com/VahidN/EFSecondLevelCache.Core，结合AspNetCore MW & EfCore Extension (可缓存)来实现以下效果：

var posts = context.Posts
                   .Where(x => x.Id > 0)
                   .OrderBy(x => x.Id)
                   .Cacheable()
                   .ProjectTo<PostDto>(configuration: _mapper.ConfigurationProvider)
                   .ToList();

ProjectTo<>() 是 AutoMapper 的扩展功能。

- hamid_reza hobab

3

有一个第二级缓存扩展可以实现你想要的功能。它叫做EntityFrameworkCore.Cacheable（是的，这个扩展是由我创建的，因为我也遇到了类似的问题）。

下面是一个基于该扩展使用的示例：

var cacheableQuery = cacheableContext.Books
    .FromSql("pr_Getxxx")
    .Cacheable(TimeSpan.FromHours(24));

Cacheable(... 方法调用将第一个结果存储到内存缓存中，如果再次调用相同的linq表达式，则返回缓存结果24小时。

- Steffen Mangold

通常，对于工具或库的链接，应该附带安装/使用说明、关于链接资源如何适用于问题的具体解释或一些示例代码，如果可能的话，最好都包含。 - Samuel Liew

1

无法与EF Core >= 3.0.0一起使用 https://github.com/SteffenMangold/EntityFrameworkCore.Cacheable/issues/19 - mabi

1

您可以使用ASP.Net Core内存缓存来缓存数据，然后根据需要设置滑动/绝对过期时间。请参阅MemoryCache的文档。https://learn.microsoft.com/en-us/aspnet/core/performance/caching/memory?view=aspnetcore-5.0

- rj972

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Tseng · Accepted Answer

你可以应用装饰者模式。它与.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 = repository.GetModel();

            // 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>();