SignalR 核心如何每 n 秒向客户端发送一次消息

Question

AKA "从后台服务向客户端发送消息">

我希望我的 SignalR 服务器每 n 秒更新一次仪表板。我现在正在使用这个：

public class MyHub : Hub
{
public override Task OnConnectedAsync()
{
Observable.Interval(TimeSpan.FromSeconds(0.5)).Subscribe(l =>
{
var alt = CalcAltitude(l);
SendMessage(alt);
});
return Task.CompletedTask;
}
private void SendMessage(double alt)
{
Clients.All.SendAsync("SendAction", new Status() {Altitude = alt});
}
private double CalcAltitude(long l)
{
return 100 * Math.Sin((double) l / 100) + 200;
}
}
public class Status
{
public double Altitude { get; set; }
}

当我的代码被执行时，它会抛出一个异常，指出

无法访问已释放的对象

我怀疑我在这里做错了什么。

那么，及时向所有客户端发送消息的正确方法是什么？

Answer 1

好的，这次答案不是来自Stack Overflow，而是来自另一个来源。

这可以使用 ASP.NET 核心 + SignalR 核心中的此代码完成。

您将需要 2 个部分。

• 后台服务本身(更新客户端(：https://github.com/davidfowl/UT3/blob/fb12e182d42d2a5a902c1979ea0e91b66fe60607/UTT/Scavenger.cs
• 设置(接线(部分：https://github.com/davidfowl/UT3/blob/fb12e182d42d2a5a902c1979ea0e91b66fe60607/UTT/Startup.cs#L46

非常感谢大卫·福勒的回复！

Answer 2

var hubContext = GlobalHost.ConnectionManager.GetHubContext<MyHub>();
hubContext.Clients.All.SendnewData(Data);

将此代码放在每秒更新或计算数据的位置。

比如：您的数据库进程已完成，然后广播新数据

using Microsoft.AspNet.SignalR;
using Microsoft.AspNet.SignalR.Infrastructure;
using Microsoft.AspNet.Mvc;
public class TestController : Controller
{
private IHubContext testHub;
public TestController(IConnectionManager connectionManager)
{
testHub = connectionManager.GetHubContext<TestHub>();
testHub.Clients.All.SendnewData(Data);
}
}