AOF 持久化的实现¶
AOF 持久化功能的实现可以分为命令追加（append）、文件写入、文件同步（sync）三个步骤。
命令追加¶
当 AOF 持久化功能处于打开状态时，
服务器在执行完一个写命令之后，
会以协议格式将被执行的写命令追加到服务器状态的 aof_buf 缓冲区的末尾：
struct redisServer {
// ...
// AOF 缓冲区
sds aof_buf;
// ...
};
举个例子， 如果客户端向服务器发送以下命令：
redis> SET KEY VALUE
OK
那么服务器在执行这个 SET 命令之后，
会将以下协议内容追加到 aof_buf 缓冲区的末尾：
*3\r\n$3\r\nSET\r\n$3\r\nKEY\r\n$5\r\nVALUE\r\n
又比如说， 如果客户端向服务器发送以下命令：
redis> RPUSH NUMBERS ONE TWO THREE
(integer) 3
那么服务器在执行这个 RPUSH 命令之后，
会将以下协议内容追加到 aof_buf 缓冲区的末尾：
*5\r\n$5\r\nRPUSH\r\n$7\r\nNUMBERS\r\n$3\r\nONE\r\n$3\r\nTWO\r\n$5\r\nTHREE\r\n
以上就是 AOF 持久化的命令追加步骤的实现原理。
AOF 文件的写入与同步¶
Redis 的服务器进程就是一个事件循环（loop），
这个循环中的文件事件负责接收客户端的命令请求，
以及向客户端发送命令回复，
而时间事件则负责执行像 serverCron 函数这样需要定时运行的函数。
因为服务器在处理文件事件时可能会执行写命令，
使得一些内容被追加到 aof_buf 缓冲区里面，
所以在服务器每次结束一个事件循环之前，
它都会调用 flushAppendOnlyFile 函数，
考虑是否需要将 aof_buf 缓冲区中的内容写入和保存到 AOF 文件里面，
这个过程可以用以下伪代码表示：
def eventLoop():
while True:
# 处理文件事件，接收命令请求以及发送命令回复
# 处理命令请求时可能会有新内容被追加到 aof_buf 缓冲区中
processFileEvents()
# 处理时间事件
processTimeEvents()
# 考虑是否要将 aof_buf 中的内容写入和保存到 AOF 文件里面
flushAppendOnlyFile()
flushAppendOnlyFile 函数的行为由服务器配置的 appendfsync 选项的值来决定，
各个不同值产生的行为如表 TABLE_APPENDFSYNC 所示。
|
|
|---|---|
|
将 |
|
将 |
|
将 |
如果用户没有主动为 appendfsync 选项设置值，
那么 appendfsync 选项的默认值为 everysec ，
关于 appendfsync 选项的更多信息，
请参考 Redis 项目附带的示例配置文件 redis.conf 。
举个例子， 假设服务器在处理文件事件期间， 执行了以下三个写入命令：
SADD databases "Redis" "MongoDB" "MariaDB"SET date "2013-9-5"INCR click_counter 10086
那么 aof_buf 缓冲区将包含这三个命令的协议内容：
*5\r\n$4\r\nSADD\r\n$9\r\ndatabases\r\n$5\r\nRedis\r\n$7\r\nMongoDB\r\n$7\r\nMariaDB\r\n
*3\r\n$3\r\nSET\r\n$4\r\ndate\r\n$8\r\n2013-9-5\r\n
*3\r\n$4\r\nINCR\r\n$13\r\nclick_counter\r\n$5\r\n10086\r\n
如果这时 flushAppendOnlyFile 函数被调用，
假设服务器当前 appendfsync 选项的值为 everysec ，
并且根据 server.aof_last_fsync 属性显示，
距离上次同步 AOF 文件已经超过一秒钟，
那么服务器会先将 aof_buf 中的内容写入到 AOF 文件中，
然后再对 AOF 文件进行同步。
以上就是对 AOF 持久化功能的文件写入和文件同步这两个步骤的介绍。