ASP.NET Core与Redis搭建一个简易分布式缓存_Cache

本文主要介绍了缓存的概念，以及如何在服务器内存中存储内容。今天的目标是利用IDistributedCache来做一些分布式缓存，这样我们就可以横向扩展我们的web应用程序。

在本教程中，我将使用Redis作为缓存。Redis是一个可靠的快速内存缓存，可以存储多种类型的对象。Redis正在被Twitter, Github, Instagram, Stackoverflow等巨头使用。

你可以在https://github.com/sahan91/DistributedCacheAspNetCoreRedis找到示例代码。

这是我们实现后的一个快照。

ASP.NET Core与Redis搭建一个简易分布式缓存

用户请求一个User对象。
App server检查缓存中是否已经有用户，如果存在则返回对象。
App server通过HTTP调用来检索用户列表。
Users service将用户列表返回给App server。
App server将用户列表发送到分布式(Redis)缓存。
App server获得缓存的版本，直到它过期(TTL)。
用户获取缓存的User对象。

我们称其为分布式缓存的主要原因是，它位于应用服务器之外(与传统的内存缓存相反)，如果需要的话，我们可以灵活地水平扩展它(在云中操作时)。来看看在企业应用程序中是如何有用的。

IDistributedCache接口为我们提供了一组操作缓存的方法。这里总结了几种不同的方法。

搭建一个示例应用程序

我们将用ASP.NET Core 5创建一个Web MVC应用程序。

dotnet new mvc -n DistributedCachedotnet new slndotnet sln add DistributedCache

让我们继续从NuGet添加Redis客户端包。

dotnet add package Microsoft.Extensions.Caching.StackExchangeRedis --version 5.0.1

创建一个Redis docker容器

假设已经在你的机器上安装了Docker。这是很方便的，你可以在任何想要开发的时候启动自己的Redis容器。

docker run --name redis-cache -p 5002:6379 -d redis

使用官方的Redis镜像，创建一个名为redis-cache的容器，并将容器的6379端口绑定到主机的5002端口。如果你在本地没有Redis的镜像，它会从DockerHub获取它。接下来让我们验证docker实例是否启动并运行。

docker ps -a

现在我们已经有了Redis容器并运行，接下来配置我们的web应用程序。

应用程序配置

因为我们已经添加了所需的NuGet包，我们只需要在应用的DI容器中注册，并告诉它在哪里可以找到我们的Redis实例。

services.AddStackExchangeRedisCache(options =>{
    options.Configuration = Configuration.GetSection("Redis")["ConnectionString"];
});

当我们在服务对象上调用AddStackExchangeRedisCache时，它会在底层通过IDistributedCache接口注册一个RedisCache类的单例。

services.Add(ServiceDescriptor.Singleton<IDistributedCache, RedisCache>());

因为我们已经在5002端口上启动并运行了Docker实例，所以我们可以在配置中设置它。

"Redis": {  "ConnectionString": "localhost:5002"}

实现

这个功能很简单，下面是我们要做的:

获取缓存的用户(如果有的话)并显示其电子邮件地址
用于调用HTTP缓存用户列表的按钮
清除缓存的按钮

UI将类似于以下。

ASP.NET Core与Redis搭建一个简易分布式缓存

让我们看看程序的入口，HomeController类。

public async Task<IActionResult> Index(){
    var users = (await _cacheService.GetCachedUser())?.FirstOrDefault();
    return View(users);
}

public async Task<IActionResult> CacheUserAsync(){
    var users = await _usersService.GetUsersAsync();
    var cacheEntry = users.First();
    return View(nameof(Index), cacheEntry);
}

public IActionResult CacheRemoveAsync(){
    _cacheService.ClearCache();
    return RedirectToAction(nameof(Index));
}

这里的代码很容易解释，我们在Index、CacheUserAsync和cacheeremoveasync中实现了之前的3个内容。

跳过所有其他管道代码，并展示我们如何使用Redis缓存获取和设置值。真正神奇的事情发生在ICacheProvider类中。

在GetFromCache方法中，我们使用给定的键(在本例中为_Users)调用GetStringAsync。值得注意的是，在将它返回给调用者之前，我们需要将它反序列化为我们想要的类型。类似地，序列化我们的用户列表，并将它作为字符串保存在Redis缓存中的_Users键下。

public class CacheProvider : ICacheProvider{
    private readonly IDistributedCache _cache;

    public CacheProvider(IDistributedCache cache)
    {
        _cache = cache;
    }
    
    public async Task<T> GetFromCache<T>(string key) where T : class
    {
        var cachedResponse = await _cache.GetStringAsync(key);
        return cachedResponse == null ? null : JsonSerializer.Deserialize<T>(cachedResponse);
    }

    public async Task SetCache<T>(string key, T value, DistributedCacheEntryOptions options) where T : class
    {
        var response = JsonSerializer.Serialize(value);
        await _cache.SetStringAsync(key, response , options);
    }

    public async Task ClearCache(string key)
    {
        await _cache.RemoveAsync(key);
    }
}