redis学习笔记——expire、pexpire、expireat、pexpireat的执行过程

在了解过期键问题前我们首先需要对redis的数据库和数据库键空间有一定的了解:

struct redisServer {
    // ...
    // 一个数组,保存着服务器中的所有数据库
    redisDb *db;

  //服务器的数据库数量,dbnum属性的值由服务器配置的database选项决定,默认情况下,该选项的值为16
    int dbnum;

// ...
};

在服务器内部,客户端状态redisClient结构的db属性记录了客户端当前的目标数据库,这个属性是一个指向redisDb结构的指针:

typedef struct redisClient {
// ...
// 记录客户端当前正在使用的数据库
redisDb *db;
// ...
} redisClient;

现在我们再来看看redisDb 结构,redisDb结构的dict字典保存了数据库中的所有键值对,我们将这个字典称为键空间(key space):

typedef struct redisDb {
    // ...
    // 
数据库键空间,保存着数据库中的所有键值对
    dict *dict;
    // ...
} redisDb;

  • 键空间的键也就是数据库的键,每个键都是一个字符串对象
  • 键空间的值也就是数据库的值,每个值可以是字符串对象、列表对象、哈希表对象、集合对象和有序集合对象中的任意一种Redis对象

下面是一个例子:

根据这个键空间,执行相关的添加、删除、更新等操作的便可以比较容易理解,我们此处也忽略不讲了。

下面我们再来介绍一下redisDb结构中的另外一个字典expires,这个字典保存了数据库中所有键的过期时间,我们称这个字典为过期字典(注意这里面只保存着键的过期时间,可不是说这个字典里面的键都是过期的):

  • 过期字典的键是一个指针,这个指针指向键空间中的某个键对象(也即是某个数据库键);
  • 过期字典的值是一个long long类型的整数,这个整数保存了键所指向的数据库键的过期时间——一个毫秒精度的UNIX时间戳;

有了上面的知识我们下载便可以来看看四个命令:expire、pexpire、expireat、pexpireat的实现过程。

四个命令的使用是比较简单的:EXPIRE <key> <seconds> 如:EXPIRE book 100

              PEXPIRE <key> <millionseconds>

              EXPIREAT <key> <timemap>

              PEXPIREAT <key> <timemap> 如:PEXPIREAT book 1388556000000(2014年1月1日零时)其实我也不知道这是怎么算出来的!!!

注意:利用PERSIST命令可以移除一个键的过期时间。

如:redis> PEXPIREAT message 1391234400000
(integer) 1

其他的命令类似。不过值得一提的是:EXPIRE、EXPIREAT、PEXPIRE全部是转换成PEXPIREAT来实现的。下面来看看每个命令的实现函数:

void expireCommand(redisClient *c) {
expireGenericCommand(c,mstime(),UNIT_SECONDS);
}
void expireatCommand(redisClient *c) {
expireGenericCommand(c,0,UNIT_SECONDS);
}
void pexpireCommand(redisClient *c) {
expireGenericCommand(c,mstime(),UNIT_MILLISECONDS);
}
void pexpireatCommand(redisClient *c) {
expireGenericCommand(c,0,UNIT_MILLISECONDS);
}

他们都调用了expireGenericCommand()函数进行实现,那我们现在就来分析一下expireGenericCommand函数是怎么实现的:

/*-----------------------------------------------------------------------------
 * Expires Commands
 *----------------------------------------------------------------------------*/

/* This is the generic command implementation for EXPIRE, PEXPIRE, EXPIREAT
 * and PEXPIREAT. Because the commad second argument may be relative or absolute
 * the "basetime" argument is used to signal what the base time is (either 0
 * for *AT variants of the command, or the current time for relative expires).
 *
 * 这个函数是 EXPIRE 、 PEXPIRE 、 EXPIREAT 和 PEXPIREAT 命令的底层实现函数。
 * 命令的第二个参数可能是绝对值,也可能是相对值。
 * 当执行 *AT 命令时, basetime 为 0 ,在其他情况下,它保存的就是当前的绝对时间。
 *
 * unit is either UNIT_SECONDS or UNIT_MILLISECONDS, and is only used for
 * the argv[2] parameter. The basetime is always specified in milliseconds.
 *
 * unit 用于指定 argv[2] (传入过期时间)的格式,
 * 它可以是 UNIT_SECONDS 或 UNIT_MILLISECONDS ,
 * basetime 参数则总是毫秒格式的。
 */
