1,前言
Redis 是内存数据库,数据库状态存储在内存中,为了进行数据持久化,需要将这些数据保存在磁盘中。因此Redis 提供了RDB 持久化功能。
RDB 持久化既可以手动执行,也可以根据服务器配置选项定期执行,该功能可以将某个时间点上的数据库状态保存到一个RDB 文件中。
RDB 持久化所生成的RDB 文件是一个二进制文件,通过该文件还可以还原生成RDB 文件时的数据库状态
2,RDB持久化
2.1,RDB文件的创建与载入
有两个命令可以用于生成RDB 文件,一个是SAVE ,另一个是BGSAVE
两者的区别在于:
SAVE 命令会阻塞Redis 服务器进程,直到RDB 文件创建完毕,在阻塞期间,服务器不能处理任何命令请求BGSAV E命令会派生出一个子进程,由子进程负责创建RDB 文件,服务器进程(父进程)继续处理请求
SAVE 和BGSAVE 命令如下:
def SAVE():
# 创建RDB文件
rdbSave()
def BGSAVE():
# 创建子进程
pid=fork()
# 如果是子进程
if pid==0:
# 子进程负责创建RDB文件
rdbSave()
# 完成之后向父进程发送信号
signal_parent()
# 如果是父进程
else pid>0:
# 父进程继续处理命令请求,并通过轮询等待子进程的信号
handle_request_and_wait_signal()
else:
# 处理出错情况
handle_fork_error()
SAVE 和BGSAVE 命令是负责创建RDB 文件的,至于载入RDB 文件,Redis 并没有提供命令,只要Redis 服务器在启动时检测到RDB 文件存在,就会自动载入
值得一提的是,由于AOF 文件的更新频率会比RDB 文件的更新频率高(越高代表着数据丢失的越少),所以:
- 如果服务器开启了
AOF 持久化功能,那么服务器会优先使用AOF 文件来还原数据 - 只有在
AOF 持久化功能处于关闭状态时,服务器才会使用RDB 文件进行还原
BGSAVE命令执行时的服务器状态
在BGSAVE 命令执行期间,服务器处理SAVE、BGSAVE、BGREWRITEAOF 三个命令的方式会和平时有所不同
- 执行
BGSAVE 时,客户端发送的SAVE 命令会被拒绝,是因为避免父进程(服务器进程)和子进程同时执行两个rdbSave() ,为了防止产生竞争条件 - 在
BGSAVE 命令期间,客户端发送的BGSAVE 命令会被服务器拒绝,因为同时执行两个BGSAVE 命令也会产生竞争条件 BGREWRITEAOF 和BGSAVE 两个命令不能同时执行:
- 如果
BGSAVE 正在执行,那么客户端发送的BGREWRITEAOF 命令会被延迟到BGSAVE 执行完毕后执行 - 如果
BGREWRITEAOF 正在执行,那么客户端发送的BGSAVE 命令会被服务器拒绝
因为BGREWIRTEAOF 和BGSAVE 两个命令的执行实际工作都由子进程执行,所以这两个命令在操作方面并没有什么冲突的地方,之所以不允许同时执行只是一个性能方面的考虑
2.2,自动间隔性保存
用户可以通过save 选项设置多个保存条件,只要其中任意一个条件被满足,服务器就会执行BGSAVE 命令
例如向服务器提供以下配置:
save 900 1
save 300 10
save 60 10000
服务器会根据save 选项所设置的保存条件,设置服务器状态redisServer 结构的saveparams 属性:
struct redisServer{
struct saveparams *saveparams;
long long dirty;
time_t lastsave;
}
saveparams 属性是一个数组,数组中的每一个元素都是saveparam 结构,每个saveparam 结构都保存了一个save 选项设置的保存条件:
struct saveparam{
time_t seconds;
int changes;
}
那么redisServer 是怎么保存上面的save 设置的条件?
dirty计数器和lastsave属性
除了saveparams 属性,服务器状态还维持着一个dirty 计数器,以及一个lastsave 属性:
dirty 计数器记录了距离上一次成功执行SAVE 命令或者BGSAVE 命令之后,服务器对数据库进行了多少次修改(增删改)lastsave 属性是一个UNIX 时间戳,记录了服务器上一次成功执行SAVE 命令或者BGSAVE 命令的时间
假设有这么一个服务器状态:
dirty 为123表示服务器在上次保存之后,对数据库状态执行了123次修改lastsave 属性则记录了服务器上次执行保存操作的时间为:1378270800(也就是:2013年9月4日零时)
检查保存条件是否满足
Redis 的服务器周期性操作函数serverCron 默认每隔100毫秒执行一次,该函数用于对正在执行的服务器进行维护,其中一项工作就是检查save 选项所设置的保存条件是否已经满足。如果满足就执行BGSAVE 命令。相关伪代码如下:
def serverCron():
#...
# 遍历所有保存条件
for saveparam in server.saveparams:
# 计算距离上次执行保存操作有多少秒
save_interval = unixtime_now() - server.lastsave
# 如果数据库状态的修改次数超过条件设置的次数
# 并且距离上次保存的时间超过条件设置的时间
# 那么执行保存操作
if server.dirty >= saveparam.changes and save_interval > saveparam.seconds:
BGSAVE()
# ...
程序会遍历并检查saveparams 数组中的所有保存条件,只要有任意一个条件被满足,那么服务器就会执行BGSAVE 命令
例如服务器状态如当前所示:
那么当过了300秒后(也就是当前时间戳为:1378271101),服务器将自动执行一次BGSAVE 命令,因为saveparams 数组的第二个保存条件:300秒内有至少10次修改,已经被满足。
执行一次BGSAVE 之后,假设执行时间为5秒,那么执行后的服务器状态应为:
可以看到,修改计数器已经被重置为0了
未完待续……
|