SignalR C# MVC 将匿名用户映射到客户端 ID

Question

问题：如何管理匿名用户，以便在 Hub 发出响应时更新单个浏览器中的多个选项卡？

场景如下：

我想将 SignalR 集成到一个项目中，以便匿名用户可以与操作员进行实时聊天。显然，已通过 iIdentity 进行身份验证的用户是通过 Client.User(username) 命令映射的。但目前说一个匿名用户正在浏览 site.com/tools 和 site.com/notTools 我无法将消息发送到只有一个 connectionID 的所有选项卡。只有一个选项卡收集响应。

我曾尝试使用 IWC 补丁，但该工具不考虑将聊天信息保存到数据库中，而且我认为通过 ajax 传递变量不是读取/写入数据库的安全方法。

我还查看了以下内容：Managing SignalR connections for Anonymous user

但是，创建这样的基础并使用会话似乎不如 Owin 安全。

我的想法是使用 client.user()，方法是在用户每次连接时创建一个虚假帐户，并在他们断开连接时将其删除。但我宁愿不要用垃圾帐户填充我的 aspnetusers db 上下文，这似乎没有必要。

是否可以使用UserHandler.ConnectedIds.Add(Context.ConnectionId); 来映射假用户名？我不知所措。

使用 iUserId 提供者有意义吗？

public interface IUserIdProvider
{
    string GetUserId(IRequest request);
}

然后创建一个将 IP 地址存储到 connectionID 和单个用户名的数据库？

数据库：

用户：使用 FK 连接 ID

|userid|username|IP       |connectionIDs|
|   1  | user1  |127.0.0.1|  1          |
|   2  | user2  |127.0.0.2|  2          |

连接ID：

|connectionID|SignalRID|connectionIDs|
|      1     | xx.x.x.x|     1       |
|      2     | xx.xxx.x|     2       |
|      3     | xx.xxxxx|     2       |
|      4     | xxxxx.xx|     2       |

那么可能围绕连接编写逻辑？

public override Task OnConnected()
    {
     if(Context.Identity.UserName != null){
      //add a connection based on the currently logged in user. 
     }
    else{
     ///save new user to database?
     } 
  }

但问题仍然存在，当在 websocket 上发送命令时，我将如何处理多个选项卡？

更新 需要明确的是，我的意图是创建一个实时聊天/支持工具，该工具始终允许在浏览器中进行匿名访问。

客户想要类似于http://www.livechatinc.com的东西

我已经创建了一个从集线器发送和接收的 javascript 插件，无论它位于哪个域中。 （我的客户有多个站点）拼图的缺失部分是最简单的，管理匿名用户以允许多标签对话。

Answer 1

我没有遵循虚假用户帐户的想法（不知道它是否有效），但会开发一个替代方案。

该目标可以通过所有浏览器选项卡共享的 ChatSessionId cookie 并创建名为此 ChatSessionId 的组来实现。

我从 asp.net/signalr 学习了基本的聊天教程，并添加了允许从多个选项卡作为同一用户聊天的功能。

1) 在“聊天”操作中分配一个聊天会话 ID 以识别用户，因为我们没有用户凭据：

    public ActionResult Chat()
    {
        ChatSessionHelper.SetChatSessionCookie();
        return View();
    }

2) 进入聊天页面时订阅聊天会话

客户端

    $.connection.hub.start()
        .then(function(){chat.server.joinChatSession();})
        .done(function() {
           ...

服务器端（集线器）

public Task JoinChatSession()
{
    //get user SessionId to allow use multiple tabs
    var sessionId = ChatSessionHelper.GetChatSessionId();
    if (string.IsNullOrEmpty(sessionId)) throw new InvalidOperationException("No chat session id");

    return Groups.Add(Context.ConnectionId, sessionId);
}

3) 向用户的聊天会话广播消息

public void Send(string message)
{
    //get user chat session id
    var sessionId = ChatSessionHelper.GetChatSessionId();
    if (string.IsNullOrEmpty(sessionId)) throw new InvalidOperationException("No chat session id");

    //now message will appear in all tabs
    Clients.Group(sessionId).addNewMessageToPage(message);
}

最后是（简单的）ChatSessionHelper 类

public static class ChatSessionHelper
{
    public static void SetChatSessionCookie()
    {
        var context = HttpContext.Current;
        HttpCookie cookie = context.Request.Cookies.Get("Session") ?? new HttpCookie("Session", GenerateChatSessionId());

        context.Response.Cookies.Add(cookie);
    }

    public static string GetChatSessionId()
    {
        return HttpContext.Current.Request.Cookies.Get("Session")?.Value;
    }

    public static string GenerateChatSessionId()
    {
        return Guid.NewGuid().ToString();
    }
}

Answer 2

一种广泛采用的解决方案是让用户在 onConnected 上使用他的某种带有连接返回的 id 进行注册。

 public override Task OnConnected()
        {
            Clients.Caller.Register();


            return base.OnConnected();
        }

然后用户返回带有某种你自己的 id 逻辑的调用

来自客户的注册方法

 public void Register(Guid userId)
    {
        s_ConnectionCache.Add(userId, Guid.Parse(Context.ConnectionId));
    }

并且您将用户 ID 保存在静态字典中（注意锁，因为您需要它是线程安全的；

static readonly IConnectionCache s_ConnectionCache = new ConnectionsCache();

这里

 public class ConnectionsCache :IConnectionCache
{
    private readonly Dictionary<Guid, UserConnections> m_UserConnections = new Dictionary<Guid, UserConnections>();
    private readonly Dictionary<Guid,Guid>  m_ConnectionsToUsersMapping = new Dictionary<Guid, Guid>();
    readonly object m_UserLock = new object();
    readonly object m_ConnectionLock = new object();
    #region Public


    public UserConnections this[Guid index] 
        => 
        m_UserConnections.ContainsKey(index)
        ?m_UserConnections[index]:new UserConnections();

    public void Add(Guid userId, Guid connectionId)
    {
        lock (m_UserLock)
        {
            if (m_UserConnections.ContainsKey(userId))
            {
                if (!m_UserConnections[userId].Contains(connectionId))
                {

                    m_UserConnections[userId].Add(connectionId);

                }

            }
            else
            {
                m_UserConnections.Add(userId, new UserConnections() {connectionId});
            }
        }


            lock (m_ConnectionLock)
            {
                if (m_ConnectionsToUsersMapping.ContainsKey(connectionId))
                {
                    m_ConnectionsToUsersMapping[connectionId] = userId;
                }
                else
                {
                        m_ConnectionsToUsersMapping.Add(connectionId, userId);
                }
            }

    }

    public void Remove(Guid connectionId)
    {
        lock (m_ConnectionLock)
        {
            if (!m_ConnectionsToUsersMapping.ContainsKey(connectionId))
            {
                return;
            }
            var userId = m_ConnectionsToUsersMapping[connectionId];
            m_ConnectionsToUsersMapping.Remove(connectionId);
            m_UserConnections[userId].Remove(connectionId);
        }



    }

从 Android 应用程序注册的示例调用

 mChatHub.invoke("Register", PrefUtils.MY_USER_ID).get();

对于 JS 来说是一样的

 chat.client.register = function () {
    chat.server.register(SOME_USER_ID);
}