void expireGenericCommand(redisClient *c, long long basetime, int unit) {
    robj *key = c->argv[1], *param = c->argv[2];
    long long when; /* unix time in milliseconds when the key will expire. */
    // 取出param中的整数值或者尝试将param中的数据尽可能转换成整数值存在when中,成功返回REDIS_OK失败则返回REDIS_ERR
    if (getLongLongFromObjectOrReply(c, param, &when, NULL) != REDIS_OK)
        return;
    // 如果传入的过期时间是以秒为单位的,那么将它转换为毫秒
    if (unit == UNIT_SECONDS) when *= 1000;
    when += basetime;

    /* No key, return zero. */
    // 查询一下该键是否存在
    if (lookupKeyRead(c->db,key) == NULL) {
        addReply(c,shared.czero);
        return;
    }
    /* EXPIRE with negative TTL, or EXPIREAT with a timestamp into the past
     * should never be executed as a DEL when load the AOF or in the context
     * of a slave instance.
     *
     * 在载入AOF数据时,或者服务器为附属节点时,
     * 即使 EXPIRE 的 TTL 为负数,或者 EXPIREAT 提供的时间戳已经过期,
     * 服务器也不会主动删除这个键,而是等待主节点发来显式的 DEL 命令。
     *
     * Instead we take the other branch of the IF statement setting an expire
     * (possibly in the past) and wait for an explicit DEL from the master.
     *
     * 程序会继续将(一个可能已经过期的 TTL)设置为键的过期时间,
     * 并且等待主节点发来 DEL 命令。
     */
    if (when <= mstime() && !server.loading && !server.masterhost) {
        // when 提供的时间已经过期,服务器为主节点(注意主服务器的masterhost==NULL),并且没在载入数据
        robj *aux;
        //删除该键
        redisAssertWithInfo(c,key,dbDelete(c->db,key));
        server.dirty++;

        /* Replicate/AOF this as an explicit DEL. */
        // 传播 DEL 命令到AOF或者从服务器
        aux = createStringObject("DEL",3);
        //修改客户端的参数数组
        rewriteClientCommandVector(c,2,aux,key);
        decrRefCount(aux);

        //信号:键值已经改变了。调用touchWatchedKey(db,key)
        signalModifiedKey(c->db,key);
        //发送键空间通知和键事件通知
        notifyKeyspaceEvent(REDIS_NOTIFY_GENERIC,"del",key,c->db->id);

        addReply(c, shared.cone);

        return;
    } else {
        // 设置键的过期时间
        // 如果服务器为附属节点,或者服务器正在载入,
        // 那么这个 when 有可能已经过期的
        setExpire(c->db,key,when);

        addReply(c,shared.cone);

        signalModifiedKey(c->db,key);
        notifyKeyspaceEvent(REDIS_NOTIFY_GENERIC,"expire",key,c->db->id);
        server.dirty++;
        return;
    }
}

下面我将对自己在看代码时里面不太熟悉的几个函数进行说明:

  • getLongLongFromObjectOrReply(redisClient *c,robj *o,long long *target,const char *msg)

函数目的:尝试从对象o中取出整数值,或者尝试将对象o中的值换成整数值,并将得到的值保存在target中。同时如果转换取出/转成功的话,返回REDIS_OK,否则返回REDIS_ERR,并向客户端发送一条出错回复。

大致实现过程: getLongLongFromObjectOrReply——>getLongLongFromObject——>stroll()最后主要看看stoll函数的实现过程就OK了。

  • lookupKeyRead(redisDb *db,robj *key)

函数目的:为执行读取操作而取出键key在数据库中的值。并根据是否成功找到值,更新服务器中的命中和不命中信息。找搞则返回值,没找到则返回NULL

函数实现

  • rewriteClientCommandVector(redisClient *c,int argc,...)

函数目的:修改客户端的参数数组。这其中涉及到C语言可变参数的运用,可以自行学习。

函数实现:如果理解了C语言的可变参数的大致运用的话,函数的实现过程已经大致理解了。其中需要注意的是lookupCommandOrOriginal()函数,lookupCommandOrOriginal()目的是在命令被更名之后,将更名后正确的redisCommand进行返回。

  • signalModifiedKey(c->db,key)键值已经改变了的信号。调用touchWatchedKey(db,key)(“触碰”一个键,如果这个键在某个客户端watch下,那这个客户端执行的EXEC时事务将失败)
  • notifyKeyspaceEvent(REDIS_NOTIFY_GENERIC,"del",key,c->db->id) 发送键空间通知和键事件通知(该部分知识今后会提到)

这里主要讲的Redis是怎么样设置过期键的,可以算作后续"Redis过期键的删除策略"的前篇或者说预备知识。

时间: 2024-08-07 00:14:23

redis学习笔记——expire、pexpire、expireat、pexpireat的执行过程的相关文章

