Redis缓存工具封装实现
来源：脚本之家
时间：2023-02-25 10:13:47 111浏览 收藏
本篇文章给大家分享《Redis缓存工具封装实现》，覆盖了数据库的常见基础知识，其实一个语言的全部知识点一篇文章是不可能说完的，但希望通过这些问题，让读者对自己的掌握程度有一定的认识(B 数)，从而弥补自己的不足，更好的掌握它。
将 StringRedisTemplate 封装成一个缓存工具类，方便以后重复使用。
1. 方法要求
在这个工具类中我们完成四个方法：
- 方法①：将任意Java对象序列化为json并存储在string类型的key中，并且可以设置TTL过期时间
- 方法②：将任意Java对象序列化为json并存储在string类型的key中，并且可以设置逻辑过期时间，用于处理缓存击穿问题
- 方法③：根据指定的key查询缓存，并反序列化为指定类型，利用缓存空值的方式解决缓存穿透问题
- 方法④：根据指定的key查询缓存，并反序列化为指定类型，需要利用逻辑过期解决缓存击穿问题
我们新建一个类，先把大致框架写出来，方法的参数可以边写边完善，但是我的方法参数已经完善好了：
@Component
public class CacheClient {
private final StringRedisTemplate stringRedisTemplate;
public CacheClient(StringRedisTemplate stringRedisTemplate) {
this.stringRedisTemplate = stringRedisTemplate;
}
//方法一
public void set(String key, Object value, Long time, TimeUnit unit) {
}
//方法二
public void setWithLogicExpire(String key, Object value, Long time, TimeUnit unit) {
}
//方法三
public R queryWithPassThrough(String keyPrefix, ID id, Class type,
Long time, TimeUnit unit, Function dbFallback) {
}
//方法四
public R queryWithLogicalExpire(String prefix, ID id, String lockPre, Class type,
Long time, TimeUnit unit, Function dbFallback) {
}
//线程池
private static final ExecutorService CACHE_REBUILD_EXECUTOR = Executors.newFixedThreadPool(10);
//获取锁
private boolean tryLock(String key) {
Boolean flag = stringRedisTemplate.opsForValue().setIfAbsent(key, "1", LOCK_SHOP_TTL, TimeUnit.SECONDS);
return BooleanUtil.isTrue(flag);
}
//释放锁
private void unLock(String key) {
stringRedisTemplate.delete(key);
}
}
接下来我们可以不断完善这些方法。
1.1 方法一
public void set(String key, Object value, Long time, TimeUnit unit) {
stringRedisTemplate.opsForValue().set(key, JSONUtil.toJsonStr(value), time, unit);
}
1.2 方法二
public void setWithLogicExpire(String key, Object value, Long time, TimeUnit unit) {
RedisData redisData = new RedisData();
redisData.setData(value);
redisData.setExpireTime(LocalDateTime.now().plusSeconds(unit.toSeconds(time)));
stringRedisTemplate.opsForValue().set(key, JSONUtil.toJsonStr(redisData));
}
1.3 方法三
publicR queryWithPassThrough(String keyPrefix, ID id, Class type, Long time, TimeUnit unit, Function dbFallback) { String key = keyPrefix + id; //1.从redis中查询商铺缓存 String json = stringRedisTemplate.opsForValue().get(key); //2.判断是否存在 if (StrUtil.isNotBlank(json)) { //2.1.存在 return JSONUtil.toBean(json, type); } //2.2.不存在 //判断是否为空值 if (json != null) { //不为null，则必为空 return null; } //3.查询数据库 R r = dbFallback.apply(id); if (r == null) { //3.1.不存在，缓存空值 stringRedisTemplate.opsForValue().set(key, "", CACHE_NULL_TTL, TimeUnit.MINUTES); } else { //3.2.存在，缓存数据 this.set(key, r, time, unit); } return r; }
方法三用到了函数式编程，这里非常巧妙，顺便再贴一下调用方法是怎样调用的：
Shop shop = cacheClient.queryWithPassThrough(CACHE_SHOP_KEY,id,Shop.class,CACHE_SHOP_TTL,TimeUnit.MINUTES,this::getById);
1.4 方法四
publicR queryWithLogicalExpire(String prefix, ID id, String lockPre, Class type, Long time, TimeUnit unit, Function dbFallback) { //1.从redis查询商铺缓存 String key = prefix + id; String json = stringRedisTemplate.opsForValue().get(key); //2.判断是否存在 if (StrUtil.isBlank(json)) { //未命中，直接返回空 return null; } //3.命中，判断是否过期 RedisData redisData = JSONUtil.toBean(json, RedisData.class); R r = JSONUtil.toBean((JSONObject) redisData.getData(), type); if (redisData.getExpireTime().isAfter(LocalDateTime.now())) { //3.1未过期,直接返回店铺信息 return r; } //3.2.已过期，缓存重建 //3.3.获取锁 String lockKey = lockPre + id; boolean flag = tryLock(lockKey); if (flag) { //3.4.获取成功 //4再次检查redis缓存是否过期，做double check json = stringRedisTemplate.opsForValue().get(key); //4.1.判断是否存在 if (StrUtil.isBlank(json)) { //未命中，直接返回空 return null; } //4.2.命中，判断是否过期 redisData = JSONUtil.toBean(json, RedisData.class); r = JSONUtil.toBean((JSONObject) redisData.getData(), type); if (redisData.getExpireTime().isAfter(LocalDateTime.now())) { //4.3.未过期,直接返回店铺信息 return r; } //4.4过期，返回旧数据 CACHE_REBUILD_EXECUTOR.submit(() -> { //5.重建缓存 try { R r1 = dbFallback.apply(id); this.setWithLogicExpire(key, r1, time, unit); } catch (Exception e) { throw new RuntimeException(e); } finally { //释放锁 unLock(lockKey); } }); } //7.获取失败,返回旧数据 return r; }
2. 完整工具类代码
@Component
@Slf4j
public class CacheClient {
private final StringRedisTemplate stringRedisTemplate;
public CacheClient(StringRedisTemplate stringRedisTemplate) {
this.stringRedisTemplate = stringRedisTemplate;
}
public void set(String key, Object value, Long time, TimeUnit unit) {
stringRedisTemplate.opsForValue().set(key, JSONUtil.toJsonStr(value), time, unit);
}
public void setWithLogicExpire(String key, Object value, Long time, TimeUnit unit) {
RedisData redisData = new RedisData();
redisData.setData(value);
redisData.setExpireTime(LocalDateTime.now().plusSeconds(unit.toSeconds(time)));
stringRedisTemplate.opsForValue().set(key, JSONUtil.toJsonStr(redisData));
}
public R queryWithPassThrough(String keyPrefix, ID id, Class type,
Long time, TimeUnit unit, Function dbFallback) {
String key = keyPrefix + id;
//1.从redis中查询商铺缓存
String json = stringRedisTemplate.opsForValue().get(key);
//2.判断是否存在
if (StrUtil.isNotBlank(json)) {
//2.1.存在
return JSONUtil.toBean(json, type);
}
//2.2.不存在
//判断是否为空值
if (json != null) {
//不为null，则必为空
return null;
}
//3.查询数据库
R r = dbFallback.apply(id);
if (r == null) {
//3.1.不存在，缓存空值
stringRedisTemplate.opsForValue().set(key, "", CACHE_NULL_TTL, TimeUnit.MINUTES);
} else {
//3.2.存在，缓存数据
this.set(key, r, time, unit);
}
return r;
}
public R queryWithLogicalExpire(String prefix, ID id, String lockPre, Class type,
Long time, TimeUnit unit, Function dbFallback) {
//1.从redis查询商铺缓存
String key = prefix + id;
String json = stringRedisTemplate.opsForValue().get(key);
//2.判断是否存在
if (StrUtil.isBlank(json)) {
//未命中，直接返回空
return null;
}
//3.命中，判断是否过期
RedisData redisData = JSONUtil.toBean(json, RedisData.class);
R r = JSONUtil.toBean((JSONObject) redisData.getData(), type);
if (redisData.getExpireTime().isAfter(LocalDateTime.now())) {
//3.1未过期,直接返回店铺信息
return r;
}
//3.2.已过期，缓存重建
//3.3.获取锁
String lockKey = lockPre + id;
boolean flag = tryLock(lockKey);
if (flag) {
//3.4.获取成功
//4再次检查redis缓存是否过期，做double check
json = stringRedisTemplate.opsForValue().get(key);
//4.1.判断是否存在
if (StrUtil.isBlank(json)) {
//未命中，直接返回空
return null;
}
//4.2.命中，判断是否过期
redisData = JSONUtil.toBean(json, RedisData.class);
r = JSONUtil.toBean((JSONObject) redisData.getData(), type);
if (redisData.getExpireTime().isAfter(LocalDateTime.now())) {
//4.3.未过期,直接返回店铺信息
return r;
}
//4.4过期，返回旧数据
CACHE_REBUILD_EXECUTOR.submit(() -> {
//5.重建缓存
try {
R r1 = dbFallback.apply(id);
this.setWithLogicExpire(key, r1, time, unit);
} catch (Exception e) {
throw new RuntimeException(e);
} finally {
//释放锁
unLock(lockKey);
}
});
}
//7.获取失败,返回旧数据
return r;
}
private static final ExecutorService CACHE_REBUILD_EXECUTOR = Executors.newFixedThreadPool(10);
//获取锁
private boolean tryLock(String key) {
Boolean flag = stringRedisTemplate.opsForValue().setIfAbsent(key, "1", LOCK_SHOP_TTL, TimeUnit.SECONDS);
return BooleanUtil.isTrue(flag);
}
//释放锁
private void unLock(String key) {
stringRedisTemplate.delete(key);
}
}
今天带大家了解了redis缓存的相关知识，希望对你有所帮助；关于数据库的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~
声明：本文转载于：脚本之家 如有侵犯，请联系study_golang@163.com删除
相关阅读
更多>
-
142 收藏
-
137 收藏
-
322 收藏
-
256 收藏
-
417 收藏
最新阅读
更多>
-
342 收藏
-
361 收藏
-
159 收藏
-
164 收藏
-
221 收藏
-
156 收藏
课程推荐
更多>
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案，代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景，打造一站式知识长龙服务，适合有JS基础的同学学习。
- 立即学习 541次学习
-
- GO语言核心编程课程
- 本课程采用真实案例，全面具体可落地，从理论到实践，一步一步将GO核心编程技术、编程思想、底层实现融会贯通，使学习者贴近时代脉搏，做IT互联网时代的弄潮儿。
- 立即学习 506次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信：Le-studyg；在课程中，我们将首先介绍MySQL8的新特性，包括性能优化、安全增强、新数据类型等，帮助学生快速熟悉MySQL8的最新功能。接着，我们将深入解析MySQL的网络通信机制，包括协议、连接管理、数据传输等，让
- 立即学习 497次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 立即学习 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网，分为导航，轮播，关于我们，成功案例，服务流程，团队介绍，数据部分，公司动态，底部信息等内容区块。网站整体采用CSSGrid布局，支持响应式，有流畅过渡和展现动画。
- 立即学习 484次学习
评论列表
-
- 土豪的猎豹
- 这篇文章内容真是及时雨啊，太细致了，太给力了，已加入收藏夹了，关注up主了！希望up主能多写数据库相关的文章。
- 2023-04-08 07:18:33
-
- 风趣的豌豆
- 好细啊，码住，感谢up主的这篇技术文章，我会继续支持！
- 2023-03-25 09:06:56
-
- 无聊的高跟鞋
- 很棒，一直没懂这个问题，但其实工作中常常有遇到...不过今天到这，看完之后很有帮助，总算是懂了，感谢博主分享技术贴！
- 2023-03-01 03:54:54
-
- 朴实的玉米
- 写的不错，一直没懂这个问题，但其实工作中常常有遇到...不过今天到这，帮助很大，总算是懂了，感谢大佬分享技术文章！
- 2023-03-01 00:31:32
-
- 谨慎的酒窝
- 细节满满，码住，感谢老哥的这篇博文，我会继续支持！
- 2023-02-28 17:07:42
-
- 迷路的跳跳糖
- 这篇技术贴太及时了，细节满满，真优秀，mark，关注楼主了！希望楼主能多写数据库相关的文章。
- 2023-02-27 20:54:09