深入Redis的Bitmap特性,落地系统签到功能
mhr18 2025-05-21 15:02 4 浏览 0 评论
一、签到功能的实现思路
最常规的思路:
1)一般我们会选择每个用户,每天的签到作为一条mysql表的数据,然后一条一条的记录。这种方式的确是可以的,但是它的局限性很大,只能适用于小规模公司的内部系统,人数不多的情况下。
2)如果是用于普通大众的话,这就将不堪设想。如果有一百万用户,每天签到,一个月,需要存的数据就会有三千万条数据,一年,需要存三亿六千万条数据。这要是用户量再大点,或者使用的时长再长点,这数据是不是就太多了,而且还只是意义不是很大的数据。
常规思路存在的问题:
1.用户数量多的时候,存在很大的IO性能消耗,对数据库造成压力
2.用户数量多的时候,存储的数据占用的空间太大
3.用户数量多,时间久的情况下,查询统计会性能下降
最近在深入学习redis,发现它里面的bitmap数据结构就能很好的用于签到功能的实现,而且签到数据占用的内存也很小,查询统计的性能也不错,很好的解决了常规思路存在的问题。
二、Bitmap介绍
bitmap也叫位图,可以理解成二进制的bit数组,数组每位只有两种数字:0或1。
redis中关于bitmap的常用命令有:
#向指定位置(offset)存入0或1
SETBIT key offset value
#获取指定位置(offset)的bit值
GETBIT key offset
#统计bitmap中(从start到end,如果不写起始位置,就统计整个key)值为1的bit数量
BITCOUNT key [start end]
#操作(查询,修改,自增)Bitmap中指定的位置(offset)的值
BITFIELD key [GET type offset] [SET type offset value] [INCRBY type offset increment] [OVERFLOW WRAP|SAT|FAIL]
#获取Bitmap中的bit数组,并以十进制返回
BITFIELD_RO
三、java代码实现签到功能
package org.bitmap.sign.function;
import org.springframework.dao.DataAccessException;
import org.springframework.data.redis.connection.BitFieldSubCommands;
import org.springframework.data.redis.connection.RedisConnection;
import org.springframework.data.redis.core.RedisCallback;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.time.Instant;
import java.time.LocalDateTime;
import java.time.ZoneId;
import java.time.format.DateTimeFormatter;
import java.util.Date;
import java.util.List;
@RestController
@RequestMapping("/sign")
public class SignController {
@Resource
private StringRedisTemplate stringRedisTemplate;
/**
* 当日签到
*
* @return
*/
@PostMapping("/do")
public String doSign() {
//用户Uid
String userId = "1234";
//获取当前日期
LocalDateTime now = LocalDateTime.now();
String keySuffix = now.format(DateTimeFormatter.ofPattern(":yyyyMM"));
// 组合成key= sign:userId:年月
String key = "sign:" + userId + keySuffix;
// 获取当前日期是当月的第多少天
int dayOfMonth = now.getDayOfMonth();
// 存到redis中的bitmap中,由于bitmap从0开始,第多少天从1开始,dayOfMonth需要减1
stringRedisTemplate.opsForValue().setBit(key, dayOfMonth - 1, true);
return "ok";
}
/**
* 指定日期补签
*
* @return
*/
@PostMapping("/doSign")
public String doSupplementarySignature(@RequestParam String signDate) {
String userId = "1234";
LocalDateTime dateOfSign = StringParseLocalDateTime(signDate);
String keySuffix = dateOfSign.format(DateTimeFormatter.ofPattern(":yyyyMM"));
String key = "sign:" + userId + keySuffix;
int dayOfMonth = dateOfSign.getDayOfMonth();
stringRedisTemplate.opsForValue().setBit(key, dayOfMonth - 1, true);
return "ok";
}
/**
* 统计指定月的用户总共签到次数
* date:年月日
* @return
*/
@GetMapping("/count")
public Integer getSignCount(@RequestParam String date) {
String userId = "1234";
LocalDateTime dateOfSign = StringParseLocalDateTime(date);
String keySuffix = dateOfSign.format(DateTimeFormatter.ofPattern(":yyyyMM"));
String key = "sign:" + userId + keySuffix;
Long count = stringRedisTemplate.execute(new RedisCallback<Long>() {
@Override
public Long doInRedis(RedisConnection redisConnection) throws DataAccessException {
return redisConnection.bitCount(key.getBytes());
}
});
assert count != null;
return count.intValue();
}
/**
* 统计当前日期往前的连续签到数(连续的)
*
* @return
*/
@GetMapping("/signCount")
public Integer signCount() {
//用户Uid
String userId = "1234";
//获取当前日期
LocalDateTime now = LocalDateTime.now();
String keySuffix = now.format(DateTimeFormatter.ofPattern(":yyyyMM"));
// 组合成key= sign:userId:年月
String key = "sign:" + userId + keySuffix;
// 获取当前日期是当月的第多少天
int dayOfMonth = now.getDayOfMonth();
// 获取本月截止今天为止的所有签到记录,返回的是一个十进制的数字
List<Long> result = stringRedisTemplate.opsForValue().bitField(key, BitFieldSubCommands.create()
.get(BitFieldSubCommands.BitFieldType.unsigned(dayOfMonth)).valueAt(0));
if (result == null || result.isEmpty()) {
return 0;
}
Long number = result.get(0);
int count = 0;
if (number == null || number == 0) {
return 0;
}
while (true) {
// 让这个数字与1做与运算,得到数字的最后一位bit,并判断这个bit是否为0
if ((number & 1) == 0) {
// 如果为0说明不是连续签到,直接终止
break;
} else {
// 如果不为0,那就为1,说明有签到,继续下次循环,并且计数器加一
count++;
}
// 把数字右移一位,抛弃最后一位的bit,继续下一个bit
number = number >>> 1; // 也可以写成 number >>>= 1
}
return count;
}
/**
* 字符串日期转换成LocalDateTime
*
* @param date
* @return
* @throws ParseException
*/
private LocalDateTime StringParseLocalDateTime(String date) {
try {
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyyMMdd");
Date parse = simpleDateFormat.parse(date);
Instant instant = parse.toInstant();
ZoneId zoneId = ZoneId.systemDefault();
return instant.atZone(zoneId).toLocalDateTime();
} catch (Exception e) {
e.printStackTrace();
throw new RuntimeException("日期格式转换报错");
}
}
}
四、思考
其实可以借鉴redis的这种bitmap思想;
数据库的实现方式:
我们可以设计一张mysql的签到表,
用户id,年份,一月,二月,三月,四月,五月,六月,七月,八月,九月,十月,十一月,十二月。
这些字段,月份字段里面存0和1组成的字符串,代表是否签到,字符串最长31位,
代表当月一共31天,也能落地签到功能
主要思考的问题:
1)少量用户数据是,两者并无太大差异
2)大量用户数据时,则需要考虑统计的问题,和系统查询的性能问题,以及数据量存储的问题等等
相关推荐
- Spring Boot3 连接 Redis 竟有这么多实用方式
-
各位互联网大厂的后端开发精英们,在日常开发中,想必大家都面临过系统性能优化的挑战。当系统数据量逐渐增大、并发请求不断增多时,如何提升系统的响应速度和稳定性,成为了我们必须攻克的难题。而Redis,这...
- 隧道 ssh -L 命令总结 和 windows端口转发配置
-
摘要:隧道ssh-L命令总结和windows端口转发配置关键词:隧道、ssh-L、端口转发、网络映射整体说明最近在项目中,因为内网的安全密级比较高,只能有一台机器连接内网数据库,推送...
- 火爆BOOS直聘的13个大厂Java社招面经(5年经验)助你狂拿offer
-
火爆BOOS直聘的13个大厂Java社招面经(5年经验)助你狂拿offer综上所述,面试遇到的所有问题,整理成了一份文档,希望大家能够喜欢!!Java面试题分享(Java中高级核心知识全面解析)一、J...
- 「第五期」游服务器一二三面 秋招 米哈游
-
一面下午2点,35分钟golang内存模型golang并发模型golanggc原理过程channel用途,原理redis数据结构,底层实现跳跃表查询插入复杂度进程,线程,协程kill原理除了kil...
- RMQ——支持合并和优先级的消息队列
-
业务背景在一个项目中需要实现一个功能,商品价格发生变化时将商品价格打印在商品主图上面,那么需要在价格发生变动的时候触发合成一张带价格的图片,每一次触发合图时计算价格都是获取当前最新的价格。上游价格变化...
- Redis 中的 zset 为什么要用跳跃表,而不是B+ Tree 呢?
-
Redis中的有序集合使用的是一种叫做跳跃表(SkipList)的数据结构来实现,而不是使用B+Tree。本文将介绍为什么Redis中使用跳跃表来实现有序集合,而不是B+Tree,并且探讨跳跃表...
- 一文让你彻底搞懂 WebSocket 的原理
-
作者:木木匠转发链接:https://juejin.im/post/5c693a4f51882561fb1db0ff一、概述上一篇文章《图文深入http三次握手核心问题【思维导图】》我们分析了简单的一...
- Redis与Java整合的最佳实践
-
Redis与Java整合的最佳实践在这个数字化时代,数据处理速度决定了企业的竞争力。Redis作为一款高性能的内存数据库,以其卓越的速度和丰富的数据结构,成为Java开发者的重要伙伴。本文将带你深入了...
- Docker与Redis:轻松部署和管理你的Redis实例
-
在高速发展的云计算时代,应用程序的部署和管理变得越来越复杂。面对各种操作系统、依赖库和环境差异,开发者常常陷入“在我机器上能跑”的泥潭。然而,容器化技术的兴起,尤其是Docker的普及,彻底改变了这一...
- Java开发中的缓存策略:让程序飞得更快
-
Java开发中的缓存策略:让程序飞得更快缓存是什么?首先,让我们来聊聊什么是缓存。简单来说,缓存是一种存储机制,它将数据保存在更快速的存储介质中,以便后续使用时能够更快地访问。比如,当你打开一个网页时...
- 国庆临近,字节后端开发3+4面,终于拿到秋招第一个offer
-
字节跳动,先面了data部门,3面技术面之后hr说需要实习转正,拒绝,之后另一个部门捞起,四面技术面,已oc分享面经,希望对大家有所帮助,秋招顺利在文末分享了我为金九银十准备的备战资源库,包含了源码笔...
- “快”就一个字!Redis凭什么能让你的APP快到飞起?
-
咱们今天就来聊一个字——“快”!在这个信息爆炸、耐心越来越稀缺的时代,谁不希望自己手机里的APP点一下“嗖”就打开,刷一下“唰”就更新?谁要是敢让咱用户盯着个小圈圈干等,那简直就是在“劝退”!而说到让...
- 双十一秒杀,为何总能抢到?Redis功不可没!
-
一年一度的双十一“剁手节”,那场面,简直比春运抢票还刺激!零点的钟声一敲响,亿万个手指头在屏幕上疯狂戳戳戳,眼睛瞪得像铜铃,就为了抢到那个心心念念的半价商品、限量版宝贝。你有没有发现一个奇怪的现象?明...
- 后端开发必看!为什么说Redis是天然的幂等性?
-
你在做后端开发的时候,有没有遇到过这样的困扰:高并发场景下,同一个操作重复执行多次,导致数据混乱、业务逻辑出错?别担心,很多同行都踩过这个坑。某电商平台就曾因订单创建接口在高并发时不具备幂等性,用户多...
- 开发一个app需要哪些技术和工具
-
APP开发需要一系列技术和工具的支持,以下是对这些技术的清晰归纳和分点表示:一、前端开发技术HTML用于构建页面结构。CSS用于样式设计和布局。JavaScript用于页面交互和逻辑处理。React...
你 发表评论:
欢迎- 一周热门
- 最近发表
- 标签列表
-
- oracle位图索引 (63)
- oracle批量插入数据 (62)
- oracle事务隔离级别 (53)
- oracle 空为0 (50)
- oracle主从同步 (55)
- oracle 乐观锁 (51)
- redis 命令 (78)
- php redis (88)
- redis 存储 (66)
- redis 锁 (69)
- 启动 redis (66)
- redis 时间 (56)
- redis 删除 (67)
- redis内存 (57)
- redis并发 (52)
- redis 主从 (69)
- redis 订阅 (51)
- redis 登录 (54)
- redis 面试 (58)
- 阿里 redis (59)
- redis 搭建 (53)
- redis的缓存 (55)
- lua redis (58)
- redis 连接池 (61)
- redis 限流 (51)