Поддержание открытого соединения Redis с помощью BookSleeve

Ответ 1

Поскольку у меня нет хороших ответов, я придумал это решение (BTW благодарит @Simon и @Alex за ваши ответы!).

Я хочу поделиться им со всем сообществом в качестве ссылки. Конечно, любые исправления будут высоко оценены.

using System;
using System.Net.Sockets;
using BookSleeve;

namespace Redis
{
    public sealed class RedisConnectionGateway
    {
        private const string RedisConnectionFailed = "Redis connection failed.";
        private RedisConnection _connection;
        private static volatile RedisConnectionGateway _instance;

        private static object syncLock = new object();
        private static object syncConnectionLock = new object();

        public static RedisConnectionGateway Current
        {
            get
            {
                if (_instance == null)
                {
                    lock (syncLock)
                    {
                        if (_instance == null)
                        {
                            _instance = new RedisConnectionGateway();
                        }
                    }
                }

                return _instance;
            }
        }

        private RedisConnectionGateway()
        {
            _connection = getNewConnection();
        }

        private static RedisConnection getNewConnection()
        {
            return new RedisConnection("127.0.0.1" /* change with config value of course */, syncTimeout: 5000, ioTimeout: 5000);
        }

        public RedisConnection GetConnection()
        {
            lock (syncConnectionLock)
            {
                if (_connection == null)
                    _connection = getNewConnection();

                if (_connection.State == RedisConnectionBase.ConnectionState.Opening)
                    return _connection;

                if (_connection.State == RedisConnectionBase.ConnectionState.Closing || _connection.State == RedisConnectionBase.ConnectionState.Closed)
                {
                    try
                    {
                        _connection = getNewConnection();
                    }
                    catch (Exception ex)
                    {
                        throw new Exception(RedisConnectionFailed, ex);
                    }
                }

                if (_connection.State == RedisConnectionBase.ConnectionState.Shiny)
                {
                    try
                    {
                        var openAsync = _connection.Open();
                        _connection.Wait(openAsync);
                    }
                    catch (SocketException ex)
                    {
                        throw new Exception(RedisConnectionFailed, ex);
                    }
                }

                return _connection;
            }
        }
    }
}

Ответ 2

В других системах (таких как ADO.NET) это достигается с помощью пула соединений. Вы никогда не получаете новый объект Connection, но на самом деле получаете его из пула.

Пул сам управляет новыми соединениями и мертвыми соединениями, независимо от кода вызывающего абонента. Идея здесь состоит в том, чтобы иметь лучшую производительность (создание нового соединения является дорогостоящим) и выжить в сетевых проблемах (код вызывающего абонента будет терпеть неудачу, пока сервер не будет работать, но возобновится, когда он вернется в онлайн). На самом деле есть один пул на AppDomain, за "тип" подключения.

Такое поведение возникает, когда вы смотрите строки подключения ADO.NET. Например, строка подключения SQL Server (ConnectionString Property) имеет понятие "Объединение", "Макс. Размер пула", "Минимальный размер пула" и т.д.. Это также метод ClearAllPools, который используется для программного reset текущих пулов AppDomain, если необходимо, например.

Я не вижу ничего близкого к этой функции, смотрящего на код BookSleeve, но, похоже, это планируется для следующего выпуска: BookSleeve RoadMap.

В то же время, я полагаю, вы можете написать свой собственный пул соединений, так как RedisConnection имеет событие ошибки, которое вы можете использовать для этого, чтобы определить, когда он мертв.

Ответ 3

Я не программист на С#, но я бы посмотрел на проблему:

• Я бы назвал общую функцию, которая будет принимать в качестве параметров соединение redis и выражение лямбда, представляющее команду Redis

• если попытка выполнить команду Redis приведет к исключению, указывающему на проблему подключения, я повторно инициализирую соединение и повторю операцию

• Если исключение не создано, просто верните результат

Вот какой-то псевдокод:

function execute(redis_con, lambda_func) {
    try {
        return lambda_func(redis_con)
    }
    catch(connection_exception) {
        redis_con = reconnect()
        return  lambda_func(redis_con)
    }
}