首页 > 代码库 > ASP.NET SignalR 与 LayIM2.0 配合轻松实现Web聊天室(八) 之 用 Redis 实现用户在线离线状态消息处理

ASP.NET SignalR 与 LayIM2.0 配合轻松实现Web聊天室(八) 之 用 Redis 实现用户在线离线状态消息处理

前言

  上篇的预告好像是“聊天室的小细节,你都注意到了吗?”。今天也是为那篇做铺垫吧。之前的版本有好多问题,比如:当前登录用户是否合法问题,userid参数如果随便传后台没有验证。还有一个致命的问题,用户AB都在线,但是如果A没有打开B的窗口或者B没有打开A的窗口,那么发消息,对方是收不到的。因为他们没有进入到同一个组里面。本篇讲述了一些Redis的东西。由于项目本身就是为了学习和练习一些东西。所以,Redis并不是我的强项,只不过随便研究研究,具体专业的用法我也不太会。还在学习中。。。

实现思路

  首先,我采用了Redis中的哈希表结构来存储用户的在线信息。如下图所示:key代表userid,value是用户的connectionid

  技术分享

  是不是很简单,那么存储这些数据有什么好处呢,

  1.我们可以统计多少在线用户

  2.配合前端界面,实现某个好友是否在线

  3.判断好友是否在线在决定是否像该好友推送消息(不在线的话,直接存储离线消息就可以)

  4.解决前言中存在的问题。对于这个问题详细解释一下,比如A给B发消息,A点击打开了B的窗口,现在A已经加入到组AB中。但是B不在组AB中,所以,B收不到本组的消息。假如A打开B窗口的时候,判断一下A是否在线,如果A在线,那么将A加入到AB组中,也就是多了一步 A=》Group的操作。这样的话,就解决了AB不同组导致收不到消息的问题。详细看下图:

  技术分享

实现细节

  我们只要在Hub代码中的建立连接,失去连接,重新连接的方法中添加对当前用户的操作逻辑就可以。

  /// <summary>        /// 获取当前用户信息        /// </summary>        private OnlineUser CurrentOnlineUser        {            get            {                return new OnlineUser                {                    connectionid = CurrentConnectId,                    userid = CurrentUserId                };            }        }        /// <summary>        /// 建立连接        /// </summary>        /// <returns></returns>        public override Task OnConnected()        {            //将当前用户添加到redis在线用户缓存中            LayIMCache.Instance.OperateOnlineUser(CurrentOnlineUser);            return Clients.Caller.receiveMessage("连接成功");        }        /// <summary>        /// 失去连接        /// </summary>        /// <param name="stopCalled"></param>        /// <returns></returns>        public override Task OnDisconnected(bool stopCalled)        {            //将当前用户从在线用户列表中剔除            LayIMCache.Instance.OperateOnlineUser(CurrentOnlineUser, isDelete: true);            return Clients.Caller.receiveMessage("失去连接");        }        /// <summary>        /// 重新连接        /// </summary>        /// <returns></returns>        public override Task OnReconnected()        {            //将当前用户添加到redis在线用户缓存中            LayIMCache.Instance.OperateOnlineUser(CurrentOnlineUser);            return Clients.Caller.receiveMessage("重新连接");        }

  这里我用的.NET客户端是 StackExchange.Redis.Extensions.Core  ,他其实是在 StackExchange.Redis 的基础上有一层封装。用起来更方便一些,喜欢直接用  StackExchange.Redis 的也没问题。

  详细代码如下:

              static NewtonsoftSerializer serializer = new NewtonsoftSerializer();        StackExchangeRedisCacheClient cacheClient = new StackExchangeRedisCacheClient(serializer);        #region 在线用户处理        public void OperateOnlineUser(OnlineUser user, bool isDelete = false)        {            if (isDelete)            {                cacheClient.HashDelete(LayIMConst.LayIM_All_OnlineUsers, user.userid);            }            else            {                cacheClient.HashSetAsync(LayIMConst.LayIM_All_OnlineUsers, user.userid, user.connectionid);            }        }        #endregion

  当我们刷新页面的时候,会先调用 OnDisconnected 方法,在调用 OnConnected 方法。不过,HashSet方法如果是同一个key,可以覆盖其值。

  本篇就到这里了,界面上没有改动,只不过增加了一些基于redis缓存的逻辑。

  GitHub:https://github.com/fanpan26/LayIM_NetClient  喜欢的话给一个star吧,谢谢啦。

  交流群:145322742 (PS:技术水平有限,高手轻喷)

ASP.NET SignalR 与 LayIM2.0 配合轻松实现Web聊天室(八) 之 用 Redis 实现用户在线离线状态消息处理