时间戳

首页 > 解决方案 > 检查组是否包含任何客户端

asp.net-core - 检查组是否包含任何客户端

问题描述

语境

我有以下工作流程让服务器从连接的客户端查询数据：

// Server-side code
async Task<string> RequestDataFromClient(string groupName)
{
    var responseId = GenerateUniqueId();

    // let the clients know that we want something
    await hubContext.Clients.Group(groupName).Request(responseId);

    try
    {
        return await WaitForIncomingCall(responseId);
    }
    catch(TimeoutException)
    {
        return GetDataFromFallbackMethod();
    }
}

服务器首先向Request给定 SignalR 组中的所有客户端发送一个。然后它等待任何客户端使用给定的using调用Respondhub 方法。有以下签名responseIdWaitForIncomingCallWaitForIncomingCall

Task<string> WaitForIncomingCall(responseId)

Respond如果一段时间后没有客户端调用hub 方法，则WaitForIncomingCall抛出TimeoutException. 如果发生这样的异常，服务器将使用回退方法来检索数据（例如，从缓存中）。

问题

如果给定的 SignalR 组中不存在客户端，则服务器将等待直到超时，直到它启动回退方法。这将对 的调用者产生很大的延迟RequestDataFromClient。如果 SignalR 组中没有客户端，我宁愿直接调用回退方法。因此，如果没有人有可能做出回应，那就别问了。

问题

如何确定 SignalR 组是否为空，或者Request呼叫是否可能已到达连接的客户端？一旦负载平衡开始发挥作用，手动跟踪连接似乎不是一个好主意。

标签： asp.net-coresignalr

解决方案

据我所知，目前 Asp.net core SignalR 没有内置方法来检查组是否为空或组中是否存在任何客户端。而从官方文档中，我们也可以发现：

当连接重新连接时，不会保留组成员身份。重新建立连接时需要重新加入组。无法计算组的成员数，因为如果应用程序扩展到多台服务器，则无法获得此信息。

要检查组是否包含任何连接的客户端，作为一种解决方法，在 hub 方法中，您可以定义一个全局变量来存储组名和在线计数，或者您可以存储用户信息（用户名、组名、在线状态等）在数据库中。

然后，在 OnConnectedAsync 方法中，您可以将用户添加到组并计算在线数或更改用户的在线状态，在 OnDisconnectedAsync 方法中，将用户从组中删除并更改在线用户数。创建自定义方法来检查/获取在线用户数。

像这样的代码（在这个示例代码中，我使用登录用户名来创建组，您可以根据您的场景进行更改）：

[Authorize]
public class ChatHub : Hub
{
    private static Dictionary<string, int> onlineClientCounts = new Dictionary<string, int>();

    public override Task OnConnectedAsync()
    { 
        var IdentityName = Context.User.Identity.Name;
        Groups.AddToGroupAsync(Context.ConnectionId, IdentityName);

        int count = 0;
        if (onlineClientCounts.TryGetValue(IdentityName, out count))
            onlineClientCounts[IdentityName] = count + 1;//increment client number
        else
            onlineClientCounts.Add(IdentityName, 1);// add group and set its client number to 1


        return base.OnConnectedAsync();
    }
    public async Task SendMessage(string user, string message)
    { 
        
        await Clients.All.SendAsync("ReceiveMessage", user, message);
    }

    public async Task SendMessageToGroup(string sender, string groupname, string message)
    { 
        //check if group contains clients or not via the global variable or check database.

        await Clients.Group(groupname).SendAsync("ReceiveMessage", sender, message);
    }

    public override async Task OnDisconnectedAsync(Exception exception)
    {
        var IdentityName = Context.User.Identity.Name;
        await Groups.RemoveFromGroupAsync(Context.ConnectionId, IdentityName);

        int count = 0;
        if (onlineClientCounts.TryGetValue(IdentityName, out count))
        {
            if (count == 1)//if group contains only 1client
                onlineClientCounts.Remove(IdentityName);
            else
                onlineClientCounts[IdentityName] = count - 1;
        } 

        await base.OnDisconnectedAsync(exception);
    }
}

推荐阅读