快速入门：在 .NET Core 中使用 Azure Cache for Redis

项目
03/05/2024

在本快速入门中，会将 Azure Redis 缓存合并到 .NET Core 应用中，以便能够访问 Azure 中的任何应用程序都可以访问的安全专用缓存。你专门在 .NET Core 控制台应用中将 StackExchange.Redis 客户端与 C# 代码配合使用。

克隆 GitHub 上的存储库 https://github.com/Azure-Samples/azure-cache-redis-samples/tree/main/quickstart/dotnet-core。

先决条件

Azure 订阅 - 创建订阅
.NET Core SDK

创建缓存

若要创建缓存，请登录到 Azure 门户并选择“创建资源” 。
在“新建”页上选择“数据库”，然后选择“Azure Cache for Redis”。

在“新建 Redis 缓存”页上配置新缓存的设置。

设置	选择值	说明
订阅	单击下拉箭头并选择你的订阅。	要在其下创建此新的 Azure Cache for Redis 实例的订阅。
资源组	单击下拉箭头并选择一个资源组，或者选择“新建”并输入新的资源组名称。	要在其中创建缓存和其他资源的资源组的名称。将所有应用资源放入一个资源组可以轻松地统一管理或删除这些资源。
DNS 名称	输入唯一名称。	缓存名称必须是包含 1 到 63 个字符的字符串，只能包含数字、字母或连字符。该名称必须以数字或字母开头和结尾，且不能包含连续的连字符。缓存实例的主机名是 <DNS name>.redis.cache.chinacloudapi.cn。
位置	单击下拉箭头并选择一个位置。	选择使用缓存的其他服务附近的区域。
缓存类型	下拉并选择一个层。	此层决定可用于缓存的大小、性能和功能。有关详细信息，请参阅用于 Redis 的 Azure 缓存概述。

选择“网络”选项卡，或选择“网络”按钮（位于页面底部）。
在“网络”选项卡中，选择你的连接方法。
选择“下一步: 高级”选项卡，或选择页面底部的“下一步: 高级”按钮，以查看“高级”选项卡。
- 对于“基本”或“标准”缓存，请切换非 TLS 端口的选项。还可以选择是否要启用“Microsoft Entra 身份验证”。
- 对于“高级”缓存，请配置非 TLS 端口、群集、托管标识和数据持久性的设置。还可以选择是否要启用“Microsoft Entra 身份验证”。
选择“下一步: 标记”选项卡，或选择页面底部的“下一步: 标记”按钮。
或者，在“标记”选项卡中，如果希望对资源分类，请输入名称或值。
选择“查看 + 创建” 。随后你会转到“查看 + 创建”选项卡，Azure 将在此处验证配置。
显示绿色的“已通过验证”消息后，选择“创建”。

创建缓存需要一段时间。可以在 Azure Cache for Redis 的“概述”页上监视进度。如果“状态”显示为“正在运行”，则表示该缓存可供使用。

从 Azure 门户检索主机名、端口和访问密钥

若要连接到你的 Azure Cache for Redis 服务器，缓存客户端需要该缓存的主机名、端口和密钥。在某些客户端中，这些项的名称可能略有不同。可以从 Azure 门户检索主机名、端口和访问密钥。

若要获取访问密钥，请在缓存的左侧导航中选择“访问密钥”。
若要获取主机名和端口，请在缓存的左侧导航栏中选择“属性”。主机名的格式为 <DNS 名称>.redis.cache.chinacloudapi.cn。

记下主机名和主访问密钥。稍后你将使用这些值来构造 CacheConnection 机密。

添加连接字符串的本地机密

在命令窗口中，在替换你的缓存名称和主访问密钥的占位符（包括尖括号）后，执行以下命令来存储名为 CacheConnection 的新机密：

dotnet user-secrets set CacheConnection "<cache name>.redis.cache.chinacloudapi.cn,abortConnect=false,ssl=true,allowAdmin=true,password=<primary-access-key>"

使用 RedisConnection 连接到缓存

与缓存的连接由 RedisConnection 类管理。首先在 Program.cs 中使用此语句建立连接：

      _redisConnection = await RedisConnection.InitializeAsync(connectionString: configuration["CacheConnection"].ToString());

在 RedisConnection.cs 中，可以看到 StackExchange.Redis 命名空间已添加到代码中。 RedisConnection 类需要此命名空间。

using StackExchange.Redis;

RedisConnection 代码通过管理 StackExchange.Redis 中的 ConnectionMultiplexer 实例来确保始终与缓存建立运行状况正常的连接。连接丢失且无法自动重新连接时，RedisConnection 类会重新创建该连接。

有关详细信息，请参阅 StackExchange.Redis 和 GitHub 存储库中的代码。

执行缓存命令

