asp.net-core-mvc - .Net Core SignalR - 连接超时 - 心跳计时器 - 连接状态更改处理

Question

首先要明确的是，这个问题是关于 .Net Core SignalR，而不是以前的版本。

新的 SignalR 在 IIS 背后的 WebSockets 上存在问题(我无法让它们在 Chrome/Win7/IIS Express 上工作)。因此，我使用服务器发送事件 (SSE)。然而，问题是，大约 2 分钟后超时，连接状态从 2 变为 3。自动重新连接已被删除(显然它在以前的版本中无论如何都不能很好地工作)。

我现在想实现一个心跳计时器来阻止客户端超时，每 30 秒一次滴答就可以完成这项工作。

11 月 10 日更新

我现在已经成功实现了服务器端 Heartbeat，基本上取自 Ricardo Peres 的 https://weblogs.asp.net/ricardoperes/signalr-in-asp-net-core

• 在startup.cs中，添加到public void Configure(IApplicationBuilder app, IHostingEnvironment env, IServiceProvider serviceProvider)

    app.UseSignalR(routes =>  
    {  
        routes.MapHub<TheHubClass>("signalr");  
    });

    TimerCallback SignalRHeartBeat = async (x) => {   
    await serviceProvider.GetService<IHubContext<TheHubClass>>().Clients.All.InvokeAsync("Heartbeat", DateTime.Now); };
    var timer = new Timer(SignalRHeartBeat).Change(TimeSpan.FromSeconds(0), TimeSpan.FromSeconds(30));            

• 集线器类

对于 HubClass，我添加了 public async Task HeartBeat(DateTime now) => wait Clients.All.InvokeAsync("Heartbeat", now);

显然，计时器、发送的数据(我只是发送 DateTime)和客户端方法名称都可以不同。

更新.Net Core 2.1+

请参阅下面的评论；不应再使用计时器回调。我现在已经实现了一个 IHostedService(或者更确切地说是抽象的BackgroundService)来做到这一点:

public class HeartBeat : BackgroundService
{
    private readonly IHubContext<SignalRHub> _hubContext;
    public HeartBeat(IHubContext<SignalRHub> hubContext)
    {
        _hubContext = hubContext;
    }
    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        while (!stoppingToken.IsCancellationRequested)
        {
            await _hubContext.Clients.All.SendAsync("Heartbeat", DateTime.Now, stoppingToken);
            await Task.Delay(30000, stoppingToken);
        }            
    }
}

在您的启动类中，将其连接到 services.AddSignalR(); 之后:

services.AddHostedService<HeartBeat>();

• 客户端

    var connection = new signalR.HubConnection("/signalr", { transport: signalR.TransportType.ServerSentEvents });
    connection.on("Heartbeat", serverTime => { console.log(serverTime); });

初始问题的其余部分

剩下的就是如何正确地重新连接客户端，例如IO 暂停后(浏览器的计算机进入休眠状态、失去连接、更换 Wifi 或其他原因)

我已经实现了一个可以正常工作的客户端 Heartbeat，至少在连接中断之前是这样:

• 集线器类:public async Task HeartBeatTock() => wait Task.CompletedTask;

• 客户端:

  var heartBeatTockTimer;函数 sendHeartBeatTock() { 连接.invoke("HeartBeatTock");}连接.start().then(args => { heartBeatTockTimer = setInterval(sendHeartBeatTock, 10000);});

例如，在浏览器挂起 IO 后，invoke 方法将抛出异常 - 该异常无法通过简单的 try/catch 捕获，因为它是异步的。我尝试为我的 HeartBeatTock 做的事情类似于(伪代码):

function sendHeartBeatTock
    try connection.invoke("HeartbeatTock)
    catch exception
         try connection.stop()
         catch exception (and ignore it)
         finally
              connection = new HubConnection().start()
    repeat try connection.invoke("HeartbeatTock")
    catch exception
        log("restart did not work")
        clearInterval(heartBeatTockTimer)
        informUserToRefreshBrowser()

现在，由于一些原因，这不起作用。由于异步运行，invoke 在代码块执行后抛出异常。它看起来好像公开了 .catch() 方法，但我不确定如何在那里正确实现我的想法。另一个原因是启动新连接需要我重新实现所有服务器调用，例如“connection.on(”send”...) - 这看起来很愚蠢。

任何有关如何正确实现重新连接客户端的提示将不胜感激。

Answer 1

这是一个issue在 IIS 后面运行 SignalR Core 时。 IIS 将在 2 分钟后关闭空闲连接。长期计划是添加保持事件消息，其副作用是阻止 IIS 关闭连接。要暂时解决该问题，您可以:

• 定期向客户发送消息
• 将 IIS 中的空闲超时设置更改为 described在这里
• 如果连接关闭，则在客户端重新启动连接
• 使用不同的传输(例如，长轮询，因为您无法在 IIS 后面的 Win7/Win2008 R2 上使用 webSockets)