文档章节

使用Spring4.3解决缓存过期后多线程并发访问数据库的问题

孟飞阳
 孟飞阳
发布于 2017/02/16 14:29
字数 475
阅读 24
收藏 0

 

缓存过期之后,如果多个线程同时请求对某个数据的访问,会同时去到数据库,导致数据库瞬间负荷增高。Spring4.3为@Cacheable注解提供了一个新的参数“sync”(boolean类型,缺省为false),当设置它为true时,只有一个线程的请求会去到数据库,其他线程都会等待直到缓存可用。这个设置可以减少对数据库的瞬间并发访问。
不过不一定所有的缓存系统都支持这个配置。经过验证,Guava Cache是支持的。验证过程如下:

1、Guava Cache配置,参考:http://blog.csdn.net/clementad/article/details/51250472

2、创建从数据库获取数据的类和方法,该方法使用@Cacheable注解:

@Service  
public class UserServiceCacheablesImpl implements UserServiceCacheables{  
    private final static Logger logger = LoggerFactory.getLogger(UserServiceCacheablesImpl.class);  
  
    @Autowired  
    UserDAO userDAO;  
      
    @Override  
    @Cacheable(value="getPhoneNoByUserId")  
    public String getPhoneNoByUserId(int userId) {  
        logger.debug("getting data from database, userId={}", userId);  
        return userDAO.getPhoneNoByUserId(userId);  
    }  
}  

3、创建多线程并发的单元测试代码:

@RunWith(SpringRunner.class)  
@SpringBootTest  
public class AdminApplicationTests {  
    protected final Logger logger = LoggerFactory.getLogger(this.getClass());  
  
    @Autowired  
    UserServiceCacheables userServiceCacheables;  
      
    /** 
     * 多线程并发测试 
     */  
    @Test  
    public void multiThreads() throws Exception{  
        int number = 3; //线程数  
        ExecutorService executorService = Executors.newFixedThreadPool(number);  
          
        List<Future<String>> results = new ArrayList<Future<String>>();  
        int userId = 26358;  
          
        for (int i=0; i < number; i++) { //非阻塞地启动number个线程,由Future接收结果  
            Future<String> future = executorService.submit(new MyThread(userId));  
            //Thread.sleep(300);  
            results.add(future);  
        }  
          
        for(Future<String> f : results){ //从Future中获取结果,打印出来  
            String phoneNo = f.get();  
            logger.debug(phoneNo);  
        }  
    }  
      
    class MyThread implements Callable<String>{  
        int userId;  
          
        public MyThread(int userId) {  
            this.userId = userId;  
        }  
          
        @Override  
        public String call() throws Exception {  
            return userServiceCacheables.getPhoneNoByUserId(userId);  
        }  
    }  
}  


4、测试结果:
当设置3个并发线程的时候,会出现3个log:“getting data from database, userId=26358”,说明访问了3次数据库。
当修改注解如下之后,只出现一次“getting data from database, userId=26358”,说明只访问了1次数据库,另外两次命中了缓存:

@Cacheable(value="getPhoneNoByUserId", sync=true)  

 

本文转载自:http://blog.csdn.net/clementad/article/details/52452119

共有 人打赏支持
孟飞阳
粉丝 206
博文 971
码字总数 544356
作品 5
朝阳
个人站长
私信 提问
ASP.NET Core 中的缓存

目录 缓存的基本概念 缓存原理 缓存设计 分布式缓存 Memcache 与 Redis 的比较 缓存穿透,缓存击穿,缓存雪崩解决方案 数据一致性 使用内置 MemoryCache 使用分布式缓存 Redis 使用 Stackexc...

RoyZShare
08/14
0
0
缓存写法总结

基本写法 为了方便演示,这里使用Runtime.Cache做缓存容器,并定义个简单操作类。如下: 简单读取: 在项目中,有不少这样写法,这样写并没有错,但在并发量上来后就容易出问题。 缓存雪崩 ...

吞吞吐吐的
2017/09/26
0
0
Redis系列十:缓存雪崩、缓存穿透、缓存预热、缓存更新、缓存降级

一、缓存雪崩 缓存雪崩我们可以简单的理解为:由于原有缓存失效,新缓存未到期间(例如:我们设置缓存时采用了相同的过期时间,在同一时刻出现大面积的缓存过期),所有原本应该访问缓存的请求...

Forande
08/27
0
0
Redis应用学习——缓存的使用与设计

缓存的收益与成本 1. 收益: 通过缓存加速读写速度。在内存中读写比硬盘速度快 降低数据库服务器的负载。比如业务端的请求的数据大多数都由Redis服务器来处理,大大减轻MySQL服务器的压力 2....

江左煤郎
11/11
0
0
缓存相关——缓存穿透、缓存并发、缓存失效、缓存预热、缓存雪崩、缓存算法

一、缓存穿透 我们在项目中使用缓存通常都是先检查缓存中是否存在,如果存在直接返回缓存内容,如果不存在就直接查询数据库然后再缓存查询结果返回。这个时候如果我们查询的某一个数据在缓存...

空云万里晴
2016/06/16
1K
0

没有更多内容

加载失败,请刷新页面

加载更多

码云项目100,水一发

简单回顾一下: 早期构想最多的,是希望能将PHP一些类和编码分区做得更细,所以很多尝试。但不得不说,PHP的功能过于单一,是的,也许写C/C++扩展,可以解决问题,那我为什么不用C#或者Golan...

曾建凯
今天
1
0
Spring应用学习——AOP

1. AOP 1. AOP:即面向切面编程,采用横向抽取机制,取代了传统的继承体系的重复代码问题,如下图所示,性能监控、日志记录等代码围绕业务逻辑代码,而这部分代码是一个高度重复的代码,也就...

江左煤郎
今天
4
0
eclipse的版本

Eclipse各版本代号一览表 Eclipse的设计思想是:一切皆插件。Eclipse核心很小,其它所有功能都以插件的形式附加于Eclipse核心之上。 Eclipse基本内核包括:图形API(SWT/Jface),Java开发环...

mdoo
今天
3
0
SpringBoot源码:启动过程分析(一)

本文主要分析 SpringBoot 的启动过程。 SpringBoot的版本为:2.1.0 release,最新版本。 一.时序图 还是老套路,先把分析过程的时序图摆出来:时序图-SpringBoot2.10启动分析 二.源码分析 首...

Jacktanger
今天
6
0
小白带你认识netty(二)之netty服务端启动(上)

上一章 中的标准netty启动代码中,ServerBootstrap到底是如何启动的呢?这一章我们来瞅下。 server.group(bossGroup, workGroup);server.channel(NioServerSocketChannel.class).optio...

天空小小
今天
4
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部