springboot中redis的缓存穿透问题实现
更新时间：2021年02月05日 08:57:04 作者：quintan
这篇文章主要介绍了springboot中redis的缓存穿透问题实现,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
什么是缓存穿透问题？？
我们使用redis是为了减少数据库的压力，让尽量多的请求去承压能力比较大的redis，而不是数据库。但是高并发条件下，可能会在redis还没有缓存的时候，大量的请求同时进入，导致一大批的请求直奔数据库，而不会经过redis。使用代码模拟缓存穿透问题如下：
首先是service里面的代码：
@Service
public class NewsService {
@Autowired
private NewsDAO newsDAO;
//springboot自动初始化，不需要我们进行配置，直接注入到代码中使用
@Autowired
private RedisTemplate<Object,Object> redisTemplate;
public /*synchronized*/ List<News> getLatestNews(int userId,int offset,int limit){
//设置序列化方式，防止乱码
redisTemplate.setKeySerializer(new StringRedisSerializer());
//第一步：查询缓存
News news= (News) redisTemplate.opsForValue().get("newsKey");
//判断是否存在缓存
if(null == news){//查询数据库
news = newsDAO.selectByUserIdAndOffset(userId,offset,limit).get(0);
//
redisTemplate.opsForValue().set("newsKey",news);
System.out.println("进入数据库。。。。。。。。");
}else{
System.out.println("进入缓存。。。。。。。。。");
}
return newsDAO.selectByUserIdAndOffset(userId,offset,limit);
}
}
然后是使用线程池在Controller里面对请求进行模拟：
@Controller
public class HomeController {
@Autowired
UserService userService;
@Autowired
NewsService newsService;
//遇到的坑，如果不加method，页面启动不起来。
@RequestMapping(value = "/home",method = {RequestMethod.GET, RequestMethod.POST})
@ResponseBody
public String index(Model model){
//这边是可以读出数据来的
//线程池------缓存穿透问题的复现
ExecutorService executorService = Executors.newFixedThreadPool(8*2);
for(int i = 0;i < 50000;i++){
executorService.submit(new Runnable() {
@Override
public void run() {
List<News> newsList = newsService.getLatestNews(0,0,10);
}
});
}
List<News> newsList = newsService.getLatestNews(0,0,10);
News news=newsList.get(0);
return news.getImage();
}
}
结果如图：大量的请求进入数据库，那么如何解决这个问题？
方法一、在方法上加锁：
@Service
public class NewsService {
@Autowired
private NewsDAO newsDAO;
//springboot自动初始化，不需要我们进行配置，直接注入到代码中使用
@Autowired
private RedisTemplate<Object,Object> redisTemplate;
//第一种方式：方法加锁
public synchronized List<News> getLatestNews(int userId,int offset,int limit){
//设置序列化方式，防止乱码
redisTemplate.setKeySerializer(new StringRedisSerializer());
//第一步：查询缓存
News news= (News) redisTemplate.opsForValue().get("newsKey");
//判断是否存在缓存
if(null == news){
//查询数据库
news = newsDAO.selectByUserIdAndOffset(userId,offset,limit).get(0);
//
redisTemplate.opsForValue().set("newsKey",news);
System.out.println("进入数据库。。。。。。。。");
}else{
System.out.println("进入缓存。。。。。。。。。");
}
return newsDAO.selectByUserIdAndOffset(userId,offset,limit);
}
}
直接在方法上加锁，保证每次只有一个请求可以进入。但是这个方法存在一个缺陷，每次只有一个请求可以进入，请求处理的速度变得相当的慢，不利于系统的实时性。
方法二、使用双重校验锁：
@Service
public class NewsService {
@Autowired
private NewsDAO newsDAO;
//springboot自动初始化，不需要我们进行配置，直接注入到代码中使用
@Autowired
private RedisTemplate<Object,Object> redisTemplate;
//第一种方式：方法加锁
public /*synchronized*/ List<News> getLatestNews(int userId,int offset,int limit){
//设置序列化方式，防止乱码
redisTemplate.setKeySerializer(new StringRedisSerializer());
//第一步：查询缓存
News news= (News) redisTemplate.opsForValue().get("newsKey");
//判断是否存在缓存
if(null == news){
//第二种方式：双重检测锁
synchronized (this){
//查询数据库
news = newsDAO.selectByUserIdAndOffset(userId,offset,limit).get(0);
//
redisTemplate.opsForValue().set("newsKey",news);
System.out.println("进入数据库。。。。。。。。");
}
}else{
System.out.println("进入缓存。。。。。。。。。");
}
return newsDAO.selectByUserIdAndOffset(userId,offset,limit);
}
}
这个方法比较好，虽然不能保证只有一个请求请求数据库，但是当第一批请求进来，第二批之后的所有请求全部会在缓存取数据。
到此这篇关于springboot中redis的缓存穿透问题实现的文章就介绍到这了,更多相关springboot redis缓存穿透内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
在 Java 中，动态编译是指在运行时动态地编译 Java 源代码，生成字节码，并加载到 JVM 中执行，动态编译可以用于实现动态代码生成、动态加载、插件化等功能，本文将给大家分享一下Java 动态编译在项目中的实践，感兴趣的同学跟着小编一起来看看吧2023-07-07
使用druid数据库连接池实现动态的配置数据源功能，在配置过程中出现一个问题既然是用户自己配置的数据源，就无法避免输入错误，连接失败等情况，关于这个问题怎么处理呢，今天小编通过本文给大家详细说明下，感兴趣的朋友一起看看吧2021-05-05
FluentMybatis实现mybatis动态sql拼装和fluent api语法
本文主要介绍了FluentMybatis实现mybatis动态sql拼装和fluent api语法，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2021-08-08
Java String.replace()方法"无效"的原因及解决方式
这篇文章主要介绍了Java String.replace()方法"无效"的原因及解决方式，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2020-08-08
Springboot中@Async异步,实现异步结果合并统一返回方式
这篇文章主要介绍了Springboot中@Async异步,实现异步结果合并统一返回方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2023-09-09
这篇文章主要为大家详细介绍了java实现表格数据的存储，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2021-04-04
这篇文章主要介绍了通过maven运行项目的两种方式,给大家提到了通过tomcat的方式来启动maven项目的方法，通过图文并茂的形式给大家介绍的非常详细，需要的朋友可以参考下2021-12-12
JAVA Stack是栈。它的特性是：先进后出(FILO, First In Last Out)。2013-11-11
这篇文章主要介绍了java File类的基本使用方法总结，为大家分享了java实现上传代码，感兴趣的小伙伴们可以参考一下2016-04-04
这篇文章主要介绍了布隆过滤器的原理以及java 简单实现，帮助大家更好的理解和学习Java，感兴趣的朋友可以了解下2020-11-11
最新评论