av一区二区在线观看_亚洲男人的天堂网站_日韩亚洲视频_在线成人免费_欧美日韩精品免费观看视频_久草视

您的位置:首頁技術文章
文章詳情頁

springboot中redis的緩存穿透問題實現

瀏覽:2日期:2023-03-25 17:00:02
什么是緩存穿透問題??

我們使用redis是為了減少數據庫的壓力,讓盡量多的請求去承壓能力比較大的redis,而不是數據庫。但是高并發條件下,可能會在redis還沒有緩存的時候,大量的請求同時進入,導致一大批的請求直奔數據庫,而不會經過redis。使用代碼模擬緩存穿透問題如下:

首先是service里面的代碼:

@Servicepublic 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里面對請求進行模擬:

@Controllerpublic 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() {@Overridepublic 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(); }}

結果如圖:大量的請求進入數據庫,那么如何解決這個問題?

springboot中redis的緩存穿透問題實現

方法一、在方法上加鎖:

@Servicepublic 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); }}

直接在方法上加鎖,保證每次只有一個請求可以進入。但是這個方法存在一個缺陷,每次只有一個請求可以進入,請求處理的速度變得相當的慢,不利于系統的實時性。

方法二、使用雙重校驗鎖:

@Servicepublic 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緩存穿透內容請搜索好吧啦網以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持好吧啦網!

標簽: Spring
相關文章:
主站蜘蛛池模板: 日韩中文一区二区三区 | 亚洲午夜在线 | 国产在视频一区二区三区吞精 | 日韩电影中文字幕 | 在线观看视频91 | 欧洲高清转码区一二区 | 91亚洲精品在线观看 | 欧美成人精品一区二区男人看 | 国产精品欧美一区二区三区不卡 | 亚洲国产网站 | 精品国产一区二区三区久久 | 日韩欧美在线免费观看 | av电影一区 | 一区二区三区四区在线视频 | 中文字幕欧美在线观看 | 日韩av免费在线电影 | 日本精品一区二区三区视频 | 国产成人精品久久二区二区 | 国产区视频在线观看 | 欧美日韩国产一区二区三区 | 国产精品一区二区av | 91视频精选 | 在线观看的av | www国产成人免费观看视频,深夜成人网 | 丁香婷婷在线视频 | 亚洲精品电影网在线观看 | 九九热这里只有精品在线观看 | 欧美激情一区二区三区 | 日本精品视频一区二区 | 国产精品免费视频一区 | 成人免费福利视频 | 在线观看www高清视频 | 亚洲a视频 | 国产精品久久久久久久久久东京 | 精品自拍视频 | 超碰成人在线观看 | 中文字幕99 | 国产精品久久久久久久久动漫 | 午夜成人在线视频 | 欧美二区在线 | 日韩一区在线播放 |