ASP.NET Core+Angular中SignalR一对一聊天：用户ID映射连接ID问题

问题根源 #

你遇到的Clients.User(message.To)无效果，核心原因通常是用户身份未被SignalR正确识别，或是客户端连接时未携带有效身份凭证，导致SignalR无法关联用户ID与连接ID。

解决方案步骤 #

1. 确保客户端连接时携带身份凭证 #

Angular端连接SignalR Hub时，必须传递用户的JWT令牌（或其他身份凭证），让服务器识别当前连接的用户：

import { HubConnectionBuilder } from '@microsoft/signalr';

// 获取本地存储的JWT令牌
const getAccessToken = () => localStorage.getItem('authToken');

const connection = new HubConnectionBuilder()
  .withUrl('/chatHub', {
    accessTokenFactory: getAccessToken
  })
  .build();

// 启动连接
connection.start().catch(err => console.error(err));

2. 配置服务器端SignalR的身份验证 #

确保ASP.NET Core项目中已正确启用身份验证，并允许SignalR Hub使用身份验证：

// Program.cs
var builder = WebApplication.CreateBuilder(args);

// 添加上下文和身份验证服务
builder.Services.AddDbContext<ApplicationDbContext>(options =>
    options.UseSqlServer(builder.Configuration.GetConnectionString("DefaultConnection")));
builder.Services.AddDefaultIdentity<IdentityUser>()
    .AddEntityFrameworkStores<ApplicationDbContext>();

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

var app = builder.Build();

// 启用身份验证和授权中间件
app.UseAuthentication();
app.UseAuthorization();

// 映射Hub并要求授权
app.MapHub<ChatHub>("/chatHub").RequireAuthorization();

app.Run();

3. 自定义用户-连接ID映射（替代默认Clients.User） #

默认的Clients.User依赖Identity的ClaimTypes.NameIdentifier，如果存在格式不匹配或自定义用户ID的场景，建议在Hub中手动维护用户与连接ID的映射表：

public class ChatHub : Hub
{
    // 单服务器场景用静态字典，集群场景请改用Redis/数据库等分布式存储
    private static readonly Dictionary<Guid, string> UserToConnectionMap = new();

    public override async Task OnConnectedAsync()
    {
        // 从当前连接的用户身份中获取ID
        var userId = Guid.Parse(Context.User.FindFirstValue(ClaimTypes.NameIdentifier));
        
        lock (UserToConnectionMap)
        {
            // 更新或添加用户的连接ID（同一用户多设备时会覆盖，如需支持多设备可改为存储连接ID列表）
            UserToConnectionMap[userId] = Context.ConnectionId;
        }
        
        await base.OnConnectedAsync();
    }

    public override async Task OnDisconnectedAsync(Exception exception)
    {
        var userId = Guid.Parse(Context.User.FindFirstValue(ClaimTypes.NameIdentifier));
        
        lock (UserToConnectionMap)
        {
            UserToConnectionMap.Remove(userId);
        }
        
        await base.OnDisconnectedAsync(exception);
    }
}

4. 在Controller中通过映射表发送一对一消息 #

在你的Controller中，通过HubContext获取用户对应的连接ID，直接发送消息：

[Route("send")]
[HttpPost]
public async Task<IActionResult> SendRequest([FromBody] Chat.Models.Message message)
{
    var userId = Guid.Parse(User.FindFirstValue(ClaimTypes.NameIdentifier));
    var user = await _userManager.FindByIdAsync(userId.ToString());
    var sender = new ChatSender { Id = userId, Name = user.FullName };

    // 从Hub的映射表中获取接收者的连接ID
    if (ChatHub.UserToConnectionMap.TryGetValue(message.To, out var recipientConnectionId))
    {
        // 发送消息给指定连接
        await _hubContext.Clients.Client(recipientConnectionId)
            .SendAsync("ReceiveMessage", sender, message.MessageText);
    }

    return Ok();
}

关键注意事项 #

• 用户ID格式一致性：确保message.To的Guid格式与ClaimTypes.NameIdentifier返回的字符串完全一致（比如是否带连字符、大小写）。
• 集群部署适配：如果是多服务器集群，静态字典无法跨服务器共享，需改用Redis、SQL Server等分布式存储来维护用户-连接映射。
• 客户端连接状态：发送消息前需确保接收者已成功连接到Hub，否则无法找到对应的连接ID。

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