作者 crossoverJie

:sparkles: Introducing new features.优化

@@ -41,6 +41,7 @@ public class CIMServerHandle extends SimpleChannelInboundHandler<CIMRequestProto @@ -41,6 +41,7 @@ public class CIMServerHandle extends SimpleChannelInboundHandler<CIMRequestProto
41 CIMUserInfo userInfo = SessionSocketHolder.getUserId((NioSocketChannel) ctx.channel()); 41 CIMUserInfo userInfo = SessionSocketHolder.getUserId((NioSocketChannel) ctx.channel());
42 LOGGER.info("用户[{}]下线",userInfo.getUserName()); 42 LOGGER.info("用户[{}]下线",userInfo.getUserName());
43 SessionSocketHolder.remove((NioSocketChannel) ctx.channel()); 43 SessionSocketHolder.remove((NioSocketChannel) ctx.channel());
  44 + SessionSocketHolder.removeSession(userInfo.getUserId());
44 45
45 //清除路由关系 46 //清除路由关系
46 clearRouteInfo(userInfo); 47 clearRouteInfo(userInfo);
@@ -21,6 +21,10 @@ public class SessionSocketHolder { @@ -21,6 +21,10 @@ public class SessionSocketHolder {
21 SESSION_MAP.put(userId, userName); 21 SESSION_MAP.put(userId, userName);
22 } 22 }
23 23
  24 + public static void removeSession(Long userId){
  25 + SESSION_MAP.remove(userId) ;
  26 + }
  27 +
24 public static void put(Long id, NioSocketChannel socketChannel) { 28 public static void put(Long id, NioSocketChannel socketChannel) {
25 CHANNEL_MAP.put(id, socketChannel); 29 CHANNEL_MAP.put(id, socketChannel);
26 } 30 }