SignalR在BackgroundService的StopAsync中无法向客户端发送消息

在IIS 10中点击标准重启按钮时，尝试通过BackgroundService的StopAsync方法向所有连接的SignalR客户端发送自定义通知，但客户端仅收到断开连接的默认通知，自定义消息未送达。相关代码无报错，SendAsync任务显示执行完成但无效果：

public sealed class MyService : BackgroundService
{
    // ...
    public override async Task StopAsync(CancellationToken cancellationToken)
    {
        Task t = _myHubDI.Clients // IHubContext<MyHub>, 已确认非null
                .Group("ALL")
                .SendAsync("qwerty1234");

        await t;
        var s = t.Status; // 状态为RanToCompletion
        var e = t.Exception; // 无异常
        
        await base.StopAsync(cancellationToken);
    }
    // ...
}

1. IIS优雅关闭超时过短 #

IIS默认的关闭超时时间较短，可能在SendAsync的消息真正发送到客户端前，服务器就已强制切断连接。

解决方法： #

• ASP.NET Core项目：在Program.cs中配置主机关闭超时，给消息发送留足时间：

builder.Services.Configure<HostOptions>(options =>
{
    options.ShutdownTimeout = TimeSpan.FromSeconds(20); // 调整为合适的时长，比如20秒
});

• 传统ASP.NET项目：在web.config中设置shutdownTimeLimit：

<system.web>
    <httpRuntime shutdownTimeLimit="20" /> <!-- 单位：秒 -->
</system.web>

2. SignalR组维护异常 #

确认客户端是否正确加入了"ALL"组，检查Hub的OnConnectedAsync方法是否有正确的组添加逻辑：

public class MyHub : Hub
{
    public override async Task OnConnectedAsync()
    {
        await Groups.AddToGroupAsync(Context.ConnectionId, "ALL");
        await base.OnConnectedAsync();
    }

    public override async Task OnDisconnectedAsync(Exception? exception)
    {
        await Groups.RemoveFromGroupAsync(Context.ConnectionId, "ALL");
        await base.OnDisconnectedAsync(exception);
    }
}

3. 消息发送未等待确认 #

SendAsync返回的任务完成仅代表消息已进入发送队列，不代表已送达客户端。可以通过增加短暂延迟或确保发送过程不被中断来优化：

public override async Task StopAsync(CancellationToken cancellationToken)
{
    // 创建链接令牌，避免原token提前取消消息发送
    using var linkedCts = CancellationTokenSource.CreateLinkedTokenSource(cancellationToken);
    linkedCts.CancelAfter(TimeSpan.FromSeconds(15)); // 超时时间

    try
    {
        await _myHubDI.Clients
            .Group("ALL")
            .SendAsync("qwerty1234", linkedCts.Token);
        
        // 短暂延迟，确保消息有时间发送到客户端
        await Task.Delay(500, linkedCts.Token);
    }
    catch (OperationCanceledException)
    {
        // 处理超时或取消情况
    }

    await base.StopAsync(cancellationToken);
}

4. 检查客户端监听逻辑 #

确认客户端是否正确监听了"qwerty1234"事件，避免因事件名称拼写错误或监听代码未执行导致消息未被接收：

// 客户端示例（JavaScript）
connection.on("qwerty1234", function() {
    alert("服务器即将重启，请保存当前操作！");
});

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