文档章节

使用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

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

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

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

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

吞吞吐吐的
2017/09/26
0
0
Redis应用学习——缓存的使用与设计

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

江左煤郎
2018/11/11
0
0
Redis系列十:缓存雪崩、缓存穿透、缓存预热、缓存更新、缓存降级

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

Forande
2018/08/27
0
0
缓存相关——缓存穿透、缓存并发、缓存失效、缓存预热、缓存雪崩、缓存算法

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

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

没有更多内容

加载失败,请刷新页面

加载更多

数据库篇多表操作

第1章 多表操作 实际开发中,一个项目通常需要很多张表才能完成。例如:一个商城项目就需要分类表(category)、商品表(products)、订单表(orders)等多张表。且这些表的数据之间存在一定的关系...

stars永恒
今天
2
0
nginx日志自动切割

1.日志配置(Nginx 日志) access.log----记录哪些用户,哪些页面以及用户浏览器,IP等访问信息;error.log------记录服务器错误的日志 #配置日志存储路径:location / {      a...

em_aaron
昨天
3
0
java 反射

基本概念 RTTI,即Run-Time Type Identification,运行时类型识别。RTTI能在运行时就能够自动识别每个编译时已知的类型。   要想理解反射的原理,首先要了解什么是类型信息。Java让我们在运...

细节探索者
昨天
2
0
推荐转载连接

https://www.cnblogs.com/ysocean/p/7409779.html#_label0

小橙子的曼曼
昨天
3
0
雷军亲自打造的套餐了解下:用多少付多少

12月28日消息,小米科技创始人兼CEO雷军微博表示,小米移动任我行套餐方案,原则上就是明明白白消费,用多少付多少,不用不花钱!上网、电话和短信都是一毛钱,上网0.1元/M,电话0.1元/分钟,...

linuxCool
昨天
6
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部