缓存热点key问题(mutex key)

您所在的位置:网站首页 复制key是什么意思 缓存热点key问题(mutex key)

缓存热点key问题(mutex key)

2024-07-07 20:43| 来源: 网络整理| 查看: 265

一、引出热点key问题  

       我们通常使用 缓存 + 过期时间的策略来帮助我们加速接口的访问速度,减少了后端负载,同时保证功能的更新,一般情况下这种模式已经基本满足要求了。

       但是有两个问题如果同时出现,可能就会对系统造成致命的危害:

      (1) 这个key是一个热点key(例如一个重要的新闻,一个热门的八卦新闻等等),所以这种key访问量可能非常大。

      (2) 缓存的构建是需要一定时间的。(可能是一个复杂计算,例如复杂的sql、多次IO、多个依赖(各种接口)等等)

 

       于是就会出现一个致命问题:在缓存失效的瞬间,有大量线程来构建缓存(见下图),造成后端负载加大,甚至可能会让系统崩溃 。

 

    

         

 

 

二、四种解决方案

 

我们的目标是:尽量少的线程构建缓存(甚至是一个) + 数据一致性 + 较少的潜在危险,下面会介绍四种方法来解决这个问题:

 下载  

1. 使用互斥锁(mutex key): 这种解决方案思路比较简单,就是只让一个线程构建缓存,其他线程等待构建缓存的线程执行完,重新从缓存获取数据就可以了(如下图)

     如果是单机,可以用synchronized或者lock来处理,如果是分布式环境可以用分布式锁就可以了(分布式锁,可以用memcache的add, redis的setnx, zookeeper的添加节点操作)。

     下面是Tim yang博客的代码,是memcache的伪代码实现下载  

      

Java代码   if (memcache.get(key) == null) {       // 3 min timeout to avoid mutex holder crash       if (memcache.add(key_mutex, 3 * 60 * 1000) == true) {           value = db.get(key);           memcache.set(key, value);           memcache.delete(key_mutex);       } else {           sleep(50);           retry();       }   }          

      如果换成redis,就是:下载  

Java代码   String get(String key) {      String value = redis.get(key);      if (value  == null) {       if (redis.setnx(key_mutex, "1")) {           // 3 min timeout to avoid mutex holder crash           redis.expire(key_mutex, 3 * 60)           value = db.get(key);           redis.set(key, value);           redis.delete(key_mutex);       } else {           //其他线程休息50毫秒后重试           Thread.sleep(50);           get(key);       }     }   }      

       

2. "提前"使用互斥锁(mutex key):

   在value内部设置1个超时值(timeout1), timeout1比实际的memcache timeout(timeout2)小。当从cache读取到timeout1发现它已经过期时候,马上延长timeout1并重新设置到cache。然后再从数据库加载数据并设置到cache中。伪代码如下:下载  

 

Java代码   v = memcache.get(key);   if (v == null) {       if (memcache.add(key_mutex, 3 * 60 * 1000) == true) {           value = db.get(key);           memcache.set(key, value);           memcache.delete(key_mutex);       } else {           sleep(50);           retry();       }   } else {       if (v.timeout 



【本文地址】


今日新闻


推荐新闻


CopyRight 2018-2019 办公设备维修网 版权所有 豫ICP备15022753号-3