.NET 8 Blazor迁移后SignalR推送通知接收失败排查

问题场景 #

将Blazor Server应用迁移到.NET 8后，在A.razor组件中调用HubConnection的SendAsync方法已触发SignalR Hub的SendMessage方法，但MainLayout.razor组件未接收到任何推送消息。

核心原因分析 #

1. SignalR消息订阅与发送的参数不匹配 #

SignalR的消息订阅严格匹配参数数量和类型：

• Hub的SendMessage方法向客户端推送时，传递了3个参数：user、msg、DateTime.Now.ToShortTimeString()（字符串类型的时间）
• 但MainLayout中订阅ReceiveMessage时，只声明接收2个字符串参数：hubConnection.On<string, string>("ReceiveMessage", ...)

这种参数不匹配会导致SignalR无法找到对应的订阅方法，自然不会触发回调逻辑。

2. AddLign方法中不必要的重复初始化操作 #

A.razor的AddLign方法中调用了await OnInitializedAsync();，虽然不会重复创建HubConnection（因为有null判断），但每次执行都会重新调用CodeService.GetCodeAccesAsync()，属于冗余操作，还可能引发意外的UI更新问题。

3. MainLayout中状态更新的潜在逻辑问题 #

在ReceiveMessage回调中，currentMessages = AllNotificationMessages.Where(elem => elem.Id != myMsg.Id).ToList();这行代码存在风险：如果myMsg未初始化（Id为默认值），可能过滤掉所有消息，导致UI无法显示，但这属于显示问题，不是接收不到消息的直接原因。

解决方案 #

1. 修正订阅的参数匹配 #

调整MainLayout中的订阅代码，匹配Hub推送的参数数量和类型：

private HubConnection? hubConnection;
protected override async Task OnInitializedAsync()
{
    hubConnection = new HubConnectionBuilder()
       .WithUrl(Navigation.ToAbsoluteUri("/chathub"))
       .Build();
    
    // 匹配Hub推送的3个参数：user(string)、message(string)、time(string)
    hubConnection.On<string, string, string>("ReceiveMessage", (user, message, time) =>
    {
        string encodedMsg = $"{user}: {message} ({time})";
        AllNotificationMessages.Add(new NotificationModel("Mon Titre"));
        // 增加空值判断，避免myMsg未初始化导致的异常
        currentMessages = AllNotificationMessages.Where(elem => elem.Id != myMsg?.Id).ToList();
        StateHasChanged();
    });
    
    try
    {
        await hubConnection.StartAsync();
    }
    catch (Exception ex)
    {
        // 记录连接异常，便于排查
        Console.WriteLine($"SignalR连接失败: {ex.Message}");
    }
}

2. 移除冗余的初始化调用 #

修改A.razor的AddLign方法，单独刷新数据而非调用OnInitializedAsync()：

private async Task AddLign()
{
    if (hubConnection is not null)
    {
        await hubConnection.SendAsync("SendMessage", "userInput", "messageInput");
    }
    // 单独刷新数据，避免重复初始化连接
    listCode = await CodeService.GetCodeAccesAsync();
    StateHasChanged(); // 若需要更新UI则添加
}

3. 添加连接错误处理（可选但推荐） #

在两个组件的HubConnection创建逻辑中添加错误处理，便于排查连接问题：

hubConnection.Closed += async (error) =>
{
    // 连接关闭时自动重试（可根据需求调整重试策略）
    await Task.Delay(new Random().Next(0, 5) * 1000);
    await hubConnection.StartAsync();
};

内容的提问来源于stack exchange，提问作者Benoît S