追溯Redis源码记忆中的日志（redis 源码日志）

追溯Redis源码：记忆中的日志

Redis是一种高性能的NoSQL数据库，已经被广泛应用于各种应用场景中。作为一名Redis开发者，有必要深入了解其源码。本文将聚焦于Redis中的日志系统，即“AOF”(Append-only file)和“RDB”(Redis Database Backup)。

AOF

AOF是Redis的一个重要特性，用于记录每个写入操作，即使它也已经在内存中执行了。使用AOF，Redis可以在灾难恢复时可靠地重建数据库。AOF文件以追加方式构建，记录所有写入操作。当Redis需要恢复数据时，它会按顺序重放AOF文件中的操作。

让我们仔细观察一下Redis源码中关于AOF的实现。在redis/src/aof.c文件中，我们可以看到如下实现：

int flushAppendOnlyFile(int force) {
    if (aof_current_size == 0) return REDIS_OK;
    if (!aof_fsync && !force) {
        if (aof_buf && sdslen(aof_buf) == 0) return REDIS_OK;
    } else {
        ssize_t nwritten;
        /* Write the buffer at AOF startup or AOF re-write time. */
        if (aof_rewrite_buf && aof_rewrite_bufpos > 0) {
            nwritten = write(server.aof_rewrite_fd,
                aof_rewrite_buf,aof_rewrite_bufpos);
            aof_rewrite_bytes += nwritten;
            if (nwritten != aof_rewrite_bufpos) goto werr;
            aof_rewrite_bufpos = 0;
            /* Since we just wrote some data to disk, if we have a pending
             * AOF fsync it's now safe to perform it. */
            if (aof_fsync == AOF_FSYNC_ALWAYS) aof_fsync_range();
        }
        if (aof_buf && sdslen(aof_buf) > 0) {
            nwritten = write(server.aof_fd,aof_buf,sdslen(aof_buf));
            if (nwritten != (ssize_t)sdslen(aof_buf))) {
                redisLog(REDIS_WARNING,"Error writing to appending file: %s",
                    strerror(errno));
                goto werr;
            }
            if (nwritten == -1) {
                /* Note that we will not exit the function before trying to
                 * flush the data that may be in the aof_rewrite_buf. */
                aof_last_write_status = REDIS_ERR;
            } else {
                aof_last_write_status = REDIS_OK;
            }
            aof_current_size += nwritten;
            sdsrange(aof_buf,nwritten,-1);
        }
    }
}

AOF文件的写入由flushAppendOnlyFile()函数实现。在空AOF文件中，aof_current_size变量的值为0，会直接返回REDIS_OK。接下来，函数会检查是否有新的数据需要写入AOF文件。如果没有新的写入数据，且aof_fsync标志没有开启，函数返回REDIS_OK。一旦有数据需要写入，函数会执行如下操作：

1. 如果有重写缓存，写入AOF重写缓存。

2. 如果有AOF缓存，将AOF缓存写入磁盘。

3. 如果一次写入是错误的，将把aof_last_write_status设置成REDIS_ERR。

RDB

RDB是另一种记录Redis市场活动的方法，类似于“快照”(snapshot)。使用RDB，Redis可以在恢复时将整个数据库快速地载入到内存中。默认情况下，Redis每隔一段时间就会自动创建一个快照(RDB文件)。在一段时间内，Redis将把所有的写入市场活动保存到内存中，然后使用fork()系统调用从一个子进程中创建RDB文件，而不会停止主进程。

Redis的RDB实现在redis/src/rdb.c文件中。以下是一个基本的创建快照的示例：

ssize_t rdbSave(char *filename) {
    char tmpfile[256];
    rio rdb;
    FILE *fp;
    time_t start;
    snprintf(tmpfile,256,"temp-%d.rdb", (int) getpid(), (int) time(NULL));

    fp = fopen(tmpfile,"w");
    if (!fp) {
        redisLog(REDIS_WARNING,"Fled opening .rdb for saving: %s",
            strerror(errno));
        return REDIS_ERR;
    }
    rioInitWithFile(&rdb,fp);
    if (rdbSaveRio(&rdb) == -1) {
        fclose(fp);
        server.dirty++;
        unlink(tmpfile);
        return REDIS_ERR;
    }
    if (fflush(fp) == -1) {
        fclose(fp);
        server.dirty++;
        unlink(tmpfile);
        return REDIS_ERR;
    }
    if (fsync(fileno(fp)) == -1) {
        fclose(fp);
        server.dirty++;
        unlink(tmpfile);
        return REDIS_ERR;
    }
    fclose(fp);
    if (rename(tmpfile,filename) == -1) {
        redisLog(REDIS_WARNING,"Fled saving .rdb: %s",
            strerror(errno));
        unlink(tmpfile);
        return REDIS_ERR;
    }
    redisLog(REDIS_NOTICE,"DB saved on disk");
    server.dirty = 0;
}

这是一个将快照保存到磁盘的示例。在temp中，Redis会生成一个临时文件名，并使用文件指针来打开文件进行写入。使用rioInitWithFile函数，将rdb与该文件关联，以便Redis可以将数据转储到该文件中。使用rename()函数将临时文件重命名为指定文件名。这将在一切顺利的情况下将快照保存到磁盘上。如果有问题，函数将返回REDIS_ERR，并删除临时文件。

结论

通过分析Redis中的日志系统，在某种程度上可以了解Redis如何管理市场活动及遇到问题时如何解决。这种深入了解对Redis开发者来说非常有用。我们敦促你花点时间研究一下Redis源代码，以便更好地理解它在管理数据方面的工作原理。