自动重新连接

可以将 HubConnection 配置为使用 HubConnectionBuilder上的 WithAutomaticReconnect 方法自动重新连接。 默认情况下，它不会自动重新连接。

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 事件。 这为用户提供警告连接已丢失并禁用 UI 元素的机会。 非交互式应用可以开始排队或删除消息。

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 事件。 这为用户提供了通知用户已重新建立连接并取消排队消息的排队的机会。

由于连接完全是服务器的新内容，因此向 Reconnected 事件处理程序提供了一个新的 ConnectionId。

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 具有三个属性： PreviousRetryCount、ElapsedTime 和 RetryReason，分别为 long、TimeSpan 和 Exception。 第一次重新连接尝试之前，PreviousRetryCount 和 ElapsedTime 均为零，RetryReason 将是导致连接丢失的异常。 每次重试失败后，PreviousRetryCount 会递增1，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();

或者，你可以编写将手动重新连接客户端的代码，如手动重新连接中所示。