SignalR(v2.2.0) OnDisconnected 设置用户离线

我使用以下代码在组中添加用户，并使用以下代码将用户保存在该特定组的数据库中。

SERVER:

  public class ChatHub : Hub
{


    public async Task JoinRoom(string user_Id, string room_Id, string user_Name)
    {
        AddLoginUser(room_Id, this.Context.ConnectionId, user_Id);
        await this.Groups.Add(this.Context.ConnectionId, room_Id);
    }


    public void Connect(string user_Id, string room_Id, string user_Name)
    {
        var id = Context.ConnectionId;

        Clients.Caller.onConnected(id, user_Name, GetRoomUser(room_Id), GetRoomMessage(room_Id));

        // send to all in group to update user list
        Clients.OthersInGroup(room_Id).onNewUserConnected(id, user_Name);
    }
  public override System.Threading.Tasks.Task OnDisconnected(bool stopCalled)
    {

        using (DataContext dc = new DataContext())
        {
            var item = dc.LoggedInUsers.FirstOrDefault(x => x.ConnectionId == Context.ConnectionId);
            if (item != null)
            {
                item.Connected = false;
                dc.SubmitChanges();

                Clients.OthersInGroup(item.RoomID.ToString()).onUserDisconnected(Context.ConnectionId, item.UserMaster.User_Name);
            }

            return base.OnDisconnected(stopCalled);
        }
    }
   }

 private void AddLoginUser(string room_Id, string connection_Id, string user_Id)
    {
        using (DataContext dc = new DataContext())
        {
            var checkUserLogedIn = (from user in dc.LoggedInUsers
                                    where (user.RoomID == Convert.ToInt32(room_Id) && user.UserID == Convert.ToInt32(user_Id))
                                    select user).SingleOrDefault();
            if (checkUserLogedIn == null)
            {
                LoggedInUser objLoggedInUser = new LoggedInUser();
                objLoggedInUser.ConnectionId = connection_Id;
                objLoggedInUser.UserID = Convert.ToInt32(user_Id);
                objLoggedInUser.RoomID = Convert.ToInt32(room_Id);
                objLoggedInUser.Connected = true;
                dc.LoggedInUsers.InsertOnSubmit(objLoggedInUser);
                dc.SubmitChanges();
            }
            else
            {
                if (!checkUserLogedIn.Connected)
                {
                    checkUserLogedIn.Connected = true;
                    dc.SubmitChanges();
                }
            }
        }
    }

Problem:

假设我使用 userid=1 登录，roomid=1 且 contextid=123asd。如果我刷新窗口，则 contextid 将更改，现在如果我关闭浏览器选项卡，然后执行以下查询：

var item = dc.LoggedInUsers.FirstOrDefault(x => x.ConnectionId == Context.ConnectionId);

没有根据最新的connectionid找出用户，因为当我在连接上保存用户时，connectionid是不同的。

我如何在断开连接事件时将特定用户的连接状态设置为 false。

提前致谢。

OnConnected您应该保存所有connectionId（与用户映射），connectionId应该是唯一的，而不是用户。因为一名用户可以同时与信号器建立多个连接（新选项卡）。

每次你应该映射用户和connectionIdOnconnected。每次你应该只删除该connectionId，而不是用户的所有connectionIdOnDisconnected。如果用户不在列表中，则应添加用户的connectionId（如果调用的停止未称为断开连接，即使用户未断开连接也会发生）OnReconnected.

您应该在此基础上重构您的代码。首先，您应该删除connectionId。然后，您可以检查；如果列表中没有该用户（与该连接 ID 映射）的记录，则可以发送消息。

Check here

我对你的代码做了一些修改，你可以根据这些知识改进这个代码。你应该打电话AddLoginUser on OnReconnected also.

     public override System.Threading.Tasks.Task OnDisconnected(bool stopCalled)
                {
                    using (DataContext dc = new DataContext())
                    {
                        var item = dc.LoggedInUsers.FirstOrDefault(x => x.ConnectionId == Context.ConnectionId);
                        if (item != null)
                        {
                            dc.LoggedInUsers.Remove(item);
                            dc.SubmitChanges();
//If there is no other connection left with this user in this room send message.
                               if (!dc.LoggedInUsers.Any(x => x.RoomID==item.RoomID && x.userId==item.UserId)
                                   Clients.OthersInGrouproomId.ToString()).onUserDisconnected(Context.ConnectionId, item.UserMaster.User_Name);
                           }
                        return base.OnDisconnected(stopCalled);
                    }
                }
            }

            private void AddLoginUser(string room_Id, string connection_Id, string user_Id)
            {
                using (DataContext dc = new DataContext())
                {
//Just check connectionId uniqunes. You don't need connected field.
                    var checkUserLogedIn = (from user in dc.LoggedInUsers
                                            where user.ConnectionId == connection_Id
                                            select user).SingleOrDefault();
                    if (checkUserLogedIn == null)
                    {
                        LoggedInUser objLoggedInUser = new LoggedInUser();
                        objLoggedInUser.ConnectionId = connection_Id;
                        objLoggedInUser.UserID = Convert.ToInt32(user_Id);
                        objLoggedInUser.RoomID = Convert.ToInt32(room_Id);
                        dc.LoggedInUsers.InsertOnSubmit(objLoggedInUser);
                        dc.SubmitChanges();
                    }
                }
            }