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实现和可被K整除的子数组的相关资料,这道题来自力扣,通过学习这道题的解题思路以及代码对大家的学习或者工作具有一定的参考借鉴价值,需要的朋友可以参考下2024-01-01
SpringBoot任意版本集成Swagger各种版本的操作指南
在学习Swagger生成API文档的时候经常会遇到问题,而目前市面上大部分技术分享者的SpringBoot版本并没和我们的同步,导致一些一模一样的代码,在我们的项目上却无法使用,这是一个经常性的问题,本文章就旨在和大家搞定SpringBoot任意版本集成Swagger各种版本2024-07-07
这篇文章主要介绍了Mybatis 中 Oracle 的拼接模糊查询及用法，非常不错，具有一定的参考借鉴价值,需要的朋友可以参考下2018-08-08
今天给大家带来的是关于Java并发的相关知识,文章围绕着ReentrantLock源码展开,文中有非常详细的介绍及代码示例,需要的朋友可以参考下2021-06-06
这篇文章主要给大家介绍了关于java如何发送get请求获取数据的相关资料,Java中的GET请求方法是HTTP协议中的一种请求方式,用于向服务器请求获取资源,需要的朋友可以参考下2023-10-10
Web开发的核心内容主要包括内嵌的Servlet容器和SpringMVCSpringBoot使用起来非常简洁，大部分配置都有SpringBoot自动装配，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习吧2022-10-10
这篇文章主要介绍了Mybatis注解方式操作Oracle数据库详解，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2020-11-11
下面小编就为大家分享一篇基于Java 生产者消费者模式(详细分析)，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2018-01-01
这篇文章主要为大家详细介绍了java实现文件重命名，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2020-03-03
Java利用iTextPDF库实现制作PDF表格模板并填充数据
这篇文章主要为大家详细介绍了如何通过Java的iTextPDF库制作一个PDF表格模板并填充数据,文中的示例代码讲解详细,感兴趣的小伙伴快跟随小编一起学习一下吧2023-12-12
最新评论