WPF应用中SignalR HubProxy.On长时间运行后不触发问题

看起来你遇到的是SignalR客户端在长时间运行后，无法接收服务器推送的消息，但调用hubProxy.Invoke正常、连接状态也显示正常的问题。结合你的代码，我来分析几个可能的原因和对应的解决方案：

1. UI线程阻塞导致回调无法执行 #

你的OnMMessage方法直接调用了MessageBox.Show，而SignalR默认会将回调调度到WPF的UI线程执行。如果UI线程长时间被其他操作阻塞（比如未关闭的弹窗、耗时的UI任务），回调就无法被触发。

解决方案：
改用Dispatcher.BeginInvoke异步执行UI操作，并添加日志确认是否收到消息：

private void OnMMessage(string message)
{
    // 先记录日志，确认是否收到服务器推送的消息
    System.Diagnostics.Debug.WriteLine($"收到服务器消息: {message}");
    
    // 异步调度到UI线程执行弹窗，避免阻塞回调线程
    Application.Current.Dispatcher.BeginInvoke(new Action(() =>
    {
        MessageBox.Show(message);
    }));
}

2. 回调委托被GC回收 #

SignalR的hubProxy.On使用弱引用存储回调委托，如果你的回调是实例方法（比如OnMMessage），在某些情况下可能被GC意外回收，导致无法触发。

解决方案：
将回调委托保存为类的成员变量，保持强引用：

// 新增成员变量保存回调委托
private Action<string> _messageReceivedCallback;

private void InitializeConnection()
{
    connection = new HubConnection(url);
    hubProxy = connection.CreateHubProxy("SignalRHub");
    connection.StateChanged += connection_StateChanged;
    
    // 保存委托到成员变量，避免被GC回收
    _messageReceivedCallback = OnMMessage;
    hubProxy.On<string>("OnMessage", _messageReceivedCallback);
    
    connection.Start();
}

3. 静默断开连接未触发重连 #

有时候底层的WebSocket/长连接会出现静默断开（比如网络波动、服务器超时），但SignalR的连接状态没有及时更新为Disconnected，导致客户端无法接收消息，但Invoke因为会触发请求重试可能暂时正常。

解决方案：
优化重连逻辑，添加心跳配置，并在重连时重新注册订阅：

客户端优化重连： #

async void connection_StateChanged(StateChange obj)
{
    if (obj.NewState == ConnectionState.Disconnected)
    {
        Debug.WriteLine("连接断开，尝试重连...");
        try
        {
            // 尝试复用现有连接重新启动，而非新建连接
            await connection.StartAsync();
            // 重新注册回调（保险起见）
            hubProxy.On<string>("OnMessage", _messageReceivedCallback);
            // 重新调用服务器的Subscribe方法，确保订阅状态同步
            await hubProxy.Invoke("Subscribe");
            Debug.WriteLine("重连成功");
        }
        catch (Exception ex)
        {
            Debug.WriteLine($"重连失败: {ex.Message}，5秒后重试");
            await Task.Delay(5000);
            // 重试失败则重新初始化连接
            InitializeConnection();
        }
    }
}

配置客户端心跳： #

在创建HubConnection时添加超时和心跳配置：

connection = new HubConnection(url);
// 设置连接超时和心跳间隔，及时检测静默断开
connection.Configuration.TransportConnectTimeout = TimeSpan.FromSeconds(30);
connection.Configuration.KeepAlive = TimeSpan.FromSeconds(10);

服务器端配置心跳（Startup.cs）： #

app.MapSignalR(new HubConfiguration
{
    EnableDetailedErrors = true,
    // 配置心跳和客户端超时，及时清理无效连接
    KeepAlive = TimeSpan.FromSeconds(10),
    ClientTimeoutInterval = TimeSpan.FromSeconds(30)
});

4. 服务器端订阅状态不同步 #

你的服务器端用SubscriberCache管理订阅客户端，但如果客户端长时间运行中出现静默断开后重连，可能订阅状态没有正确同步。

解决方案：
确保服务器端的OnReconnected方法正确添加连接ID到订阅缓存，并且发送消息时只发给订阅的客户端（而非Clients.All）：

public void SendMessage(string message)
{
    logger.Info("message sending to client");
    // 只发给订阅的客户端，而非所有客户端
    Clients.Clients(SubscriberCache.Subscribers).OnMessage(message);
}

最后，建议在客户端和服务器端添加详细的日志，记录连接状态变化、消息收发情况，这样更容易定位问题出现的具体场景。

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