已知UserId如何获取ConnectionId？或如何将用户加入Azure SignalR组？

方法一：通过用户连接查询批量加入组 #

在Microsoft.Azure.SignalR.Management库中，可通过IUserManager获取指定用户的所有连接ID，再逐个将连接加入目标组：

private readonly IUserManager _userManager;
private readonly IHubContext _messageHubContext;

public YourController(IUserManager userManager, IHubContext messageHubContext)
{
    _userManager = userManager;
    _messageHubContext = messageHubContext;
}

public async Task<ActionResult> AddToGroup([FromBody]GroupAddRequest request)
{
    // 获取用户的所有连接ID
    var connectionIds = await _userManager.GetConnectionsAsync(request.UserId, CancellationToken.None);
    
    // 遍历连接ID，加入组
    foreach (var connectionId in connectionIds)
    {
        await _messageHubContext.Groups.AddToGroupAsync(connectionId, request.GroupId);
    }
    
    await _messageHubContext.Clients.User(request.UserId).SendAsync("group", request.GroupId);
    return new JsonResult("Done");
}

方法二：客户端主动上报连接ID加入组（推荐） #

无服务器模式下更推荐让客户端在连接成功后，主动携带自身connectionId调用API完成组加入，避免后端频繁查询连接状态：

客户端示例（JavaScript） #

const connection = new signalR.HubConnectionBuilder()
    .withUrl('your-signalr-endpoint')
    .build();

connection.start().then(() => {
    const connectionId = connection.connectionId;
    // 调用后端API提交加入组请求
    fetch('/api/addToGroup', {
        method: 'POST',
        headers: { 'Content-Type': 'application/json' },
        body: JSON.stringify({
            UserId: '当前用户ID',
            GroupId: '目标组ID',
            ConnectionId: connectionId
        })
    });
});

后端修改接口 #

public async Task<ActionResult> AddToGroup([FromBody]GroupAddRequest request)
{
    await _messageHubContext.Groups.AddToGroupAsync(request.ConnectionId, request.GroupId);
    await _messageHubContext.Clients.User(request.UserId).SendAsync("group", request.GroupId);
    return new JsonResult("Done");
}

// 更新请求模型
public class GroupAddRequest
{
    public string UserId { get; set; }
    public string GroupId { get; set; }
    public string ConnectionId { get; set; }
}

关键说明 #

• 同一用户可能存在多设备连接，方法一需遍历所有连接ID才能确保用户所有会话都能接收组消息。
• 方法二更贴合无服务器架构的轻量化设计，减少后端状态依赖，性能更优。

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