ASP.NET Core 操作 Redis

简介

Redis是一款开源的内存中键值存储数据库，常用于缓存、排行榜、实时数据分析等场景。在ASP.NET Core应用程序中使用Redis可以提高性能和可伸缩性，并且方便扩展。本文将介绍如何使用ASP.NET Core操作Redis数据库。

准备工作

在开始之前，需要确保已安装以下组件：

• .NET Core SDK
• Redis数据库

在ASP.NET Core项目中，需要通过NuGet管理包，使用以下包：

• StackExchange.Redis：Redis数据库的客户端库。

可以通过以下命令在项目中安装该包：

dotnet add package StackExchange.Redis

连接Redis

在项目中，首先需要建立与Redis数据库的连接。创建一个RedisService.cs文件，用于封装Redis数据库的连接。

using StackExchange.Redis;

public class RedisService
{
    private readonly string _connectionString;
    private readonly ConnectionMultiplexer _redis;

    public RedisService(string connectionString)
    {
        _connectionString = connectionString;
        _redis = ConnectionMultiplexer.Connect(_connectionString);
    }

    public IDatabase GetDatabase()
    {
        return _redis.GetDatabase();
    }

    public void Dispose()
    {
        _redis.Dispose();
    }
}

使用Redis缓存数据

在ASP.NET Core中，可以使用Redis作为缓存提供程序。在Startup.cs文件中，配置Redis缓存服务。

using Microsoft.Extensions.DependencyInjection;
using StackExchange.Redis;

public class Startup
{
    public void ConfigureServices(IServiceCollection services)
    {
        // ...其他服务配置...

        services.AddDistributedRedisCache(options =>
        {
            options.Configuration = "localhost";
            options.InstanceName = "SampleInstance";
        });
    }
}

现在可以在控制器或其他类中使用缓存服务。

using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Caching.Distributed;
using System;

public class HomeController : Controller
{
    private readonly IDistributedCache _cache;

    public HomeController(IDistributedCache cache)
    {
        _cache = cache;
    }

    public IActionResult Index()
    {
        var cacheKey = "current_time";
        var cachedTime = _cache.GetString(cacheKey);

        if (string.IsNullOrEmpty(cachedTime))
        {
            // 缓存中不存在，重新生成数据
            var currentTime = DateTime.Now.ToString();
            _cache.SetString(cacheKey, currentTime);

            ViewBag.Time = currentTime;
        }
        else
        {
            ViewBag.Time = cachedTime;
        }

        return View();
    }
}

使用Redis存储数据

除了作为缓存外，Redis还可用于存储和检索其他类型的数据，如字符串、列表、哈希等。

在RedisService.cs文件中，添加相应的方法，用于存储和检索数据。

public class RedisService
{
    // ...其他代码...

    public async Task<string> GetStringAsync(string key)
    {
        var db = GetDatabase();
        return await db.StringGetAsync(key);
    }

    public async Task SetStringAsync(string key, string value)
    {
        var db = GetDatabase();
        await db.StringSetAsync(key, value);
    }

    public async Task<List<string>> GetListAsync(string key)
    {
        var db = GetDatabase();
        var redisValues = await db.ListRangeAsync(key);
        return redisValues.Select(rv => rv.ToString()).ToList();
    }

    public async Task AddToListAsync(string key, string value)
    {
        var db = GetDatabase();
        await db.ListRightPushAsync(key, value);
    }

    public async Task<Dictionary<string, string>> GetHashAsync(string key)
    {
        var db = GetDatabase();
        var redisValues = await db.HashGetAllAsync(key);
        return redisValues.ToDictionary(rv => rv.Name.ToString(), rv => rv.Value.ToString());
    }

    public async Task SetHashAsync(string key, Dictionary<string, string> values)
    {
        var db = GetDatabase();
        var hashEntries = values.Select(kv => new HashEntry(kv.Key, kv.Value)).ToArray();
        await db.HashSetAsync(key, hashEntries);
    }
}

现在可以使用以下代码在控制器或其他类中存储和检索数据。

public class HomeController : Controller
{
    private readonly RedisService _redisService;

    public HomeController(RedisService redisService)
    {
        _redisService = redisService;
    }

    public async Task<IActionResult> Index()
    {
        var cacheKey = "current_time";
        var cachedTime = await _redisService.GetStringAsync(cacheKey);

        if (string.IsNullOrEmpty(cachedTime))
        {
            // 缓存中不存在，重新生成数据
            var currentTime = DateTime.Now.ToString();
            await _redisService.SetStringAsync(cacheKey, currentTime);

            ViewBag.Time = currentTime;
        }
        else
        {
            ViewBag.Time = cachedTime;
        }

        return View();
    }
}

结论

本文介绍了如何在ASP.NET Core应用程序中操作Redis数据库。首先通过连接Redis实例，然后通过缓存服务使用Redis作为缓存提供程序。此外，还演示了如何存储和检索其他数据类型的内容。通过使用Redis，可以提高应用程序的性能和可伸缩性。

以上就是ASP.NET Core操作Redis的内容，希望对你有所帮助！

本文来自极简博客，作者：神秘剑客，转载请注明原文链接：ASP.NET Core 操作 Redis