如何在SignalR的IHubContext及类库中获取当前已认证用户？

1. 如何在SignalR的IHubContext中获取当前用户？ #

首先得明确一个核心点：IHubContext本身并不直接绑定单个用户或连接——它的作用是让你在Hub类外部（比如后台服务、类库）向Hub客户端发送消息，并非处理单个请求的上下文载体。

分两种场景来看解决方案：

• 如果是在Hub类的方法内部，你完全不需要依赖IHubContext，直接用Hub自带的Context.User就能拿到当前连接的认证用户，因为Hub的Context是和当前活跃连接绑定的。
• 如果是在Hub外部使用IHubContext，这时候要获取用户信息，得先拿到用户的唯一标识（比如从Claim中提取的用户ID）或对应的连接ID。由于一个用户可能同时在多个设备上连接，通常需要维护一份「用户ID ↔ 连接ID列表」的映射，这份映射可以在Hub的连接生命周期方法里维护。

2. 在类库中拿到IHubContext后，如何访问已认证用户的User属性？ #

直接说结论：IHubContext本身没有User属性，因为它不是为单个请求/连接设计的。你需要根据使用场景换个思路实现：

场景1：在有HttpContext的环境下（比如Controller、中间件） #

如果你的类库服务是在处理前端请求的上下文里被调用的，直接从当前HttpContext中获取认证用户，再结合IHubContext给这个用户发消息即可：

using System.Security.Claims;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.SignalR;

public class MyLibraryService
{
    private readonly IHubContext<MyAwesomeHub> _hubContext;

    public MyLibraryService(IHubContext<MyAwesomeHub> hubContext)
    {
        _hubContext = hubContext;
    }

    // 调用时传入当前请求的HttpContext
    public async Task NotifyCurrentUser(HttpContext httpContext, string notification)
    {
        // 从HttpContext获取当前用户的唯一标识
        var userId = httpContext.User.FindFirstValue(ClaimTypes.NameIdentifier);
        // 直接通过用户ID给该用户的所有连接发消息
        await _hubContext.Clients.User(userId).SendAsync("ReceiveNotification", notification);
    }
}

场景2：在无HttpContext的环境下（比如后台任务） #

如果是后台服务这类没有请求上下文的场景，需要先在Hub中维护用户与连接的映射关系：

首先在Hub类中添加映射逻辑：

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

public class MyAwesomeHub : Hub
{
    // 用线程安全的字典存储用户ID和对应的连接ID列表
    private static readonly ConcurrentDictionary<string, List<string>> _userConnections = new ConcurrentDictionary<string, List<string>>();

    public override async Task OnConnectedAsync()
    {
        var userId = Context.UserIdentifier; // 该值来自认证系统的Claim
        if (userId != null)
        {
            // 将当前连接ID添加到用户的连接列表中
            _userConnections.AddOrUpdate(
                userId,
                _ => new List<string> { Context.ConnectionId },
                (_, existing) => { existing.Add(Context.ConnectionId); return existing; }
            );
        }
        await base.OnConnectedAsync();
    }

    public override async Task OnDisconnectedAsync(Exception? exception)
    {
        var userId = Context.UserIdentifier;
        if (userId != null && _userConnections.TryGetValue(userId, out var connections))
        {
            connections.Remove(Context.ConnectionId);
            // 如果用户没有活跃连接了，移除该用户的记录
            if (connections.Count == 0)
            {
                _userConnections.TryRemove(userId, out _);
            }
        }
        await base.OnDisconnectedAsync(exception);
    }

    // 提供静态方法让类库访问连接映射（也可以用依赖注入的方式存储映射）
    public static bool TryGetUserConnections(string userId, out List<string> connectionIds)
    {
        return _userConnections.TryGetValue(userId, out connectionIds);
    }
}

然后在类库中使用这个映射给指定用户发消息：

using Microsoft.AspNetCore.SignalR;

public class MyBackgroundService
{
    private readonly IHubContext<MyAwesomeHub> _hubContext;

    public MyBackgroundService(IHubContext<MyAwesomeHub> hubContext)
    {
        _hubContext = hubContext;
    }

    public async Task SendTaskUpdateToUser(string userId, string updateMessage)
    {
        if (MyAwesomeHub.TryGetUserConnections(userId, out var connectionIds))
        {
            foreach (var connectionId in connectionIds)
            {
                await _hubContext.Clients.Client(connectionId).SendAsync("ReceiveTaskUpdate", updateMessage);
            }
        }
    }
}

额外配置提醒 #

要确保SignalR已正确配置认证，比如在ASP.NET Core的Program.cs中：

var builder = WebApplication.CreateBuilder(args);

// 添加认证服务（示例为JWT认证）
builder.Services.AddAuthentication("Bearer")
    .AddJwtBearer(options =>
    {
        // 配置JWT验证参数：Issuer、Audience、SecretKey等
        options.TokenValidationParameters = new()
        {
            ValidateIssuer = true,
            ValidateAudience = true,
            ValidateLifetime = true,
            ValidateIssuerSigningKey = true,
            ValidIssuer = builder.Configuration["Jwt:Issuer"],
            ValidAudience = builder.Configuration["Jwt:Audience"],
            IssuerSigningKey = new SymmetricSecurityKey(Encoding.UTF8.GetBytes(builder.Configuration["Jwt:SecretKey"]))
        };
    });

// 添加SignalR服务
builder.Services.AddSignalR();

var app = builder.Build();

// 中间件顺序不可颠倒：先认证，再授权，最后映射Hub
app.UseAuthentication();
app.UseAuthorization();

app.MapHub<MyAwesomeHub>("/my-awesome-hub");

app.Run();

内容的提问来源于stack exchange，提问作者Cristian E.