如何在ASP.NET 6中通过SignalR从服务器定期发送消息

在ASP.NET Core SignalR中，不能直接获取Hub实例——因为Hub是客户端连接时动态创建的，每个连接对应一个独立的Hub实例，直接实例化的Hub没有关联任何客户端连接，无法完成消息推送。正确的做法是使用IHubContext<THub>，它是SignalR提供的用于全局操作Hub通信的核心对象。

以下是两种可行的实现方式，推荐使用第一种符合ASP.NET Core最佳实践的方案：

方案一：使用托管服务（推荐，生产环境首选） #

通过BackgroundService（IHostedService的实现类）管理后台定时任务，依赖注入IHubContext完成消息推送，ASP.NET Core宿主会自动处理任务的启动、停止生命周期。

步骤1：创建后台广播服务 #

// UIBroadcastService.cs
public class UIBroadcastService : BackgroundService
{
    private readonly IHubContext<SiteLayoutHub> _hubContext;

    // 构造函数注入IHubContext
    public UIBroadcastService(IHubContext<SiteLayoutHub> hubContext)
    {
        _hubContext = hubContext;
    }

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        // 循环推送，支持应用关闭时的取消信号
        while (!stoppingToken.IsCancellationRequested)
        {
            var uiState = GetUIState();
            // 直接通过IHubContext向所有客户端推送消息
            await _hubContext.Clients.All.SendAsync("UIUpdateMessage", uiState, stoppingToken);
            // 用Task.Delay替代Thread.Sleep，避免阻塞线程
            await Task.Delay(500, stoppingToken);
        }
    }

    // 你的UI状态获取逻辑
    private UIState GetUIState()
    {
        return new UIState 
        { 
            // 填充具体状态数据
        };
    }
}

// 假设的UIState实体类
public class UIState
{
    // 自定义属性，比如：
    // public string CurrentStatus { get; set; }
    // public int OnlineUsers { get; set; }
}

步骤2：注册服务并映射Hub #

修改Program.cs，添加SignalR服务、注册托管服务，最后映射Hub：

var builder = WebApplication.CreateBuilder(args);

// 添加SignalR服务
builder.Services.AddSignalR();
// 注册后台广播服务
builder.Services.AddHostedService<UIBroadcastService>();

var app = builder.Build();

// 映射SignalR Hub路由
app.MapHub<SiteLayoutHub>("hubs/site");

app.Run();

方案二：直接获取服务实例（快速测试用，不推荐生产） #

如果只是快速验证功能，可以在Program.cs中直接从服务容器获取IHubContext，启动后台任务：

var builder = WebApplication.CreateBuilder(args);

builder.Services.AddSignalR();

var app = builder.Build();

app.MapHub<SiteLayoutHub>("hubs/site");

// 从服务容器获取IHubContext
var hubContext = app.Services.GetRequiredService<IHubContext<SiteLayoutHub>>();

// 启动后台推送任务
_ = Task.Run(async () =>
{
    while (true)
    {
        var uiState = GetUIState();
        await hubContext.Clients.All.SendAsync("UIUpdateMessage", uiState);
        await Task.Delay(500);
    }
});

app.Run();

// 本地定义UI状态获取方法
UIState GetUIState()
{
    return new UIState();
}

public class UIState { /* 自定义属性 */ }

可选：封装Hub通信逻辑 #

如果需要复用推送逻辑，可以封装一个Hub服务类，将通信细节与业务代码分离：

// SiteLayoutHubService.cs
public class SiteLayoutHubService
{
    private readonly IHubContext<SiteLayoutHub> _hubContext;

    public SiteLayoutHubService(IHubContext<SiteLayoutHub> hubContext)
    {
        _hubContext = hubContext;
    }

    // 封装推送方法
    public async Task SendUIUpdateMessage(UIState uiState)
    {
        await _hubContext.Clients.All.SendAsync("UIUpdateMessage", uiState);
    }
}

然后在Program.cs注册该服务：

builder.Services.AddScoped<SiteLayoutHubService>();

最后在托管服务中注入这个服务使用即可。

内容的提问来源于stack exchange，提问作者Efi Z