如何告知SignalR当前已认证的用户身份？

一、SignalR识别用户的核心逻辑 #

SignalR 通过 Context.UserIdentifier 标识当前连接所属的用户，默认从 ASP.NET Core 认证系统的用户声明中获取。如果不用 Bearer 令牌，我们可以通过自定义逻辑来指定这个用户标识，从而实现向特定用户发送私有消息。

二、不用Bearer令牌的用户关联方法 #

方法1：自定义IUserIdProvider（全局生效，推荐） #

这个方案让 SignalR 全局使用自定义的用户标识来源（比如查询字符串中的用户名），无需修改 Hub 的核心逻辑，直接就能复用微软文档里的 Clients.User(userName) 发送消息。

1. 实现自定义IUserIdProvider

using Microsoft.AspNetCore.SignalR;

public class UsernameBasedUserIdProvider : IUserIdProvider
{
    public string GetUserId(HubConnectionContext connection)
    {
        // 从查询字符串提取用户名
        connection.GetHttpContext().Request.Query.TryGetValue("username", out var username);
        // 若没有获取到用户名， fallback 到连接ID（可选）
        return username.FirstOrDefault() ?? connection.ConnectionId;
    }
}

2. 注册自定义服务

在 Program.cs 中替换默认的用户ID提供者：

builder.Services.AddSignalR();
// 注册自定义的用户ID提供者
builder.Services.AddSingleton<IUserIdProvider, UsernameBasedUserIdProvider>();

3. 前端连接时传递用户名

前端创建连接时，通过查询字符串带上用户名：

const connection = new signalR.HubConnectionBuilder()
    .withUrl("/chatHub?username=jonas") // 这里传递目标用户名
    .build();

async function startConnection() {
    try {
        await connection.start();
        console.log("连接成功");
    } catch (err) {
        console.error(err);
        setTimeout(startConnection, 5000);
    }
}
startConnection();

完成以上步骤后，你就可以直接使用微软文档中的示例代码发送私有消息：

public Task SendPrivateMessage(string user, string message)
{
    return Clients.User(user).SendAsync("ReceiveMessage", message);
}

方法2：手动维护连接-用户映射（灵活可控） #

如果不想全局修改用户标识逻辑，可以在 Hub 中手动维护连接ID与用户名的映射关系，适合临时或需要额外控制的场景。

1. 在Hub中维护映射字典

using Microsoft.AspNetCore.SignalR;
using System.Collections.Concurrent;

public class ChatHub : Hub
{
    // 线程安全字典，存储用户名到连接ID列表的映射
    private static readonly ConcurrentDictionary<string, List<string>> _userConnectionMap = new();

    public override async Task OnConnectedAsync()
    {
        // 从查询字符串获取用户名
        if (Context.GetHttpContext().Request.Query.TryGetValue("username", out var username))
        {
            var userName = username.FirstOrDefault();
            if (!string.IsNullOrEmpty(userName))
            {
                // 将当前连接ID添加到用户的连接列表
                _userConnectionMap.AddOrUpdate(
                    userName,
                    new List<string> { Context.ConnectionId },
                    (key, existingList) => {
                        existingList.Add(Context.ConnectionId);
                        return existingList;
                    }
                );
            }
        }
        await base.OnConnectedAsync();
    }

    public override async Task OnDisconnectedAsync(Exception exception)
    {
        // 断开连接时移除对应映射
        foreach (var entry in _userConnectionMap)
        {
            entry.Value.Remove(Context.ConnectionId);
            if (entry.Value.Count == 0)
            {
                _userConnectionMap.TryRemove(entry.Key, out _);
            }
        }
        await base.OnDisconnectedAsync(exception);
    }

    // 自定义私有消息发送方法
    public async Task SendPrivateMessage(string userName, string message)
    {
        if (_userConnectionMap.TryGetValue(userName, out var connectionIds))
        {
            // 向该用户的所有连接发送消息
            await Clients.Clients(connectionIds).SendAsync("ReceiveMessage", message);
        }
    }
}

2. 前端传递用户名

和方法1的前端代码一致，连接时通过查询字符串带上 username 参数即可。

三、生产环境注意事项 #

• 如果是服务器集群部署，方法2中的静态字典会存在节点间数据不一致的问题，建议改用分布式缓存（如 Redis）存储连接-用户映射。
• 若需要对用户名做验证，可在 OnConnectedAsync 中添加校验逻辑，避免无效或恶意用户名的关联。

内容的提问来源于stack exchange，提问作者Jonas Van der Reysen