ASP.NET Core SignalR.NET 客户端ASP.NET Core SignalR .NET Client

这篇文章中的代码示例是使用 ASP.NET Core SignalR.NET 客户端的 WPF 应用。

包是 .net 客户端连接到 SignalR 中心所必需的。

Visual Studio

若要安装客户端库，请在 "包管理器控制台" 窗口中运行以下命令：

若要安装客户端库，请在命令 shell 中运行以下命令：

连接到中心Connect to a hub

若要建立连接，请创建 HubConnectionBuilder 并调用 Build。在建立连接时，可以配置中心 URL、协议、传输类型、日志级别、标头和其他选项。通过在 Build中插入任意 HubConnectionBuilder 方法来配置任何所需的选项。开始与 StartAsync的连接。

using System;
using System.Threading.Tasks;
using System.Windows;
using Microsoft.AspNetCore.SignalR.Client;
namespace SignalRChatClient
{
    public partial class MainWindow : Window
    {
        HubConnection connection;
        public MainWindow()
        {
            InitializeComponent();
            connection = new HubConnectionBuilder()
                .WithUrl("http://localhost:53353/ChatHub")
                .Build();
            connection.Closed += async (error) =>
            {
                await Task.Delay(new Random().Next(0,5) * 1000);
                await connection.StartAsync();
            };
        }
        private async void connectButton_Click(object sender, RoutedEventArgs e)
        {
            connection.On<string, string>("ReceiveMessage", (user, message) =>
            {
                this.Dispatcher.Invoke(() =>
                {
                   var newMessage = $"{user}: {message}";
                   messagesList.Items.Add(newMessage);
                });
            });
            try
            {
                await connection.StartAsync();
                messagesList.Items.Add("Connection started");
                connectButton.IsEnabled = false;
                sendButton.IsEnabled = true;
            }
            catch (Exception ex)
            {
            }
        }
        private async void sendButton_Click(object sender, RoutedEventArgs e)
        {
            try
            {
                await connection.InvokeAsync("SendMessage", 
                    userTextBox.Text, messageTextBox.Text);
            }
            catch (Exception ex)
            {                
                messagesList.Items.Add(ex.Message);                
            }
        }
    }
}

可以将配置为使用 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 状态，并激发事件。这为用户提供警告连接已丢失并禁用 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。

警告

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 状态，并激发事件。这为尝试手动重新启动连接或通知用户连接永久丢失有机会。

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，将更新以反映到目前为止所用的时间量，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;
        }
    }
}

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

警告

使用事件来响应丢失的连接。例如，你可能需要自动重新连接。

Closed 事件需要一个返回 Task的委托，该委托允许异步代码在不使用 async void的情况下运行。若要在同步运行的 Closed 事件处理程序中满足委托签名，请返回 Task.CompletedTask：

connection.Closed += (error) => {
    // Do your close logic.
    return Task.CompletedTask;
};

异步支持的主要原因是，可以重启连接。启动连接是一种异步操作。

在重启连接的 Closed 处理程序中，考虑等待一些随机延迟以防止服务器过载，如以下示例中所示：

connection.Closed += async (error) =>
{
    await Task.Delay(new Random().Next(0,5) * 1000);
    await connection.StartAsync();
};

从客户端调用集线器方法Call hub methods from client

InvokeAsync 在集线器上调用方法。将 hub 方法名称和在 hub 方法中定义的所有参数传递到 InvokeAsync。 SignalR 是异步的，因此在进行调用时使用 async 和 await。

await connection.InvokeAsync("SendMessage", 
    userTextBox.Text, messageTextBox.Text);

InvokeAsync 方法返回一个在服务器方法返回时完成的 Task。返回值（如果有）作为 Task的结果提供。服务器上的方法所引发的任何异常都会产生出错的 Task。使用 await 语法等待服务器方法完成，并 try…catch 语法来处理错误。

SendAsync 方法返回一个在消息已发送到服务器时完成的 Task。不会提供返回值，因为此 Task 不会等待服务器方法完成。发送消息时，在客户端上引发的任何异常都会产生出错的 Task。使用 await 和 try…catch 语法处理发送错误。

备注

如果在无服务器模式下使用 Azure SignalR 服务，则无法从客户端调用集线器方法。有关详细信息，请参阅。

定义集线器在生成之后但在启动连接之前 connection.On 调用的方法。

connection.On<string, string>("ReceiveMessage", (user, message) =>
{
    this.Dispatcher.Invoke(() =>
    {
       var newMessage = $"{user}: {message}";
       messagesList.Items.Add(newMessage);
    });
});

当服务器端代码使用 SendAsync 方法调用时，connection.On 中的前面的代码将运行。

错误处理和日志记录Error handling and logging

使用 try-catch 语句处理错误。检查 Exception 对象，以确定在发生错误之后要执行的适当操作。

try
{
    await connection.InvokeAsync("SendMessage", 
        userTextBox.Text, messageTextBox.Text);
}
catch (Exception ex)
{                
    messagesList.Items.Add(ex.Message);

JavaScript 客户端