监听 session 判断用户是否在线

逃离我推掉我的手 2022-02-21 18:47 341阅读 0赞

### 文章目录 ###

*  场景描述
 *   *  session 容器
     *  添加 session
     *  移除 session
     *   *  注销时
         *  Session 失效时
 *  补充：
 *   *  监听 session 属性的变更
     *  session 独立
     *  其他session共享方案：

# 场景描述 #

spring boot 项目中为了简化消息模块，如果有新消息，先写入数据库，如果用户在线，设置接收消息用户的 session 中 newMessageFlag = true，前端每次轮询只需轮询 session 即可，无需每次访问数据库。  
这里需要根据用户ID 获取session，所以用户登录成功，调用 put 方法，退出登录 或者session 失效，调用 remove。

## session 容器 ##

存储已登录用户的 session

public class LoggedUserSessionContext{ 
    	//默认容量为 16 ，可以根据自己网站的访问量设置一个合理的初始值，避免刚开始时候的频繁扩容。
        private static Map<Integer, HttpSession> sessionMap  = new ConcurrentHashMap<>(128);
    
        public static HttpSession putIfAbsent(Integer userId, HttpSession session) { 
        	//先前已经在某个客户端登录了，则返回那个 session，以实现多端登录session共享
    	    return sessionMap.putIfAbsent(userId, session);        
        }
    
        public static void remove(Integer userId) { 
            sessionMap.remove(userId);
        }
     
        public static HttpSession getSession(Integer userId) { 
            return sessionMap.get(userId);
        }
    
    }

## 添加 session ##

用户登录成功后执行以下代码段

HttpSession session = LoggedUserSessionContext.getSession(user.getId());
                if(session != null){ 
                    //使用之前登陆过的 id
                    SpringUtil.setCookie("JSESSIONID", session.getId(), 60 * 30);
    			}else{ 
    				session = SpringUtil.getRequest().getSession();
    				session.setAttribute(SessionKey.USER, user);
    				LoggedUserSessionContext.putIfAbsent(user.getId(), session);
    			}

注册成功后执行以下代码段

HttpSession session = SpringUtil.getRequest().getSession();
    			session.setAttribute(SessionKey.USER, user);
    			LoggedUserSessionContext.putIfAbsent(user.getId(), session);

## 移除 session ##

### 注销时 ###

User user = (User)session.getAttribute(SessionKey.USER);
    LoggedUserSessionContext.remove(user.getId());
    session.invalidate();

### Session 失效时 ###

使用 监听器 监听 Session 的实现，实现 HttpSessionListener 接口即可

import javax.servlet.annotation.WebListener;
    import javax.servlet.http.HttpSession;
    import javax.servlet.http.HttpSessionEvent;
    import javax.servlet.http.HttpSessionListener;
    
    @WebListener
    public class SessionListener implements HttpSessionListener { 
    
        //注意：HttpServletRequest的getSession()方法，如果当前请求没有对应的session会自动创建session。
        //使用getSession(false)就不会创建session，如果没有当前请求对应的session就返回null.
    
       
        //新 session 创建 如未知用户浏览
        @Override
        public void sessionCreated(HttpSessionEvent event) { 
    
        }
    
        //session 销毁 用户下线，退出登录
        @Override
        public void sessionDestroyed(HttpSessionEvent event) throws ClassCastException { 
            HttpSession session = event.getSession();
            Object userObj = session.getAttribute(SessionKey.USER);
            if(userObj != null){ 
            	User user = (User)userObj;
            	LoggedUserSessionContext.remove(user.getId());
            }
            
        }
    
    }

# 补充： #

## 监听 session 属性的变更 ##

--------------------

带 HttpSessionAttributeListener \*\* 不推荐监听 HttpSessionAttributeListener \*\* 因为太过频繁

import java.util.HashSet;
    
    import javax.servlet.ServletContext;
    import javax.servlet.annotation.WebListener;
    import javax.servlet.http.HttpSession;
    import javax.servlet.http.HttpSessionAttributeListener;
    import javax.servlet.http.HttpSessionBindingEvent;
    import javax.servlet.http.HttpSessionEvent;
    import javax.servlet.http.HttpSessionListener;
    
    @WebListener
    public class SessionListener implements HttpSessionListener, HttpSessionAttributeListener { 
    
        //注意：HttpServletRequest的getSession()方法，如果当前请求没有对应的session会自动创建session。
        //使用getSession(false)就不会创建session，如果没有当前请求对应的session就返回null.
    
        //添加属性 用户登录 
        @Override
        public void attributeAdded(HttpSessionBindingEvent httpSessionBindingEvent) { 
            HttpSession session = httpSessionBindingEvent.getSession();
        }
    
        //删除属性 用户注销
        @Override
        public void attributeRemoved(HttpSessionBindingEvent httpSessionBindingEvent) { 
            logger.info("--attributeRemoved--");
        }
    
        //属性替换 信息更改
        @Override
        public void attributeReplaced(HttpSessionBindingEvent httpSessionBindingEvent) { 
            
        }
    
        //新 session 创建 如未知用户浏览
        @Override
        public void sessionCreated(HttpSessionEvent event) { 
            HttpSession session = event.getSession();
            MySessionContext.AddSession(event.getSession());
        }
    
        //session 销毁 用户下线，退出登录
        @Override
        public void sessionDestroyed(HttpSessionEvent event) throws ClassCastException { 
            HttpSession session = event.getSession();
            MySessionContext.DelSession(session);
        }
    
    }

## session 独立 ##

session 不共享，而是用代码逻辑设置伪共享，将存储 session的容器，数据结构改变一下即可

private static Map<Integer, List<HttpSession>> sessionMap  = new ConcurrentHashMap<>(128);

这样每个终端就可以互不影响的使用session。

## 其他session共享方案： ##

[https://blog.csdn.net/HBL6016/article/details/80398515][https_blog.csdn.net_HBL6016_article_details_80398515]  
[https://blog.csdn.net/hua\_yan\_ling/article/details/83856879][https_blog.csdn.net_hua_yan_ling_article_details_83856879]

[https_blog.csdn.net_HBL6016_article_details_80398515]: https://blog.csdn.net/HBL6016/article/details/80398515
[https_blog.csdn.net_hua_yan_ling_article_details_83856879]: https://blog.csdn.net/hua_yan_ling/article/details/83856879