Blazor WebAssembly中SignalR向指定用户发送通知的实现方案问询

原方案问题说明 #

你当前的全量广播+客户端过滤思路存在两个核心缺陷：一是所有在线用户都会收到不属于自己的通知，存在数据泄露风险；二是全量广播会浪费大量服务端和客户端带宽，性能表现差。SignalR本身已经内置了和Microsoft Identity的原生集成能力，可以直接实现精准的单用户推送，不需要手动做过滤逻辑。

服务端实现改造 #

1. 先配置带鉴权的SignalR Hub #

首先给你的通知Hub加上[Authorize]特性，确保只有经过Identity身份校验的客户端才能建立连接：

[Authorize]
public class NotificationHub : Hub
{
    // 不需要手动维护用户和连接ID的映射关系，SignalR会自动处理
}

在Program.cs中确保鉴权中间件顺序正确：

// 必须先注册身份验证、授权中间件，再注册SignalR路由
app.UseAuthentication();
app.UseAuthorization();

app.MapHub<NotificationHub>("/notificationHub");

2. 改造通知发送逻辑 #

SignalR内置了IUserIdProvider，默认会自动读取用户Claims中的ClaimTypes.NameIdentifier作为用户标识，你可以直接调用Clients.User()方法精准推送：

public async System.Threading.Tasks.Task SendPushNotification(ClaimsPrincipal user, string someNotificationMessage)
{
    string userGuid = user.FindFirst(ClaimTypes.NameIdentifier).Value;
    // 仅推送给指定用户的所有活跃连接，不会广播给其他用户
    await _hubContext.Clients.User(userGuid).SendAsync("notification", someNotificationMessage);
}

Blazor WASM客户端实现 #

1. 建立带身份校验的SignalR连接 #

通过IAccessTokenProvider获取Identity下发的访问令牌，带入SignalR连接请求中完成鉴权，不需要额外做身份校验逻辑：

@inject IAccessTokenProvider TokenProvider
@inject NavigationManager NavigationManager
@implements IAsyncDisposable

private HubConnection? _hubConnection;
private List<string> _notificationList = new();

protected override async Task OnInitializedAsync()
{
    var tokenResult = await TokenProvider.RequestAccessToken();
    if (tokenResult.TryGetToken(out var token))
    {
        // 构建带身份凭证的SignalR连接
        _hubConnection = new HubConnectionBuilder()
            .WithUrl(NavigationManager.ToAbsoluteUri("/notificationHub"), options =>
            {
                options.AccessTokenProvider = () => Task.FromResult(token.Value);
            })
            .Build();

        // 监听服务端推送的通知
        _hubConnection.On<string>("notification", (message) =>
        {
            // 这里收到的通知都是发给当前登录用户的，不需要再做身份校验
            _notificationList.Add(message);
            StateHasChanged();
        });

        await _hubConnection.StartAsync();
    }
}

// 页面销毁时释放连接
public async ValueTask DisposeAsync()
{
    if (_hubConnection != null)
    {
        await _hubConnection.DisposeAsync();
    }
}

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