клиент .NET core SignalR ASP.NET

Автоматическое повторное подключение

Его HubConnection можно настроить для автоматического повторного подключения с помощью метода в объекте WithAutomaticReconnect HubConnectionBuilder. По умолчанию он не будет автоматически повторно подключаться.

HubConnection connection= new HubConnectionBuilder()
    .WithUrl(new Uri("http://127.0.0.1:5000/chathub"))
    .WithAutomaticReconnect()
    .Build();

Без параметров WithAutomaticReconnect() клиент настраивает ожидание 0, 2, 10 и 30 секунд соответственно, прежде чем пытаться выполнить каждую попытку повторного подключения, остановившись после четырех неудачных попыток.

Перед началом любых попыток HubConnection повторного подключения он перейдет в HubConnectionState.Reconnecting состояние и вызовет Reconnecting событие. Это дает возможность предупредить пользователей о том, что подключение потеряно и отключает элементы пользовательского интерфейса. Неинтерактивные приложения могут начинать очередь или удалять сообщения.

connection.Reconnecting += error =>
{
    Debug.Assert(connection.State == HubConnectionState.Reconnecting);

    // Notify users the connection was lost and the client is reconnecting.
    // Start queuing or dropping messages.

    return Task.CompletedTask;
};

Если клиент успешно повторно подключается в течение первых четырех попыток, HubConnection он вернется к состоянию Connected и вызовет Reconnected событие. Это дает возможность сообщить пользователям о том, что подключение было восстановлено и удалено из очереди.

Так как подключение выглядит совершенно новым на сервере, новое ConnectionId будет предоставлено обработчикам Reconnected событий.

connection.Reconnected += connectionId =>
{
    Debug.Assert(connection.State == HubConnectionState.Connected);

    // Notify users the connection was reestablished.
    // Start dequeuing messages queued while reconnecting if any.

    return Task.CompletedTask;
};

WithAutomaticReconnect() не настраивает повторные HubConnection начальные сбои запуска, поэтому при выполнении сбоев запуска необходимо обрабатывать вручную:

public static async Task<bool> ConnectWithRetryAsync(HubConnection connection, CancellationToken token)
{
    // Keep trying to until we can start or the token is canceled.
    while (true)
    {
        try
        {
            await connection.StartAsync(token);
            Debug.Assert(connection.State == HubConnectionState.Connected);
            return true;
        }
        catch when (token.IsCancellationRequested)
        {
            return false;
        }
        catch
        {
            // Failed to connect, trying again in 5000 ms.
            Debug.Assert(connection.State == HubConnectionState.Disconnected);
            await Task.Delay(5000);
        }
    }
}

Если клиент не успешно пересоединяется в течение первых четырех попыток, HubConnection он перейдет в Disconnected состояние и вызовет Closed событие. Это дает возможность перезапустить подключение вручную или сообщить пользователям, что подключение было потеряно окончательно.

connection.Closed += error =>
{
    Debug.Assert(connection.State == HubConnectionState.Disconnected);

    // Notify users the connection has been closed or manually try to restart the connection.

    return Task.CompletedTask;
};

Чтобы настроить настраиваемое количество попыток повторного подключения перед отключением или изменением времени повторного подключения, WithAutomaticReconnect принимает массив чисел, представляющий задержку в миллисекундах, чтобы ждать перед началом каждой попытки повторного подключения.

HubConnection connection= new HubConnectionBuilder()
    .WithUrl(new Uri("http://127.0.0.1:5000/chathub"))
    .WithAutomaticReconnect(new[] { TimeSpan.Zero, TimeSpan.Zero, TimeSpan.FromSeconds(10) })
    .Build();

    // .WithAutomaticReconnect(new[] { TimeSpan.Zero, TimeSpan.FromSeconds(2), TimeSpan.FromSeconds(10), TimeSpan.FromSeconds(30) }) yields the default behavior.

В предыдущем примере настраивается HubConnection запуск повторного подключения сразу после потери подключения. Это также верно для конфигурации по умолчанию.

Если первая попытка повторного подключения завершается сбоем, вторая попытка повторного подключения также начнется немедленно, а не ожидает 2 секунд, как в конфигурации по умолчанию.

Если вторая попытка повторного подключения завершается ошибкой, третья попытка повторного подключения начнется через 10 секунд, которая снова похожа на конфигурацию по умолчанию.

Настраиваемое поведение снова развернется от поведения по умолчанию, остановив после третьего сбоя повторного подключения. В конфигурации по умолчанию будет еще одна попытка повторного подключения в течение еще 30 секунд.

Если требуется еще больше контроля над временем и количеством попыток автоматического повторного подключения, WithAutomaticReconnect принимает объект, реализующий IRetryPolicy интерфейс, имеющий один метод с именем NextRetryDelay.

NextRetryDelay принимает один аргумент с типом RetryContext. Имеет RetryContext три свойства: PreviousRetryCountElapsedTime и RetryReason, которые являются long,a TimeSpan и Exception соответственно. Перед первой попыткой PreviousRetryCount повторного подключения оба и ElapsedTime будет нулевым, и RetryReason будет исключение, которое привело к потере подключения. После каждой неудачной попытки PreviousRetryCount повтора будет увеличиваться по одному, ElapsedTime будет обновлено, чтобы отразить время повторного подключения до сих пор, и RetryReason будет исключение, которое вызвало последнюю попытку повторного подключения.

NextRetryDelay должен возвращать значение TimeSpan, представляющее время ожидания перед следующей попыткой повторного подключения или null HubConnection если необходимо прекратить повторное подключение.

public class RandomRetryPolicy : IRetryPolicy
{
    private readonly Random _random = new Random();

    public TimeSpan? NextRetryDelay(RetryContext retryContext)
    {
        // If we've been reconnecting for less than 60 seconds so far,
        // wait between 0 and 10 seconds before the next reconnect attempt.
        if (retryContext.ElapsedTime < TimeSpan.FromSeconds(60))
        {
            return TimeSpan.FromSeconds(_random.NextDouble() * 10);
        }
        else
        {
            // If we've been reconnecting for more than 60 seconds so far, stop reconnecting.
            return null;
        }
    }
}

HubConnection connection = new HubConnectionBuilder()
    .WithUrl(new Uri("http://127.0.0.1:5000/chathub"))
    .WithAutomaticReconnect(new RandomRetryPolicy())
    .Build();

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