只是要预先明确,这个问题是关于 .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) => 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; 函数 sendHeartBeatTock() { 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"...)——这看起来很傻。
任何有关如何正确实现重新连接客户端的提示将不胜感激。