redis源代码分析17–持久化之快照

redis的持久化支持快照方式。快照方式会将整个db dump到磁盘上。 client 可以发布save/bgsave命令让server将db dump到磁盘上。其中bgsave会执行后台dump（新建子进程执行dump），而save是阻塞式的dump db，会影响其他client的命令执行。除了发布命令执行快照

redis的持久化支持快照方式。快照方式会将整个db dump到磁盘上。

client 可以发布save/bgsave命令让server将db dump到磁盘上。其中bgsave会执行后台dump（新建子进程执行dump），而save是阻塞式的dump db，会影响其他client的命令执行。除了发布命令执行快照保存外，redis的servercron也会按照配置的参数执行后台dump，另外 slave建立连接时，master也会执行一个后台dump，然后才发送数据给slave（这在主从复制一节中介绍）。

static int servercron(struct aeeventloop *eventloop, long long id, void *clientdata) {
    ---
/* check if a background saving or aof rewrite in progress terminated */
    if (server.bgsavechildpid != -1 || server.bgrewritechildpid != -1) {
      ---
    }
else {
        /* if there is not a background saving in progress check if
         * we have to save now */
         time_t now = time(null);
         for (j = 0; j < server.saveparamslen; j++) {
            struct saveparam *sp = server.saveparams+j;
            if (server.dirty >= sp->changes &&
                now-server.lastsave > sp->seconds) {
                redislog(redis_notice,"%d changes in %d seconds. saving...",
                    sp->changes, sp->seconds);
                rdbsavebackground(server.dbfilename);
                break;
            }
         }
}
---
}

无论是新建子进程还是阻塞式的执行快照方式（新建子进程方式会先调用rdbsavebackground），最终都会调用rdbsave来保存db。

在rdbsave中可以看到，redis是按type、key、val方式来保存db中的数据的。

rdbload是快照方式保存数据后server启动时加载数据的函数，是rdbsave的逆过程。

static int rdbsave(char *filename) {
    ---
    for (j = 0; j < server.dbnum; j++) {
        redisdb *db = server.db+j;
       ---
        /* iterate this db writing every entry */
        while((de = dictnext(di)) != null) {
            robj *key = dictgetentrykey(de);
            robj *o = dictgetentryval(de);
            time_t expiretime = getexpire(db,key);
            ---
            /* save type, key, value */
           if (rdbsavetype(fp,o->type) == -1) goto werr;
          if (rdbsavestringobject(fp,key) == -1) goto werr;
          if (rdbsaveobject(fp,o) == -1) goto werr;
          ---
        }
        dictreleaseiterator(di);
    }
    ---
    /* use rename to make sure the db file is changed atomically only
     * if the generate db file is ok. */
    if (rename(tmpfile,filename) == -1) {
        redislog(redis_warning,"error moving temp db file on the final destination: %s", strerror(errno));
        unlink(tmpfile);
        return redis_err;
    }
    ---
}

【说明】：本文章由站长整理发布，文章内容不代表本站观点，如文中有侵权行为，请与本站客服联系(QQ:)！