什么是缓存穿透问题？？
我们使用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 <span>本文来源gaodai#ma#com搞*!代#%^码网5</span>= 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);
}
}
搞代码网（gaodaima.com）提供的所有资源部分来自互联网，如果有侵犯您的版权或其他权益，请说明详细缘由并提供版权或权益证明然后发送到邮箱[email protected]，我们会在看到邮件的第一时间内为您处理，或直接联系QQ：872152909。本网站采用BY-NC-SA协议进行授权
转载请注明原文链接：springboot中redis的缓存穿透问题实现
转载请注明原文链接：springboot中redis的缓存穿透问题实现
