StackExchange Redis Cache在SetAsync报错时是否自动重建连接？如何配置？

一、关于启用UseForceReconnect特性 #

可以启用，但默认情况下无法直接解决你遇到的READONLY错误，核心原因如下：

1. 触发条件限制：从源码逻辑看，OnRedisError方法仅在捕获到RedisConnectionException或SocketException时，才会清空客户端缓存的连接。而你遇到的"READONLY You can't write against a read only replica"属于RedisServerException，不在默认触发范围内。
2. 启用方式：若要开启该特性，可在应用启动阶段通过以下代码设置AppContext开关：

   AppContext.SetSwitch("Microsoft.AspNetCore.Caching.StackExchangeRedis.UseForceReconnect", true);
   

3. 扩展适配：如果需要让该特性覆盖READONLY错误场景，你可以通过自定义RedisCache子类或包装类，捕获RedisServerException并判断错误信息包含"READONLY"时，通过反射访问RedisCache内部的_cache字段手动清空连接缓存。

二、其他报错时重建连接的方法 #

1. 自定义缓存包装类捕获特定错误并重置连接 #

实现IDistributedCache包装类，在写入操作中捕获READONLY错误，主动清空缓存连接后重试：

public class RedisCacheWithReconnect : IDistributedCache
{
    private readonly RedisCache _innerCache;
    private readonly FieldInfo _cacheField;

    public RedisCacheWithReconnect(RedisCache innerCache)
    {
        _innerCache = innerCache;
        _cacheField = typeof(RedisCache).GetField("_cache", BindingFlags.NonPublic | BindingFlags.Instance);
    }

    public async Task SetAsync(string key, byte[] value, DistributedCacheEntryOptions options, CancellationToken token = default)
    {
        try
        {
            await _innerCache.SetAsync(key, value, options, token);
        }
        catch (RedisServerException ex) when (ex.Message.Contains("READONLY"))
        {
            // 清空缓存的连接，触发下一次请求重建连接
            _cacheField?.SetValue(_innerCache, null);
            // 重试一次写入操作
            await _innerCache.SetAsync(key, value, options, token);
        }
    }

    // 其他接口方法直接委托给内部RedisCache实例
    public byte[] Get(string key) => _innerCache.Get(key);
    public Task<byte[]> GetAsync(string key, CancellationToken token = default) => _innerCache.GetAsync(key, token);
    public void Refresh(string key) => _innerCache.Refresh(key);
    public Task RefreshAsync(string key, CancellationToken token = default) => _innerCache.RefreshAsync(key, token);
    public void Remove(string key) => _innerCache.Remove(key);
    public Task RemoveAsync(string key, CancellationToken token = default) => _innerCache.RemoveAsync(key, token);
    public void Set(string key, byte[] value, DistributedCacheEntryOptions options) => _innerCache.Set(key, value, options);
}

然后在DI容器中替换原RedisCache注册：

services.AddStackExchangeRedisCache(options =>
{
    options.Configuration = "你的Redis连接字符串";
});

// 替换为自定义的带重连逻辑的缓存实现
services.Replace(ServiceDescriptor.Singleton<IDistributedCache>(sp =>
{
    var redisCache = sp.GetRequiredService<RedisCache>();
    return new RedisCacheWithReconnect(redisCache);
}));

2. 配置ConnectionMultiplexer连接策略 #

直接配置ConnectionMultiplexer的核心参数，增强连接容错能力：

• 设置AbortOnConnectFail=false：允许客户端在初始连接失败后持续尝试重新连接
• 监听ConnectionFailed事件：在连接异常时触发自定义重置逻辑，主动刷新连接池

示例配置代码：

var config = new ConfigurationOptions
{
    EndPoints = { "你的Redis节点地址" },
    AbortOnConnectFail = false,
    SyncTimeout = 5000,
    AsyncTimeout = 5000
};

var multiplexer = ConnectionMultiplexer.Connect(config);
multiplexer.ConnectionFailed += (sender, args) =>
{
    // 连接失败时的自定义处理，比如日志记录或主动触发连接重置
    ((ConnectionMultiplexer)sender).GetDatabase().Ping();
};

3. 自定义重试策略针对特定错误 #

通过实现IRetryPolicy，对READONLY错误添加重试逻辑，让客户端在遇到写入只读副本错误时自动重试：

public class CustomRedisRetryPolicy : IRetryPolicy
{
    public TimeSpan? RetryDelay(IRedisCommand command, Exception exception)
    {
        // 仅针对READONLY错误添加重试延迟
        if (exception is RedisServerException ex && ex.Message.Contains("READONLY"))
        {
            return TimeSpan.FromMilliseconds(150);
        }
        return null;
    }
}

// 配置到ConnectionMultiplexer
var multiplexer = ConnectionMultiplexer.Connect(new ConfigurationOptions
{
    EndPoints = { "你的Redis节点地址" },
    RetryPolicy = new CustomRedisRetryPolicy()
});

注意事项 #

• 线程安全：重置连接时需确保线程安全，避免并发操作导致的连接池混乱
• 重试限制：添加重试逻辑时需设置最大重试次数，防止无限循环占用资源

内容的提问来源于stack exchange，提问作者Eugeniy Maksimov