为什么需要Redis持久化？

redis本身是内存数据库，数据都是存储在操作系统内存中的，那么就会存在当进程退出或者服务断电等情况下内存数据丢失的问题，所以redis就需要提供某种持久化方案用来把内存中的数据保存到磁盘上，用以解决内存数据丢失的问题。

持久化的几种方式？

一提到持久化，不仅仅是Redis，基本上所有的持久化方案都会采用“快照”和“日志”这个两种方式，快照是一种定时生成的方式，而日志则更倾向于实时产生，（redis4.0开始支持了快照和日志的混合模式）

Redis中的RDB

本文先介绍Redis中的第一种持久化方案—RDB，这就是基于“快照”的方式完成持久化的。

在redis中既可以手动执行命令触发rdb，也可以通过服务端的配置选择定时触发rdb，rdb执行结束后生成一个经过压缩的二进制.rdb文件，还原时再通过这个rdb文件进行恢复。

触发rdb的命令

在redis中提供了两种命令可以生成rdb文件，一个是save，一个bgsave。

执行save命令后会阻塞服务端进程，直到RDB文件创建完毕为止，在整个RDB文件生成过程中服务器不能处理任何命令请求，所以一般情况下我们不会使用save命令触发rdb持久化。

而bgsave则是会fork出一个子进程，父进程继续处理客户端发来的命令请求，子进程写入完成时，用新的rdb替换旧的rdb，并删除旧的rdb文件，整个过程只是调用fork函数时会阻塞。

save命令执行后的日志信息

1264:M 02 Nov 2020 14:19:37.547 * DB saved on disk

bgsave命令执行后的日志信息，可以明显看出多出了有一个1289的进程。

1264:M 02 Nov 2020 14:19:49.731 * Background saving started by pid 12891289:C 02 Nov 2020 14:19:49.739 * DB saved on disk1289:C 02 Nov 2020 14:19:49.739 * RDB: 4 MB of memory used by copy-on-write1264:M 02 Nov 2020 14:19:49.743 * Background saving terminated with success

rdb的自动触发配置

在conf配置文件中，找到如下的配置项，文档已经描述的非常详细，以下这段配置表示的含义如下：

save 900 1：900秒之内，对数据库至少修改了1次。

save 300 10：300秒之内，对数据库至少修改了10次。

save 60 10000：60秒之内，对数据库至少修改了10000次。

只要满足三个条件中任意一个，就会触发bgsave。

在这里插入图片描述

bgsave运行流程

在这里插入图片描述

源码入口

save

int rdbSave(char *filename, rdbSaveInfo *rsi) {
       char tmpfile[256];    char cwd[MAXPATHLEN]; /* Current working dir path for error messages. */    FILE *fp;    rio rdb;    int error = 0;    snprintf(tmpfile,256,"temp-%d.rdb", (int) getpid());    fp = fopen(tmpfile,"w");    if (!fp) {
           char *cwdp = getcwd(cwd,MAXPATHLEN);        serverLog(LL_WARNING,            "Failed opening the RDB file %s (in server root dir %s) "            "for saving: %s",            filename,            cwdp ? cwdp : "unknown",            strerror(errno));        return C_ERR;    }    rioInitWithFile(&rdb,fp);    startSaving(RDBFLAGS_NONE);    if (server.rdb_save_incremental_fsync)        rioSetAutoSync(&rdb,REDIS_AUTOSYNC_BYTES);    if (rdbSaveRio(&rdb,&error,RDBFLAGS_NONE,rsi) == C_ERR) {
           errno = error;        goto werr;    }    /* Make sure data will not remain on the OS's output buffers */    if (fflush(fp) == EOF) goto werr;    if (fsync(fileno(fp)) == -1) goto werr;    if (fclose(fp) == EOF) goto werr;    /* Use RENAME to make sure the DB file is changed atomically only     * if the generate DB file is ok. */    if (rename(tmpfile,filename) == -1) {
           char *cwdp = getcwd(cwd,MAXPATHLEN);        serverLog(LL_WARNING,            "Error moving temp DB file %s on the final "            "destination %s (in server root dir %s): %s",            tmpfile,            filename,            cwdp ? cwdp : "unknown",            strerror(errno));        unlink(tmpfile);        stopSaving(0);        return C_ERR;    }    serverLog(LL_NOTICE,"DB saved on disk");    server.dirty = 0;    server.lastsave = time(NULL);    server.lastbgsave_status = C_OK;    stopSaving(1);    return C_OK;werr:    serverLog(LL_WARNING,"Write error saving DB on disk: %s", strerror(errno));    fclose(fp);    unlink(tmpfile);    stopSaving(0);    return C_ERR;}

bgsave

int rdbSaveBackground(char *filename, rdbSaveInfo *rsi) {
       pid_t childpid;    if (hasActiveChildProcess()) return C_ERR;    server.dirty_before_bgsave = server.dirty;    server.lastbgsave_try = time(NULL);    openChildInfoPipe();    if ((childpid = redisFork()) == 0) {
           int retval;        /* Child */        redisSetProcTitle("redis-rdb-bgsave");        redisSetCpuAffinity(server.bgsave_cpulist);        retval = rdbSave(filename,rsi);        if (retval == C_OK) {
               sendChildCOWInfo(CHILD_INFO_TYPE_RDB, "RDB");        }        exitFromChild((retval == C_OK) ? 0 : 1);    } else {
           /* Parent */        if (childpid == -1) {
               closeChildInfoPipe();            server.lastbgsave_status = C_ERR;            serverLog(LL_WARNING,"Can't save in background: fork: %s",                strerror(errno));            return C_ERR;        }        serverLog(LL_NOTICE,"Background saving started by pid %d",childpid);        server.rdb_save_time_start = time(NULL);        server.rdb_child_pid = childpid;        server.rdb_child_type = RDB_CHILD_TYPE_DISK;        return C_OK;    }    return C_OK; /* unreached */}