Redis学习笔记

Redis学习笔记:Redis是什么?redis是开源BSD许可高级的key-vlue存储系统可以用来存储字符串哈希结构链表.结构.集合,因此常用来提供数据结构服务. redis和memcache相比的独特之处:1.redis可以用来做存储,而memcache是用来做缓存 这个特点主要因为其有"持久化"的功能.2.存储的数据有"结构",对于memcache来说,存储的数据只有1种类型"字符串"而 redis则可以存储字符串.链表.哈希机构.集合.

Redis学习笔记4-Redis配置具体解释

在Redis中直接启动redis-server服务时, 採用的是默认的配置文件.採用redis-server   xxx.conf 这种方式能够依照指定的配置文件来执行Redis服务. 依照本Redis学习笔记中Redis的依照方式依照后,Redis的配置文件是/etc/redis/6379.conf.以下是Redis2.8.9的配置文件各项的中文解释. #daemonize no 默认情况下, redis 不是在后台运行的.假设须要在后台运行,把该项的值更改为 yes daemonize ye

Redis学习笔记4-Redis配置详解

原文:  http://blog.csdn.net/mashangyou/article/details/24555191 在Redis中直接启动redis-server服务时, 采用的是默认的配置文件.采用redis-server   xxx.conf 这样的方式可以按照指定的配置文件来运行Redis服务.按照本Redis学习笔记中Redis的按照方式按照后,Redis的配置文件是/etc/redis/6379.conf.下面是Redis2.8.9的配置文件各项的中文解释. 1 #daemon

(转)redis 学习笔记(1)-编译、启动、停止

redis 学习笔记(1)-编译.启动.停止 一.下载.编译 redis是以源码方式发行的,先下载源码,然后在linux下编译 1.1 http://www.redis.io/download 先到这里下载Stable稳定版,目前最新版本是2.8.17 1.2 上传到linux,然后运行以下命令解压 tar xzf redis-2.8.17.tar.gz 1.3 编译 cd redis-2.8.17make 注:make命令需要linux上安装gcc,若机器上未安装gcc,redhat环境下,如

Redis学习笔记~目录

redis是一个key-value存储系统.和Memcached类似,它支持存储的value类型相对更多,包括string(字符串).list(链表).set(集合).zset(sorted set --有序集合)和hashs(哈希类型).这些数据类型都 支持push/pop.add/remove及取交集并集和差集及更丰富的操作,而且这些操作都是原子性的.在此基础上,redis支持各种不同方式的排 序.与memcached一样,为了保证效率,数据都是缓存在内存中.区别的是redis会周期性的把更

Redis学习笔记7--Redis管道(pipeline)

redis是一个cs模式的tcp server,使用和http类似的请求响应协议.一个client可以通过一个socket连接发起多个请求命令.每个请求命令发出后client通常会阻塞并等待redis服务处理,redis处理完后请求命令后会将结果通过响应报文返回给client.基本的通信过程如下: Client: INCR X Server: 1 Client: INCR X Server: 2 Client: INCR X Server: 3 Client: INCR X Server: 4

Redis学习笔记(简单了解与运行)

Redis学习笔记(简单了解与运行) 开源的非关系型数据库 是REmote Dictionary Server(远程字典服务器)的缩写,以字典结构存储数据 允许其他应用通过TCP协议读写字典中的内容. Redis支持存储的键值数据类型 字符串类型 散列类型 列表类型 集合类型 有序集合类型 Redis的特性 通过一个列子看出Mysql和Redis的存储区别 例如: (存储一篇文章,文章包括:标题(title),正文(content),阅读量(views),标签(tags)) 需求: 把数据存储在

Redis学习笔记(增删查)

Redis学习笔记(增删查) 向数据库中添加一个键 SET key value 获取数据库中的key KEYS pattern pattern支持glob风格通配符格式 " ? " 匹配一个字符 " * " 匹配任意字符 " [] " 匹配括号间的任一字符,可以使用" - "符号表示一个范围,例如:a[a-z]c " \x " 匹配字符x,用于转义字符.如需要匹配"?",就需要用 \?

gcc 学习笔记(一) - 编译C程序 及 编译过程

一. C程序编译过程 编译过程简介 : C语言的源文件 编译成 可执行文件需要四个步骤, 预处理 (Preprocessing) 扩展宏, 编译 (compilation) 得到汇编语言, 汇编 (assembly) 得到机器码, 连接 (linking) 得到可执行文件; -- 查看每个步骤的编译细节 : "-E" 对应 预处理, "-S" 对应 编译, "-c" 对应 汇编, "-O" 对应 连接; -- 每个步骤对应的工