ASP.NET Core 6 Web API与.NET 6 WinForms客户端SignalR回调未触发

问题现象 #

搭建SignalR Hub后，客户端可正常发送消息至服务端，但服务端调用Clients.All.ReceiveMessage(message)后，客户端的回调函数未触发。

核心问题分析 #

对比服务端与客户端的代码，发现回调方法的参数不匹配：

• 服务端调用await Clients.All.ReceiveMessage(message);，仅传递了1个ChatMessage类型的参数
• 客户端注册回调时，却声明接收2个参数：_signalRConnection.On<string, ChatMessage>("ReceiveMessage", ...)，期望一个string和一个ChatMessage

这种参数数量/类型不匹配的情况，会导致SignalR客户端无法匹配到对应的回调方法，自然不会触发执行。

修复步骤 #

1. 修正客户端回调注册代码 #

将客户端的ReceiveMessage回调注册改为匹配服务端的参数数量和类型：

_signalRConnection.On<ChatMessage>("ReceiveMessage", (message) =>
{
    if (txtMessages.InvokeRequired)
    {
        txtMessages.Invoke(new Action(() => txtMessages.AppendText($"{message.From} : {message?.MessageText}" + Environment.NewLine)));
    }
    else
    {
        txtMessages.AppendText($"{message.From} : {message?.MessageText}" + Environment.NewLine);
    }
});

（注：如果需要显示发送者名称，可以从message.From字段获取，或者在服务端调用时额外传递参数，确保两端参数定义完全一致即可）

2. 验证强类型Hub的接口定义 #

由于服务端使用了强类型Hub（ChatHub : Hub<IChatClient>），需要确保IChatClient接口中的ReceiveMessage方法定义与服务端调用、客户端注册完全一致：

public interface IChatClient
{
    Task ReceiveMessage(ChatMessage message);
}

3. 额外检查点 #

• 建议将回调注册放在连接启动之前，避免短暂窗口期间错过消息：

  // 先注册回调，再启动连接
  _signalRConnection.On<ChatMessage>("ReceiveMessage", (message) => { ... });
  
  _signalRConnection.StartAsync().ContinueWith(task => { ... });
  

• 查看服务端日志，确认Clients.All.ReceiveMessage(message)未抛出异常（当前代码包含try-catch，可通过日志排查潜在错误）
• 确保客户端与服务端的ChatMessage类属性完全一致（名称、类型、可序列化特性），避免序列化/反序列化失败

修复后的客户端核心代码示例 #

private void connectChat()
{
    _signalRConnection = new HubConnectionBuilder()
       .WithUrl(Properties.Settings.Default.APIPath + "/hubs/chat").WithAutomaticReconnect()
       .Build();

    try
    {
        // 先注册回调
        _signalRConnection.On<ChatMessage>("ReceiveMessage", (message) =>
        {
            if (txtMessages.InvokeRequired)
            {
                txtMessages.Invoke(new Action(() => txtMessages.AppendText($"{message.From} : {message?.MessageText}" + Environment.NewLine)));
            }
            else
            {
                txtMessages.AppendText($"{message.From} : {message?.MessageText}" + Environment.NewLine);
            }
        });

        // 再启动连接
        _signalRConnection.StartAsync().ContinueWith(task =>
        {
            if (task.IsFaulted)
            {
                this.Invoke(new Action(() => txtMessages.AppendText("连接打开出错: " + task.Exception.GetBaseException().Message)));
            }
            else
            {
                this.Invoke(new Action(() => txtMessages.AppendText("已连接")));
            }
        });
    }
    catch (Exception)
    {
        throw;
    }
}

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