SignalR Hub服务器断开连接后无法恢复的问题求助

1. 启用服务器端详细日志定位根源 #

本地无法复现问题时，必须通过服务器端日志捕获底层错误。在appsettings.json中添加SignalR相关的调试日志配置：

{
  "Logging": {
    "LogLevel": {
      "Default": "Information",
      "Microsoft.AspNetCore.SignalR": "Debug",
      "Microsoft.AspNetCore.Http.Connections": "Debug"
    }
  }
}

或者在Program.cs中通过代码配置：

builder.Logging.AddFilter("Microsoft.AspNetCore.SignalR", LogLevel.Debug);
builder.Logging.AddFilter("Microsoft.AspNetCore.Http.Connections", LogLevel.Debug);

这些日志会记录连接建立、断开、消息传输过程中的所有细节，包括未被自定义代码捕获的底层异常。

2. 配置SignalR连接超时与资源回收 #

调整SignalR的连接参数，让服务器更快回收异常连接，避免资源耗尽：

builder.Services.AddSignalR(options =>
{
    options.ClientTimeoutInterval = TimeSpan.FromSeconds(30); // 客户端无响应超时时间
    options.KeepAliveInterval = TimeSpan.FromSeconds(10); // 心跳包间隔
    options.MaximumReceiveMessageSize = 1024 * 1024; // 根据业务调整最大消息大小
})
.AddWebSocketTransport(options =>
{
    options.CloseTimeout = TimeSpan.FromSeconds(5); // WebSocket关闭超时时间
});

3. 全局捕获Hub生命周期异常 #

创建Hub全局过滤器，捕获连接、断开、方法调用过程中的所有异常，避免异常扩散影响服务器：

public class HubExceptionFilter : IHubFilter
{
    private readonly ILogger<HubExceptionFilter> _logger;

    public HubExceptionFilter(ILogger<HubExceptionFilter> logger)
    {
        _logger = logger;
    }

    public async ValueTask<object> InvokeMethodAsync(HubInvocationContext invocationContext, Func<HubInvocationContext, ValueTask<object>> next)
    {
        try
        {
            return await next(invocationContext);
        }
        catch (Exception ex)
        {
            _logger.LogError(ex, "Hub method {MethodName} failed (ConnectionId: {ConnId})", 
                invocationContext.MethodName, invocationContext.Context.ConnectionId);
            throw;
        }
    }

    public async Task OnConnectedAsync(HubLifetimeContext context, Func<HubLifetimeContext, Task> next)
    {
        try
        {
            await next(context);
        }
        catch (Exception ex)
        {
            _logger.LogError(ex, "Client {ConnId} failed to connect", context.Context.ConnectionId);
            throw;
        }
    }

    public async Task OnDisconnectedAsync(HubLifetimeContext context, Exception exception, Func<HubLifetimeContext, Exception, Task> next)
    {
        if (exception != null)
        {
            _logger.LogError(exception, "Client {ConnId} disconnected with error", context.Context.ConnectionId);
        }
        await next(context, exception);
    }
}

然后在Program.cs中注册过滤器：

builder.Services.AddSignalR(options =>
{
    options.AddFilter<HubExceptionFilter>();
});

4. 排查服务器资源瓶颈 #

当SignalR服务异常时，检查服务器以下指标：

• CPU、内存使用率
• .NET线程池线程数（避免同步阻塞操作耗尽线程）
• TCP连接数（是否存在连接泄漏）
  如果Hub中存在同步阻塞代码（如.Result、.Wait()），全部替换为异步await调用，防止线程池耗尽。

5. 优化客户端重连策略 #

调整客户端重连逻辑，采用指数退避减少服务器压力：

const conn = new signalR.HubConnectionBuilder()
    .withUrl("/someHub")
    .withAutomaticReconnect({
        nextRetryDelayInMilliseconds: retryContext => {
            // 指数退避，最大重连间隔30秒
            return Math.min(1000 * Math.pow(2, retryContext.previousRetryCount), 30000);
        }
    })
    .build();

conn.start().catch(err => console.error(err.toString()));

conn.onclose(err => {
    console.error("Connection closed:", err);
});

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