.Net Core SignalR - 连接超时 - 心跳定时器 - 连接状态更改处理

Posted 2023-03-17

【中文标题】.Net Core SignalR - 连接超时 - 心跳定时器 - 连接状态更改处理

【英文标题】：.Net Core SignalR - connection timeout - heartbeat timer - connection state change handling

【发布时间】：2017-11-09 18:12:47

【问题描述】：

首先要明确一点，这个问题是关于 .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

对于 HubClass，我添加了public async Task HeartBeat(DateTime now) => await 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 或其他）

我已经实现了一个正常工作的客户端心跳，至少在连接中断之前：

集线器类：public async Task HeartBeatTock() => await Task.CompletedTask;

客户：

var heartBeatTockTimer; 功能发送心脏跳动（） connection.invoke("HeartBeatTock"); connection.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"...) - 这看起来很愚蠢。

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

【问题讨论】：

啊，一个谜解开了。如果我将 IServiceProvider 注入到 Configure 方法中，我可能可以设置它。重要信息...

所以这行得通：app.UseSignalR(routes => routes.MapHub<SignalRHub>("signalr"); ); TimerCallback SignalRHeartBeat = async (x) => await serviceProvider.GetService<IHubContext<SignalRHub>>().Clients.All.InvokeAsync("Heartbeat", DateTime.Now); ; var timer = new Timer(SignalRHeartBeat).Change(TimeSpan.FromSeconds(0), TimeSpan.FromSeconds(30)); 我将更新我的问题，现在只剩下客户需要处理了。

感谢您发布您的解决方案。关于服务器端代码的问题。计时器触发时，我收到 ObjectDisposedException 。计时器触发时，我的 ServiceProvider 已经死了。你有没有遇到过这个问题，你是怎么解决的？

@EricVaughan ***.com/a/50641557/221683

我必须在独立商店中注册我的应用程序的消息处理程序，否则在创建新连接时它们会丢失。当消息到达时，连接的“on”处理程序遍历集合，转发消息。

【参考方案1】：

这是在 IIS 后面运行 SignalR Core 时的issue。 IIS 将在 2 分钟后关闭空闲连接。长期计划是添加保持活动消息，作为副作用，这将阻止 IIS 关闭连接。要暂时解决此问题，您可以：

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

【讨论】：

谢谢帕维尔！服务器超时问题已解决，我已经实现了计时器（请参阅上面的评论）。剩下的唯一事情是客户端重新连接，例如IO 挂起或连接状态的任何其他更改。我不知道如何在客户端库中访问它。

我已经更新了我的问题以显示已实现的服务器端，以及我（失败的）尝试重新连接客户端。

【参考方案2】：

我现在有了一个可行的解决方案（目前已在 Chrome 和 FF 中进行了测试）。为了激励你想出更好的东西，或者在你自己想出类似的东西时为你节省一点时间，我在这里发布我的解决方案：

上述问题中描述了 Heartbeat-“Tick”消息（服务器定期 ping 客户端）。 客户端（“Tock”部分）现在有：

注册连接的函数，以便可以重复回调方法（connection.on()）；否则，它们会在重新启动“新 HubConnection”后丢失 注册 TockTimer 的函数 以及一个实际发送 Tock ping 的函数

tock 方法在发送时捕获错误，并尝试启动新连接。由于计时器一直在运行，我正在注册一个新连接，然后只需坐下来等待下一次调用。 将客户端放在一起：

// keeps the connection object
var connection = null;
// stores the ID from SetInterval
var heartBeatTockTimer = 0;
// how often should I "tock" the server
var heartBeatTockTimerSeconds = 10;
// how often should I retry after connection loss?
var maxRetryAttempt = 5;
// the retry should wait less long then the TockTimer, or calls may overlap
var retryWaitSeconds = heartBeatTockTimerSeconds / 2;
// how many retry attempts did we have?
var currentRetryAttempt = 0;
// helper function to wait a few seconds
$.wait = function(miliseconds) 
    var defer = $.Deferred();
    setTimeout(function()  defer.resolve(); , miliseconds);
    return defer;
;
// first routine start of the connection
registerSignalRConnection();
function registerSignalRConnection() 
    ++currentRetryAttempt;
    if (currentRetryAttempt > maxRetryAttempt) 
        console.log("Clearing registerHeartBeatTockTimer");
        clearInterval(heartBeatTockTimer);
        heartBeatTockTimer = 0;
        throw "Retry attempts exceeded.";
    
    if (connection !== null) 
        console.log("registerSignalRConnection was not null", connection);
        connection.stop().catch(err => console.log(err));
    
    console.log("Creating new connection");
    connection = new signalR.HubConnection("/signalr",  transport: signalR.TransportType.ServerSentEvents );
    connection.on("Heartbeat", serverTime =>  console.log(serverTime); );
    connection.start().then(() => 
        console.log("Connection started, starting timer.");
        registerHeartBeatTockTimer();
    ).catch(exception => 
        console.log("Error connecting", exception, connection);
    );

function registerHeartBeatTockTimer() 
    // make sure we're registered only once
    if (heartBeatTockTimer !== 0) return;
    console.log("Registering registerHeartBeatTockTimer");
    if (connection !== null)
        heartBeatTockTimer = setInterval(sendHeartBeatTock, heartBeatTockTimerSeconds * 1000);
    else
        console.log("Connection didn't allow registry");


function sendHeartBeatTock() 
    console.log("Standard attempt HeartBeatTock");
    connection.invoke("HeartBeatTock").then(() =>  
         console.log("HeartbeatTock worked.") )
         .catch(err => 
             console.log("HeartbeatTock Standard Error", err);
             $.wait(retryWaitSeconds * 1000).then(function() 
                 console.log("executing attempt #" + currentRetryAttempt.toString());
             registerSignalRConnection();
         );
         console.log("Current retry attempt: ", currentRetryAttempt);
     );
 

【讨论】：

您也可以发布服务器端吗？

@EricBrunner 看看问题，它显示了服务器部分

@ExternalUse 服务器上也需要HeartbeatTock方法。

另外，currentRetryAttempt 应该在成功创建新连接后重置。

你需要服务器端和客户端的心跳吗？如果有，为什么？

【参考方案3】：

基于ExternalUse的answer的客户端版本...

import * as signalR from '@aspnet/signalr'
import _ from 'lodash'

var connection = null;
var sendHandlers = [];
var addListener = f => sendHandlers.push(f);

function registerSignalRConnection() 

    if (connection !== null) 
        connection.stop().catch(err => console.log(err));
    

    connection = new signalR.HubConnectionBuilder()
        .withUrl('myHub')
        .build();

    connection.on("Heartbeat", serverTime =>
        console.log("Server heartbeat: " + serverTime));

    connection.on("Send", data =>
        _.each(sendHandlers, value => value(data)));

    connection.start()
        .catch(exception =>
            console.log("Error connecting", exception, connection));


registerSignalRConnection();

setInterval(() =>
    connection.invoke("HeartBeatTock")
        .then(() => console.log("Client heatbeat."))
        .catch(err =>     
            registerSignalRConnection();
        ), 10 * 1000);

export  addListener ;