Redis缓存失效机制介绍

Redis缓存失效机制

Redis缓存失效机制是为应对缓存应用的一种很常见的场景而设计的，讲个场景：

我们为了减轻后端数据库的压力，很开心的借助Redis服务把变化频率不是很高的数据从DB load出来放入了缓存，因此之后的一段时间内我们都可以直接从缓存上拿数据，然而我们又希望一段时间之后，我们再重新的从DB load出当前的数据放入缓存，这个事情怎么做呢？

问题提出来了，这个问题怎么解决呢？好吧，我们对于手头的语言工具很熟悉，坚信可以很快的写出这么一段逻辑：我们记录上次从db load数据的时间，然后每次响应服务的时候都去判断时间是不是过期了，要不要从db重新load了……。当然这种方法也是可以的，然而当我们查阅Redis command document的时候，发现我们做了本来不需要做的事情，Redis本身提供这种机制，我们只要借助EXPIRE命令就可以轻松的搞定这件事情：

EXPIRE key 30

上面的命令即为key设置30秒的过期时间，超过这个时间，我们应该就访问不到这个值了，到此为止我们大概明白了什么是缓存失效机制以及缓存失效机制的一些应用场景，接下来我们继续深入探究这个问题，Redis缓存失效机制是如何实现的呢？

延迟失效机制

延迟失效机制即当客户端请求操作某个key的时候，Redis会对客户端请求操作的key进行有效期检查，如果key过期才进行相应的处理，延迟失效机制也叫消极失效机制。我们看看t_string组件下面对get请求处理的服务端端执行堆栈：

getCommand 
 -> getGenericCommand 
 -> lookupKeyReadOrReply 
 -> lookupKeyRead 
 -> expireIfNeeded

关键的地方是expireIfNeed，Redis对key的get操作之前会判断key关联的值是否失效，这里先插入一个小插曲，我们看看Redis中实际存储值的地方是什么样子的：

typedef struct redisDb {
 dict *dict; /* The keyspace for this DB */
 dict *expires; /* Timeout of keys with a timeout set */
 dict *blocking_keys; /* Keys with clients waiting for data (BLPOP) */
 dict *ready_keys; /* Blocked keys that received a PUSH */
 dict *watched_keys; /* WATCHED keys for MULTI/EXEC CAS */
 int id; long long avg_ttl; /* Average TTL, just for stats */} redisDb;

上面是Redis中定义的一个结构体，dict是一个Redis实现的一个字典，也就是每个DB会包括上面的五个字段，我们这里只关心两个字典，一个是dict，一个是expires：

dict是用来存储正常数据的，比如我们执行了set key "hahaha"，这个数据就存储在dict中。

expires使用来存储关联了过期时间的key的，比如我们在上面的基础之上有执行的expire key 1，这个时候就会在expires中添加一条记录。

回过头来看看expireIfNeeded的流程，大致如下：

从expires中查找key的过期时间，如果不存在说明对应key没有设置过期时间，直接返回。

如果是slave机器，则直接返回，因为Redis为了保证数据一致性且实现简单，将缓存失效的主动权交给Master机器，slave机器没有权限将key失效。

如果当前是Master机器，且key过期，则master会做两件重要的事情：1）将删除命令写入AOF文件。2）通知Slave当前key失效，可以删除了。

master从本地的字典中将key对于的值删除。

主动失效机制

主动失效机制也叫积极失效机制，即服务端定时的去检查失效的缓存，如果失效则进行相应的操作。

我们都知道Redis是单线程的，基于事件驱动的，Redis中有个EventLoop，EventLoop负责对两类事件进行处理：

一类是IO事件，这类事件是从底层的多路复用器分离出来的。

一类是定时事件，这类事件主要用来事件对某个任务的定时执行。

看起来Redis的EventLoop和Netty以及JavaScript的EventLoop功能设计的大概类似，一方面对网络I/O事件处理，一方面还可以做一些小任务。

为什么讲到Redis的单线程模型，因为Redis的主动失效机制逻辑是被当做一个定时任务来由主线程执行的，相关代码如下：

if(aeCreateTimeEvent(server.el, 1, serverCron, NULL, NULL) == AE_ERR) {
 redisPanic("Can't create the serverCron time event."); 
 exit(1);
 }

serverCron就是这个定时任务的函数指针，adCreateTimeEvent将serverCron任务注册到EventLoop上面，并设置初始的执行时间是1毫秒之后。接下来，我们想知道的东西都在serverCron里面了。serverCron做的事情有点多，我们只关心和本篇内容相关的部分，也就是缓存失效是怎么实现的，我认为看代码做什么事情，调用堆栈还是比较直观的：

aeProcessEvents
 ->processTimeEvents
 ->serverCron 
 -> databasesCron 
 -> activeExpireCycle 
 -> activeExpireCycleTryExpire

EventLoop通过对定时任务的处理，触发对serverCron逻辑的执行，最终之执行key过期处理的逻辑，值得一提的是，activeExpireCycle逻辑只能由master来做。

更多redis知识请关注redis入门教程栏目。

声明：本网页内容旨在传播知识，若有侵权等问题请及时与本网联系，我们将在第一时间删除处理。TEL:177 7030 7066 E-MAIL:11247931@qq.com