在 program.cs 中，你可以看到控制台应用程序 Program 类中 RunRedisCommandsAsync 方法的以下代码：

private static async Task RunRedisCommandsAsync(string prefix)
    {
        // Simple PING command
        Console.WriteLine($"{Environment.NewLine}{prefix}: Cache command: PING");
        RedisResult pingResult = await _redisConnection.BasicRetryAsync(async (db) => await db.ExecuteAsync("PING"));
        Console.WriteLine($"{prefix}: Cache response: {pingResult}");

        // Simple get and put of integral data types into the cache
        string key = "Message";
        string value = "Hello! The cache is working from a .NET console app!";

        Console.WriteLine($"{Environment.NewLine}{prefix}: Cache command: GET {key} via StringGetAsync()");
        RedisValue getMessageResult = await _redisConnection.BasicRetryAsync(async (db) => await db.StringGetAsync(key));
        Console.WriteLine($"{prefix}: Cache response: {getMessageResult}");

        Console.WriteLine($"{Environment.NewLine}{prefix}: Cache command: SET {key} \"{value}\" via StringSetAsync()");
        bool stringSetResult = await _redisConnection.BasicRetryAsync(async (db) => await db.StringSetAsync(key, value));
        Console.WriteLine($"{prefix}: Cache response: {stringSetResult}");

        Console.WriteLine($"{Environment.NewLine}{prefix}: Cache command: GET {key} via StringGetAsync()");
        getMessageResult = await _redisConnection.BasicRetryAsync(async (db) => await db.StringGetAsync(key));
        Console.WriteLine($"{prefix}: Cache response: {getMessageResult}");

        // Store serialized object to cache
        Employee e007 = new Employee("007", "Davide Columbo", 100);
        stringSetResult = await _redisConnection.BasicRetryAsync(async (db) => await db.StringSetAsync("e007", JsonSerializer.Serialize(e007)));
        Console.WriteLine($"{Environment.NewLine}{prefix}: Cache response from storing serialized Employee object: {stringSetResult}");

        // Retrieve serialized object from cache
        getMessageResult = await _redisConnection.BasicRetryAsync(async (db) => await db.StringGetAsync("e007"));
        Employee e007FromCache = JsonSerializer.Deserialize<Employee>(getMessageResult);
        Console.WriteLine($"{prefix}: Deserialized Employee .NET object:{Environment.NewLine}");
        Console.WriteLine($"{prefix}: Employee.Name : {e007FromCache.Name}");
        Console.WriteLine($"{prefix}: Employee.Id   : {e007FromCache.Id}");
        Console.WriteLine($"{prefix}: Employee.Age  : {e007FromCache.Age}{Environment.NewLine}");
    }

可以使用 StringSetAsync 和 StringGetAsync 方法来存储和检索缓存项。

在示例中，你可以看到 Message 密钥设置为值。应用更新了该缓存值。应用还执行了 PING 和命令。

处理缓存中的 .NET 对象

Redis 服务器将大多数数据存储为字符串，但这些字符串可能包含许多类型的数据，包括序列化的二进制数据，可在缓存中存储 .NET 对象时使用。

Azure Redis 缓存可以缓存 .NET 对象以及基元数据类型，但在缓存 .NET 对象之前，必须将其序列化。

此 .NET 对象序列化是应用程序开发人员的责任，同时赋与开发人员选择序列化程序的弹性。

在 Program.cs 中定义了以下 Employee 类，因此示例还可以显示如何获取和设置序列化对象：

class Employee
    {
        public string Id { get; set; }
        public string Name { get; set; }
        public int Age { get; set; }

        public Employee(string id, string name, int age)
        {
            Id = id;
            Name = name;
            Age = age;
        }
    }

运行示例

如果你已打开任何文件，请保存这些文件，并使用以下命令生成应用：

dotnet build

使用以下命令运行应用来测试 .NET 对象的序列化：

dotnet run

Console app completed

清理资源

如果你要继续使用本快速入门，可以保留并重复使用创建的资源。

如果已完成快速入门示例应用程序，可以删除本快速入门中创建的 Azure 资源，以免产生费用。

重要

删除资源组的操作不可逆，资源组以及其中的所有资源将被永久删除。请确保不会意外删除错误的资源组或资源。如果在现有资源组（其中包含要保留的资源）中为托管此示例而创建了相关资源，可在左侧逐个删除这些资源，而不是删除资源组。

删除资源组的步骤

登录到 Azure 门户，然后选择“资源组”。
在“按名称筛选...”文本框中键入资源组的名称。本文的说明使用了名为 TestResources 的资源组。在结果列表中的资源组上，选择“...”，然后选择“删除资源组” 。
系统会要求确认是否删除该资源组。键入资源组的名称进行确认，然后选择“删除”。

片刻之后，将会删除该资源组及其包含的所有资源。