StackExchange.Redis 同步方法的 ConnectionMultiplexer 池

StackExchange.Redis ConnectionMultiplexer pool for synchronous methods

如果我们将它用于同步方法,实现 ConnectionMultiplexer 池是否有意义?

所以我所说的池是指创建 StackExchange.Redis ConnectionMultiplexer 的多个实例,存储这些对象,当我想与 Redis 服务器通信时,我从池中取出最少使用的一个。这是为了根据本文中的第 10 条建议防止由于队列大小过大而导致超时:https://azure.microsoft.com/en-us/blog/investigating-timeout-exceptions-in-stackexchange-redis-for-azure-redis-cache/

我有疑问,因为我不确定如果 connectionMultiplexer 阻塞线程直到调用 returns.

,队列怎么可能发生

在我看来,拥有同步方法调用的池毫无意义,但 Redis 最佳实践文章建议创建这种池,而不考虑方法类型(sync/async)

我认为你在这里感到困惑。 ConnectionMultiplexer 不会“被阻止”。创建一个 ConnectionMultiplexer 给你一个类似工厂的对象,你可以用它创建 IDatabase 个实例。然后,您可以使用这些实例来执行正常的 Redis 查询。您也可以使用连接多路复用器本身执行 Redis 查询,但这些是服务器查询,不太可能经常执行。
因此,简而言之,无论 sync/async/mixed 使用情况如何,拥有一个连接多路复用器池都会有很大帮助。


为了进一步扩展,这里有一个非常简单的池实现,当然可以进一步增强:

public interface IConnectionMultiplexerPool
{
    Task<IDatabase> GetDatabaseAsync();
}

public class ConnectionMultiplexerPool : IConnectionMultiplexerPool
{
    private readonly ConnectionMultiplexer[] _pool;
    private readonly ConfigurationOptions _redisConfigurationOptions;

    public ConnectionMultiplexerPool(int poolSize, string connectionString) : this(poolSize, ConfigurationOptions.Parse(connectionString))
    {
    }

    public ConnectionMultiplexerPool(int poolSize, ConfigurationOptions redisConfigurationOptions)
    {
        _pool = new ConnectionMultiplexer[poolSize];
        _redisConfigurationOptions = redisConfigurationOptions;
    }

    public async Task<IDatabase> GetDatabaseAsync()
    {
        var leastPendingTasks = long.MaxValue;
        IDatabase leastPendingDatabase = null;

        for (int i = 0; i < _pool.Length; i++)
        {
            var connection = _pool[i];

            if (connection == null)
            {
                _pool[i] = await ConnectionMultiplexer.ConnectAsync(_redisConfigurationOptions);

                return _pool[i].GetDatabase();
            }

            var pending = connection.GetCounters().TotalOutstanding;

            if (pending < leastPendingTasks)
            {
                leastPendingTasks = pending;
                leastPendingDatabase = connection.GetDatabase();
            }
        }

        return leastPendingDatabase;
    }
}