我正在寻找Redis连接丢失后恢复[在多线程环境中]的引用实现。到目前为止找不到任何有意义的东西。

设置:我有一个 Azure worker 角色，它在多个线程中运行相同的代码 (ThreadProc)。最初，我有静态 ConnectionMultiplexer 并在每次 Redis 操作之前执行 .GetDatabase() 。这根本没有通过压力测试(一旦负载从低增加到中等，就会出现大量“无法连接”错误)。我已将其更改为:

static readonly ConnectionMultiplexer _connection = ConnectionMultiplexer.Connect(...);
static readonly IDatabase _cache = _connection.GetDatabase();

void ThreadProc() // running in multiple threads
{
    while (true)
    {
      // using _cache here
    }
}

即使在高负载(每个工作角色实例 1000+ op/s)下，它也能很好地工作，直到我得到“没有可用的连接来为这个操作服务”，然后事情就无法恢复了。

请告诉我可以从间歇性连接问题中恢复的正确/推荐代码是什么。

最佳答案

编辑 2015-05-02:虽然更高版本的 StackExchange.Redis 客户端明确应该在内部自动处理这种“丢失连接”->“重新连接”逻辑，但我的测试毫无疑问地表明他们无法成功实现这一目标，因此仍然需要这种东西，至少在繁忙的环境中是这样。我将下面的代码从缓存层中抽出一段时间，结果出现了数以万计的连接失败错误。我把它放回去，那些都消失了。

编辑 2015-02-24:不再需要此方法。 StackExchange.Redis的最新版本客户端正确处理断开连接 - 他们会自动重新连接，下面的解决方法只会干扰事情。出于历史目的将其保留在这里，但我的建议是忽略它。

这是我的 SimpleCacheRedis<T> 中的一些方法显示我如何处理问题的包装器:

public async Task<TValue> GetAsync(string key, Func<Task<TValue>> missingFunc)
{
    key = GetKey(key);
    var value = default(TValue);
    try
    {
        var db = _connection.GetDatabase();
        var str = await db.StringGetAsync(key);
        if (!str.IsNullOrEmpty)
        {
            value = _jsonSerializer.Deserialize<TValue>(str);
        }
    }
    catch (RedisConnectionException ex)
    {
        HandleRedisConnectionError(ex);
    }
    catch (Exception ex)
    {
        _logger.Error("Error retrieving item '" + key +
                      "' from Redis cache; falling back to missingFunc(). Error = " + ex);
    }
    if (value == default(TValue))
    {
        present = false;
        value = await missingFunc();
        await PerformAddAsync(key, value);
    }
    return value;
}

private void HandleRedisConnectionError(RedisConnectionException ex)
{
    _logger.Error("Connection error with Redis cache; recreating connection for the next try, and falling back to missingFunc() for this one. Error = " + ex.Message);
    Task.Run(async () =>
    {
        try
        {
            await CreateConnectionAsync();
        }
        catch (Exception genEx)
        {
            _logger.Error("Unable to recreate redis connection (sigh); bailing for now: " + genEx.Message);
        }
    });
}

private async Task CreateConnectionAsync()
{
    if (_attemptingToConnect) return;
    var sw = new StringWriter();
    try
    {
        _attemptingToConnect = true;
        _connection = await ConnectionMultiplexer.ConnectAsync(_redisCs, sw);
    }
    catch (Exception ex)
    {
        _logger.Error("Unable to connect to redis async: " + ex);
        _logger.Debug("internal log: \r\n" + sw);
        throw;
    }
    finally
    {
        _attemptingToConnect = false;
    }
}

基本上，如果我发现由于 RedisConnectionException 而无法连接到 Redis , 我分拆了一个单独的 async重新创建共享连接的任务。当然，那个调用可能会失败，但无论如何调用都会在那段时间失败。一旦成功，任何新调用都将使用新(重新)创建的连接。就像我上面说的，有点无聊。

我的情况可能与您的略有不同，因为我没有将 Redis 用作永久存储，而只是用作缓存。这意味着丢失 redis 连接的唯一影响是我需要从数据库而不是缓存中检索结果。所以我可以稍微宽松地对待某些事情。

关于c# - 从 Redis 连接丢失中恢复，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/24922782/