c# - ServiceStack Redis(AWS ElastiCache 实施)使用 .Net 核心导致错误 No master found in: redis-cluster-xxxxxxxx:637
问题描述
我已经实现了以下版本的 ServiceStack .net Core Redis 库:
服务堆栈.Redis.Core 5.9.2
我正在使用该库访问我创建的 Redis 缓存,以使用 .NET Core 3.1 为我的 AWS 无服务器应用程序保留值。我已经为 ServiceStack Redis 支付了商业许可。
在尝试创建 Redis 客户端时,我的应用程序会定期且无警告地捕获以下错误:
Exception: System.Exception: No master found in: redis-cluster-api-prd-lcs.in-xxxxxxxx:6379
at ServiceStack.Redis.RedisResolver.CreateRedisClient(RedisEndpoint config, Boolean master) in C:\BuildAgent\work\b2a0bfe2b1c9a118\src\ServiceStack.Redis\RedisResolver.cs:line 116
at ServiceStack.Redis.RedisResolver.CreateMasterClient(Int32 desiredIndex) in C:\BuildAgent\work\b2a0bfe2b1c9a118\src\ServiceStack.Redis\RedisResolver.cs:line 142
at ServiceStack.Redis.RedisManagerPool.GetClient() in C:\BuildAgent\work\b2a0bfe2b1c9a118\src\ServiceStack.Redis\RedisManagerPool.cs:line 174
at LCSApi.UtilityCommand.Cache.IsCacheValueExists(String cacheKey, RedisManagerPool pool) in D:\a\1\s\testapi\Utility.cs:line 167
at LCSApi.Functions.LcsConfigurationSweeper(ILambdaContext context) in D:\a\1\s\testapi\Function.cs:line 2028
Exception: System.Exception: No master found in: redis-cluster-api-prd-lcs.in
其他时候,相同的代码可以正常工作。我的实现很简单:
private readonly RedisManagerPool _redisClient;
_redisClient = new RedisManagerPool(Environment.GetEnvironmentVariable("CACHE_URL") + ":" +
Environment.GetEnvironmentVariable("CACHE_PORT"));
public static T GetCacheValue<T>(string cacheKey, RedisManagerPool pool)
{
T cacheValue;
try
{
//StackExchange.Redis.IDatabase cache = Functions._redisConnect.GetDatabase();
//string value = cache.StringGet(cacheKey);
//cacheValue = (T)Convert.ChangeType(value, typeof(T));
using (var client = pool.GetClient())
{
client.RetryCount = Convert.ToInt32(Environment.GetEnvironmentVariable("CACHE_RETRY_COUNT"));
client.RetryTimeout = Convert.ToInt32(Environment.GetEnvironmentVariable("CACHE_RETRY_TIMEOUT"));
cacheValue = client.Get<T>(cacheKey);
}
}
catch (Exception ex)
{
//Console.WriteLine($"[CACHE_EXCEPTION] {ex.ToString()}");
cacheValue = GetParameterSSMFallback<T>(cacheKey);
//Console.WriteLine($"[CACHE_EXCEPTION] Fallback SSM parameter --> {cacheValue}");
}
return cacheValue;
}
碰巧我不得不编写一个“回退”例程来从其来源的 AWS Parameter Store 中获取值。不理想。这是 Redis 的配置:
我可以在任何地方在线找到关于此错误的任何信息。我尝试注册 ServiceStack 论坛但没有成功,即使我有商业许可证,由于某种原因它不会让我注册。有人可以帮忙吗?
解决方案
该错误是由于网络实例未连接到 redis ROLE命令所标识的主实例。这可能发生在 ElastiCache 故障转移期间,最终主实例将以原始 DNS 名称返回:
Amazon ElastiCache for Redis 将通过获取新的服务资源来修复节点,然后将节点的现有 DNS 名称重定向到新的服务资源。因此,Redis 节点的 DNS 名称保持不变,但 Redis 节点的 IP 地址会随时间变化。
ServiceStack.Redis将尝试使用所有指定的主连接(通常只有 1 个)连接到主实例。如果它无法连接到主实例,它必须放弃,因为客户端希望在读/写主实例上执行操作。
如果预计主实例将以相同的 DNS 名称返回,我们可以使用自定义IRedisResolver
在指定的时间段内不断重试主实例的同一连接,例如:
public class ElasticCacheRedisResolver : RedisResolver
{
public override RedisClient CreateRedisClient(RedisEndpoint config, bool master)
{
if (master)
{
//ElastiCache Redis will failover & retain same DNS for master
var firstAttempt = DateTime.UtcNow;
Exception firstEx = null;
var retryTimeSpan = TimeSpan.FromMilliseconds(config.RetryTimeout);
var i = 0;
while (DateTime.UtcNow - firstAttempt < retryTimeSpan) {
try
{
var client = base.CreateRedisClient(config, master:true);
return client;
}
catch (Exception ex)
{
firstEx ??= ex;
ExecUtils.SleepBackOffMultiplier(++i);
}
}
throw new TimeoutException(
$"Could not resolve master within {config.RetryTimeout}ms RetryTimeout", firstEx);
}
return base.CreateRedisClient(config, master:false);
}
}
您使用 Redis 客户端管理器进行配置,例如:
private static readonly RedisManagerPool redisManager;
redisManager = new RedisManagerPool(...) {
RedisResolver = new ElasticCacheRedisResolver()
};
注意:您应该只使用 1 个Redis 客户端管理器的共享实例,这样RedisManagerPool
共享同一个连接池。如果包含 的类redisManager
不是单例,则应将其分配给静态字段,以确保使用相同的单例实例来检索客户端。
推荐阅读
- laravel - Laravel Passport Vue 组件没有发布到正确的路径
- c - 递归语句中返回的值与计算的不同
- javascript - 如何在jstree中获取点击的对象
- google-maps - 如何在 Go 中实现 Google Maps API 的 isLocationOnEdge?
- javascript - 连续的 keyup 事件无法正常工作
- c++ - 通过引用传递函数正确性
- regex - 匹配数字与
- c# - C# Jagged 数组循环实现问题
- perl - 安装 perl 模块 Bio::Perl 的问题
- python - Python 脚本包不适用于 Atom。有小费吗?