作为一种定期清理无效数据的重要机制，主键失效存在于大多数缓存系统中，reids也不例外。在redis提供的诸多命令中，expire、expireat、pexpire、pexpireat以及setex和psetex均可以用来设置一条key-value对的失效时间，而一条key-value对一旦被关联了失效时间就会在到期后自动删除（或者说变得无法访问更为准确）。可以说，主键失效这个概念还是比较容易理解的，但是在具体实现到redis中又是如何呢？最近本博主就对redis中的主键失效机制产生了几个疑问，并根据这些疑问对其进行了仔细的探究，现总结所得如下，以飨各位看客。
一、除了调用persist命令外，还有没有其他情况会撤销一个主键的失效时间？答案是肯定的。首先，在通过del命令删除一个主键时，失效时间自然会被撤销（这不是废话么，哈哈）。其次，在一个设置了失效时间的主键被更新覆盖时，该主键的失效时间也会被撤销（这貌似也是废话，哈哈）。但需要注意的是，这里所说的是主键被更新覆盖，而不是主键对应的value被更新覆盖，因此set、mset或者是getset可能会导致主键被更新覆盖，而像incr、decr、lpush、hset等都是更新主键对应的值，这类操作是不会触碰主键的失效时间的。此外，还有一个特殊的命令就是rename，当我们使用rename对一个主键进行重命名后，之前关联的失效时间会自动传递给新的主键，但是如果一个主键是被rename所覆盖的话（如主键hello可能会被命令rename
world hello所覆盖），这时被覆盖主键的失效时间会被自动撤销，而新的主键则继续保持原来主键的特性。
二、redis中的主键失效是如何实现的，即失效的主键是如何删除的？实际上，redis删除失效主键的方法主要有两种：1）消极方法（passive
way），在主键被访问时如果发现它已经失效，那么就删除它；2）积极方法（active
way），周期性地从设置了失效时间的主键中选择一部分失效的主键删除。接下来我们就通过代码来探究一下这两种方法的具体实现，但在此之前，我们先看一看redis是如何管理和维护主键的吧（注：本博文中的源码全部来自redis-2.6.12）。
代码段一给出了redis中关于数据库的结构体定义，这个结构体定义中除了id以外都是指向字典的指针，其中我们只看dict和expires，前者用来维护一个redis数据库中包含的所有key-value对（其结构可以理解为dict[key]:value，即主键与值之间的映射），后者则用于维护一个redis数据库中设置了失效时间的主键（其结构可以理解为expires[key]:timeout，即主键与失效时间的映射）。当我们使用setex和psetex命令向系统插入数据时，redis首先将key和value添加到dict这个字典表中，然后将key和失效时间添加到expires这个字典表中。当我们使用expire、expireat、pexpire和pexpireat命令设置一个主键的失效时间时，redis首先到dict这个字典表中查找要设置的主键是否存在，如果存在就将这个主键和失效时间添加到expires这个字典表。简单地总结来说就是，设置了失效时间的主键和具体的失效时间全部都维护在expires这个字典表中。
代码段一：
typedef struct redisdb {
dict *dict;
dict *expires;
dict *blocking_keys;
dict *ready_keys;
dict *watched_keys;
int id;
} redisdb;
在大致了解了redis是如何维护设置了失效时间的主键之后，我们就先来看一看redis是如何实现消极地删除失效主键的。代码段二给出了一个名为expireifneeded的函数，这个函数在任何访问数据的函数中都会被调用，也就是说redis在实现get、mget、hget、lrange等所有涉及到读取数据的命令时都会调用它，它存在的意义就是在读取数据之前先检查一下它有没有失效，如果失效了就删除它。代码段二中给出了expireifneeded函数的所有相关描述，这里就不再重复它的实现方法了。这里需要说明的是在expireifneeded函数中调用的另外一个函数propagateexpire，这个函数用来在正式删除失效主键之前广播这个主键已经失效的信息，这个信息会传播到两个目的地：一个是发送到aof文件，将删除失效主键的这一操作以del
key的标准命令格式记录下来；另一个就是发送到当前redis服务器的所有slave，同样将删除失效主键的这一操作以del
key的标准命令格式告知这些slave删除各自的失效主键。从中我们可以知道，所有作为slave来运行的redis服务器并不需要通过消极方法来删除失效主键，它们只需要对master唯命是从就ok了！
代码段二：
int expireifneeded(redisdb *db, robj *key) {
获取主键的失效时间
long long when = getexpire(db,key);
假如失效时间为负数，说明该主键未设置失效时间（失效时间默认为-1），直接返回0
if (when < 0) return 0;
假如redis服务器正在从rdb文件中加载数据，暂时不进行失效主键的删除，直接返回0
if (server.loading) return 0;
假如当前的redis服务器是作为slave运行的，那么不进行失效主键的删除，因为slave
上失效主键的删除是由master来控制的，但是这里会将主键的失效时间与当前时间进行
一下对比，以告知调用者指定的主键是否已经失效了
if (server.masterhost != null) {
return mstime() > when;
}
如果以上条件都不满足，就将主键的失效时间与当前时间进行对比，如果发现指定的主键
还未失效就直接返回0
if (mstime() <= when) return 0;
如果发现主键确实已经失效了，那么首先更新关于失效主键的统计个数，然后将该主键失
效的信息进行广播，最后将该主键从数据库中删除
server.stat_expiredkeys++;
propagateexpire(db,key);
return dbdelete(db,key);
}
代码段三：
void propagateexpire(redisdb *db, robj *key) {
robj *argv[2];
shared.del是在redis服务器启动之初就已经初始化好的一个常用redis对象，即del命令
argv[0] = shared.del;
argv[1] = key;
incrrefcount(argv[0]);
incrrefcount(argv[1]);
检查redis服务器是否开启了aof，如果开启了就为失效主键记录一条del日志
if (server.aof_state != redis_aof_off)
feedappendonlyfile(server.delcommand,db->id,argv,2);
检查redis服务器是否拥有slave，如果是就向所有slave发送del失效主键的命令，这就是
上面expireifneeded函数中发现自己是slave时无需主动删除失效主键的原因了，因为它
只需听从master发送过来的命令就ok了
if (listlength(server.slaves))
replicationfeedslaves(server.slaves,db->id,argv,2);
decrrefcount(argv[0]);
decrrefcount(argv[1]);
以上我们通过对expireifneeded函数的介绍了解了redis是如何以一种消极的方式删除失效主键的，但是仅仅通过这种方式显然是不够的，因为如果某些失效的主键迟迟等不到再次访问的话，redis就永远不会知道这些主键已经失效，也就永远也不会删除它们了，这无疑会导致内存空间的浪费。因此，redis还准备了一招积极的删除方法，该方法利用redis的时间事件来实现，即每隔一段时间就中断一下完成一些指定操作，其中就包括检查并删除失效主键。这里我们说的时间事件的回调函数就是servercron，它在redis服务器启动时创建，每秒的执行次数由宏定义redis_default_hz来指定，默认每秒钟执行10次。代码段四给出该时间事件创建时的程序代码，该代码在redis.c文件的initserver函数中。实际上，servercron这个回调函数不仅要进行失效主键的检查与删除，还要进行统计信息的更新、客户端连接超时的控制、bgsave和aof的触发等等，这里我们仅关注删除失效主键的实现，也就是函数activeexpirecycle。
代码段四：
if(aecreatetimeevent(server.el, 1, servercron, null, null) == ae_err) {
redispanic("create time event failed");
exit(1);
代码段五给出了函数activeexpirecycle的实现及其详细描述，其主要实现原理就是遍历处理redis服务器中每个数据库的expires字典表中，从中尝试着随机抽样redis_expirelookups_per_cron（默认值为10）个设置了失效时间的主键，检查它们是否已经失效并删除掉失效的主键，如果失效的主键个数占本次抽样个数的比例超过25%，redis会认为当前数据库中的失效主键依然很多，所以它会继续进行下一轮的随机抽样和删除，直到刚才的比例低于25%才停止对当前数据库的处理，转向下一个数据库。这里我们需要注意的是，activeexpirecycle函数不会试图一次性处理redis中的所有数据库，而是最多只处理redis_dbcron_dbs_per_call（默认值为16），此外activeexpirecycle函数还有处理时间上的限制，不是想执行多久就执行多久，凡此种种都只有一个目的，那就是避免失效主键删除占用过多的cpu资源。代码段五有对activeexpirecycle所有代码的详细描述，从中可以了解该函数的具体实现方法。
代码段五：
void activeexpirecycle(void) {
因为每次调用activeexpirecycle函数不会一次性检查所有redis数据库，所以需要记录下
每次函数调用处理的最后一个redis数据库的编号，这样下次调用activeexpirecycle函数
还可以从这个数据库开始继续处理，这就是current_db被声明为static的原因，而另外一
个变量timelimit_exit是为了记录上一次调用activeexpirecycle函数的执行时间是否达
到时间限制了，所以也需要声明为static
static unsigned int current_db = 0;
static int timelimit_exit = 0;
unsigned int j, iteration = 0;
每次调用activeexpirecycle函数处理的redis数据库个数为redis_dbcron_dbs_per_call
unsigned int dbs_per_call = redis_dbcron_dbs_per_call;
long long start = ustime(), timelimit;
如果当前redis服务器中的数据库个数小于redis_dbcron_dbs_per_call，则处理全部数据库，
如果上一次调用activeexpirecycle函数的执行时间达到了时间限制，说明失效主键较多，也
会选择处理全部数据库
if (dbs_per_call > server.dbnum || timelimit_exit)
dbs_per_call = server.dbnum;
执行activeexpirecycle函数的最长时间（以微秒计），其中redis_expirelookups_time_perc
是单位时间内能够分配给activeexpirecycle函数执行的cpu时间比例，默认值为25，server.hz
即为一秒内activeexpirecycle的调用次数，所以这个计算公式更明白的写法应该是这样的，即
(1000000 * (redis_expirelookups_time_perc / 100)) / server.hz
timelimit = 1000000*redis_expirelookups_time_perc/server.hz/100;
timelimit_exit = 0;
if (timelimit <= 0) timelimit = 1;
遍历处理每个redis数据库中的失效数据
for (j = 0; j < dbs_per_call; j++) {
int expired;
redisdb *db = server.db+(current_db % server.dbnum);
此处立刻就将current_db加一，这样可以保证即使这次无法在时间限制内删除完所有当前
数据库中的失效主键，下一次调用activeexpirecycle一样会从下一个数据库开始处理，
从而保证每个数据库都有被处理的机会
current_db++;
开始处理当前数据库中的失效主键
do {
unsigned long num, slots;
long long now;
如果expires字典表大小为0，说明该数据库中没有设置失效时间的主键，直接检查下
一数据库
if ((num = dictsize(db->expires)) == 0) break;
slots = dictslots(db->expires);
now = mstime();
如果expires字典表不为空，但是其填充率不足1%，那么随机选择主键进行检查的代价
会很高，所以这里直接检查下一数据库
if (num && slots > dict_ht_initial_size &&
(num*100/slots < 1)) break;
expired = 0;
如果expires字典表中的entry个数不足以达到抽样个数，则选择全部key作为抽样样本
if (num > redis_expirelookups_per_cron)
num = redis_expirelookups_per_cron;
while (num--) {
dictentry *de;
long long t;
随机获取一个设置了失效时间的主键，检查其是否已经失效
if ((de = dictgetrandomkey(db->expires)) == null) break;
t = dictgetsignedintegerval(de);
if (now > t) {
发现该主键确实已经失效，删除该主键
sds key = dictgetkey(de);
robj *keyobj = createstringobject(key,sdslen(key));
同样要在删除前广播该主键的失效信息
propagateexpire(db,keyobj);
dbdelete(db,keyobj);
decrrefcount(keyobj);
expired++;
server.stat_expiredkeys++;
}
}
每进行一次抽样删除后对iteration加一，每16次抽样删除后检查本次执行时间是否
已经达到时间限制，如果已达到时间限制，则记录本次执行达到时间限制并退出
iteration++;
if ((iteration & 0xf) == 0 &&
(ustime()-start) > timelimit)
{
timelimit_exit = 1;
return;
如果失效的主键数占抽样数的百分比大于25%，则继续抽样删除过程
} while (expired > redis_expirelookups_per_cron/4);
）！
四、redis的主键失效机制会不会影响系统性能？通过以上对redis主键失效机制的介绍，我们知道虽然redis会定期地检查设置了失效时间的主键并删除已经失效的主键，但是通过对每次处理数据库个数的限制、activeexpirecycle函数在一秒钟内执行次数的限制、分配给activeexpirecycle函数cpu时间的限制、继续删除主键的失效主键数百分比的限制，redis已经大大降低了主键失效机制对系统整体性能的影响，但是如果在实际应用中出现大量主键在短时间内同时失效的情况还是会使得系统的响应能力降低，所以这种情况无疑应该避免。
<a href="http://www.cnblogs.com/tangtianfly/archive/2012/05/02/2479315.html">http://www.cnblogs.com/tangtianfly/archive/2012/05/02/2479315.html</a>
原文链接:[http://wely.iteye.com/blog/2361617]