Java在线人数统计核心是准确识别用户上下线与活跃状态,单机可用HttpSession监听,Web端推荐心跳机制,分布式必须用Redis共享存储并配合过期策略。
Java系统中实现在线人数统计和用户在线状态管理,核心在于准确识别“谁在什么时候上线、是否还活跃、何时下线”。不依赖第三方中间件也能做,但要注意会话生命周期、异常掉线、分布式场景等关键问题。
利用Servlet容器(如Tomcat)的HttpSession监听机制,是最轻量的入门方案。用户登录成功后创建session,通过监听器感知上下线。
HttpSessionListener接口,在sessionCreated()中将用户ID或session ID加入全局计数器(如ConcurrentHashMap)sessionDestroyed()中移除对应记录,并减计数maxInactiveInterval(默认30分钟)和定时清理逻辑static AtomicInteger onlineCount = new AtomicInteger(0)做总数,用ConcurrentMap存明细(key为sessionId,value为用户信息)前端每隔15–30秒发一次心跳请求(如/api/heartbeat),后端更新该用户的最后活跃时间。这是判断“当前是否在线”最可靠的方式。
ConcurrentMap),key为用户ID,value为最后一次心跳时间戳/api/online-count接口,遍历map,过滤掉“最后心跳超时(如>60秒)”的用户,返回剩余数量beforeunload)或登出时主动调用/api/logout清除状态,提升及时性单机内存方案在集群下失效。必须引入共享存储,常见选择是Redis。
SETEX user:1001:online "1" 120(120秒过期,代表心跳周期)EXPIRE user:1001:online 120
KEYS user:*:online效率低,改用SCAN或更优方式——给所有在线key打上同一前缀,用PFADD online_hll {userId} + PFCOUNT online_hll做基数估算(适合海量用户)SADD online_users 1001 + EXPIRE online_users 120不行(Set本身不支持整体过期),应为每个用户单独设key,再用SCAN匹配+校验TTL真实业务中,几个容易忽略但影响准确性的点:
userId_deviceId作为唯一key基本上就这些。从单机监听到分布式心跳,本质都是围绕“活跃性定义”和“状态存储一致性”展开。选型看规模:小系统用session监听+定时清理够用;中大型务必上Redis,配合心跳+过期策略,再加一层缓存降级(比如本地Caffeine兜底最近1分钟数据),就比
较稳了。