springboot项目Redis统计在线用户的实现示例
我的项目有个显示用户的遗忘曲线，需要统计在线用户以计算他们的曲线
思考了两种方案，但都是用Redis的bitmap数据结构
Bitmap是一种特殊类型的数组，其中每个元素只能存储0或1。在Redis中，Bitmap实际上是字符串，每个字符的每一位都被视为一个独立的位，因此一个字符串可以存储多达8*字符串长度的位。 这段代码中，markUserActive方法接收一个用户ID作为参数。然后，它创建一个键，该键由字符串"active_users:"和当前日期组成，格式为ISO_DATE。这样，每天都会有一个新的键，用于存储当天活跃的用户。 然后，它使用redisUtils.setBit方法将用户ID对应的位设置为1。这里，用户ID被用作位的索引。例如，如果用户ID为10，那么第10位将被设置为1。 这样，我们就可以通过检查特定位的值来确定用户是否活跃。如果位的值为1，那么用户就是活跃的；如果位的值为0，那么用户就是不活跃的。 这种方法的优点是，它可以在非常小的空间内存储大量的信息。此外，由于Redis是内存数据库，因此这种方法的速度非常快。
方案一
- 使用心跳包来追踪和统计用户活跃状态，客户端每隔30分钟或者一段时间给服务端发送一个心跳，服务端获取到用户id然后存储到Redis
- 但这样的话客户端要定时任务，且依赖客户端。
方案二
- 在用户每次请求操作的时候，由于我后端配置了Shiro的拦截器判断每次请求是否token过期，加入标记用户活跃的逻辑，并redis设置过期时间2小时
- 缺点是资源消耗大，每次请求都要标记
@Override
public void markUserActive(int userId) {
String key = "active_users:" + LocalDateTime.now().format(DateTimeFormatter.ISO_LOCAL_DATE_TIME);
redisUtils.setBit(key, userId, true);
// 设置2小时的过期时间
redisUtils.expire(key, 2, TimeUnit.HOURS);
}
markUserActive(int userId) 方法： 这个方法用于标记一个用户为活跃状态。它接收一个用户ID作为参数。方法首先构造一个键，键的格式是 “active_users:” 加上当前的日期和时间。然后，它在 Redis 数据库中将这个键对应的位（由用户ID指定）设置为 true，表示该用户是活跃的。最后，它设置这个键的过期时间为2小时。这意味着，如果2小时内没有再次标记该用户为活跃，那么这个键就会从 Redis 数据库中删除。
@Override
public List<Integer> getActiveUserIds() {
List<Integer> activeUserIds = new ArrayList<>();
// 当前时间
LocalDateTime currentTime = LocalDateTime.now();
for (int i = 0; i < 2; i++) {
// 遍历过去2小时内的键
String key = "active_users:" + currentTime.minusHours(i).format(DateTimeFormatter.ISO_LOCAL_DATE_TIME);
if (redisUtils.hasKey(key)) {
// 遍历1000个用户
for (int j = 0; j < 1000; j++) {
Boolean isUserActive = redisUtils.getBit(key, j);
if (isUserActive != null && isUserActive) {
activeUserIds.add(j);
}
}
}
}
return activeUserIds;
}
但是之后测试的时候发现在查找活跃用户的时候并没有找到，可能是时间戳精度问题，所以修改代码将其key保留到分钟形式
String key = "active_users:" + LocalDateTime.now().truncatedTo(ChronoUnit.MINUTES).format(DateTimeFormatter.ISO_LOCAL_DATE_TIME);
到此这篇关于springboot项目Redis统计在线用户的实现示例的文章就介绍到这了,更多相关springboot Redis统计在线用户内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
在本文中小编给大家整理了关于Java==和equals的区别以及相关知识点，有兴趣的朋友们学习下。2019-03-03
这篇文章主要介绍Java并发之同步器设计，本文以记录方式并发编程中同步器设计的一些共性特征。并简单介绍了Java中的AQS,需要的朋友可以参考一下文章的详细内容2021-10-10
这篇文章主要介绍了Spring Boot 直接用jar运行项目的方法，非常不错，具有参考借鉴价值，需要的朋友参考下2018-02-02
这篇文章主要给大家介绍了关于Java如何实现一个简易版的多级菜单功能的相关资料,文中通过实例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2022-01-01
有些时候我们需要在项目中展示PDF,所以我们可以将PDF转为图片,然后已图片的方式展示,效果很好,Java使用各种技术将pdf转换成图片格式,并且内容不失帧,本文给大家介绍了三种方法实现PDF转图片的案例,需要的朋友可以参考下2023-10-10
在SpringBoot生态中,starter是一种特殊的依赖,它能够自动装配相关组件,简化项目配置,本文将详细介绍6种不同的自定义starter开发方法,有需要的可以了解下2025-04-04
SpringBoot集成LiteFlow工作流引擎的完整指南
LiteFlow作为一款国产轻量级规则引擎/流程引擎,以其零学习成本、高可扩展性和极致性能成为微服务架构下的理想选择,本文将详细讲解SpringBoot集成LiteFlow的全过程,助大家轻松驾驭轻量级流程编排2025-06-06
spring-boot-starter-thymeleaf加载外部html文件方式
本文介绍了在SpringMVC中使用Thymeleaf模板引擎加载外部HTML文件的方法,以及在Spring Boot中使用Thymeleaf的基本步骤,包括引入依赖、创建Controller、创建HTML文件、参数化访问、热加载和热更新文件2025-02-02
intellij idea 启动tomcat 1099端口被占用的解决
这篇文章主要介绍了intellij idea 启动tomcat 1099端口被占用的解决，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2019-09-09
本文主要介绍了java8中@Contended注解的使用，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2023-07-07
最新评论