Redis RDB 持久化源碼深度解析：從原理到實現(xiàn)
為避免服務(wù)器宕機著情況導(dǎo)致redis內(nèi)存數(shù)據(jù)庫數(shù)據(jù)丟失，redis默認出通過rdb保證可靠性，本文將從源碼的角度帶讀者了解rdb讀寫時機和寫入流程。
save指令觸發(fā)rdb
redis支持通過命令的方式持久化內(nèi)存數(shù)據(jù)庫數(shù)據(jù)，當(dāng)我們鍵入save的時候，redis解析到這個指令之后，主線程直接調(diào)用saveCommand方法生成rdb文件落到磁盤中。
我們可以在rdb.c文件中看到該方法的實現(xiàn)，可以看到為了避免臟寫等問題，saveCommand會檢查當(dāng)前是否有rdb子進程執(zhí)行，如果沒有在子進程執(zhí)行rdb持久化則直接調(diào)用rdbSave方法生成dump.rdb文件落盤：
//調(diào)用save指令其內(nèi)部調(diào)用rdbSave完成rdb文件生成
void saveCommand(redisClient *c) {
//檢查是否子進程執(zhí)行rdb，若有則直接返回
if (server.rdb_child_pid != -1) {
addReplyError(c,"Background save already in progress");
return;
}
//調(diào)用rdbSave
if (rdbSave(server.rdb_filename) == REDIS_OK) {
addReply(c,shared.ok);
} else {
addReply(c,shared.err);
}
}步入rdbSave即可看到生成臨時rdb寫入數(shù)據(jù)，然后數(shù)據(jù)刷盤，最后完成文件名原子修改的操作：
int rdbSave(char *filename) {
char tmpfile[256];
FILE *fp;
rio rdb;
int error;
//生成一個tmp文件
snprintf(tmpfile,256,"temp-%d.rdb", (int) getpid());
fp = fopen(tmpfile,"w");
if (!fp) {
redisLog(REDIS_WARNING, "Failed opening .rdb for saving: %s",
strerror(errno));
return REDIS_ERR;
}
//調(diào)用rdbSaveRio完成數(shù)據(jù)寫入
rioInitWithFile(&rdb,fp);
if (rdbSaveRio(&rdb,&error) == REDIS_ERR) {
errno = error;
goto werr;
}
//直接刷盤到磁盤，避免留在系統(tǒng)輸出緩沖區(qū)
/* 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;
//完成寫入后文件重命名為dump.rdb
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;
}
//......
return REDIS_OK;
//......
}bgsave指令觸發(fā)rdb
同時redis也支持后臺持久化，如果用戶需要考慮redis性能問題，可以直接通過bgsave指令創(chuàng)建rdb子進程完成數(shù)據(jù)庫數(shù)據(jù)持久化。
我們同樣可以在rdb.c文件中看到bgsave指令調(diào)用的方法bgsaveCommand，可以看到如果沒有子進程進行rdb或者aof，該指令會調(diào)用rdbSaveBackground完成異步數(shù)據(jù)持久化：
//調(diào)用rdbSaveBackground創(chuàng)建一個子進程生成rdb文件，不影響主線程
void bgsaveCommand(redisClient *c) {
//如果有子進程執(zhí)行rdb或者aof，則直接返回錯誤提醒
if (server.rdb_child_pid != -1) {
addReplyError(c,"Background save already in progress");
} else if (server.aof_child_pid != -1) {
addReplyError(c,"Can't BGSAVE while AOF log rewriting is in progress");
} else if (rdbSaveBackground(server.rdb_filename) == REDIS_OK) {//調(diào)用rdbSaveBackground進行數(shù)據(jù)持久化
addReplyStatus(c,"Background saving started");
} else {
addReply(c,shared.err);
}
}步入rdbSaveBackground可以看到，其內(nèi)部還會檢查一次是否有文件進行rdb，如果明確沒有之后直接fork一個子進程出來調(diào)用上文所說的rdbSave完成數(shù)據(jù)持久化到dump.rdb中：
int rdbSaveBackground(char *filename) {
pid_t childpid;
long long start;
if (server.rdb_child_pid != -1) return REDIS_ERR;
//......
start = ustime();
if ((childpid = fork()) == 0) {//創(chuàng)建子進程
int retval;
//......
retval = rdbSave(filename);//生成rdb文件
exitFromChild((retval == REDIS_OK) ? 0 : 1);//退出子進程
} else {
//......
}
return REDIS_OK; /* unreached */
}rdb被動觸發(fā)
redis被動觸發(fā)由時間事件輪詢處理，我們可以在redis.conf配置rdb被動觸發(fā)持久化的時機，默認配置如下當(dāng)60s生成10000或者300s 生成10次改變亦或者900s生成1次改變，我們就會執(zhí)行一次被動rdb持久化：
save 900 1
save 300 10
save 60 10000
對應(yīng)的我們可以在redis.c的serverCron函數(shù)在看到這段邏輯，它會遍歷出我們配置的保存間隔配置saveparam，通過比對這3條配置的上次保存時間計算出時間間隔，以及當(dāng)前redis變化書dirty看看是否符合要求，若如何要求則進行后臺rdb持久化：
int serverCron(struct aeEventLoop *eventLoop, long long id, void *clientData) {
//......
/* Check if a background saving or AOF rewrite in progress terminated. */
if (server.rdb_child_pid != -1 || server.aof_child_pid != -1) {
//......
}
} else {
//遍歷3個配置的params，如果改變數(shù)和事件間隔配置要求則直接進行后臺被動rdb持久化
for (j = 0; j < server.saveparamslen; j++) {
struct saveparam *sp = server.saveparams+j;
if (server.dirty >= sp->changes && //查看變化數(shù)是否大于當(dāng)前配置的changes
server.unixtime-server.lastsave > sp->seconds && //查看時間間隔是否大于配置
(server.unixtime-server.lastbgsave_try >
REDIS_BGSAVE_RETRY_DELAY ||
server.lastbgsave_status == REDIS_OK))
{
//......
//執(zhí)行異步持久化
rdbSaveBackground(server.rdb_filename);
break;
}
}
//......
}
}
//......
return 1000/server.hz;
}其他被動落盤時機
其實有些時候我們執(zhí)行的某些執(zhí)行也會進行rdb持久化，例如flushall刷盤指令,其調(diào)用函數(shù)flushallCommand就會時間串行執(zhí)行rdb持久化：
//調(diào)用flush指令時會調(diào)用rdbSave進行數(shù)據(jù)持久化
void flushallCommand(redisClient *c) {
//......
if (server.saveparamslen > 0) {
//串行執(zhí)行rdb持久化
int saved_dirty = server.dirty;
rdbSave(server.rdb_filename);
//......
}
server.dirty++;
}當(dāng)我們關(guān)閉redis服務(wù)器的時候也會執(zhí)行rdb串行持久化：
//服務(wù)器進程關(guān)閉時調(diào)用rdbSave生成rdb文件
int prepareForShutdown(int flags) {
//......
if (server.rdb_child_pid != -1) {
//......
}
if (server.aof_state != REDIS_AOF_OFF) {
//......
}
if ((server.saveparamslen > 0 && !nosave) || save) {
if (rdbSave(server.rdb_filename) != REDIS_OK) {
//......
return REDIS_ERR;
}
}
//......
return REDIS_OK;
}rdb寫入文件數(shù)據(jù)詳解
無論是rdbsave還是rdbbgsave對應(yīng)的方法，其內(nèi)部都會調(diào)用rdbSaveRio，它進行文件寫入時對應(yīng)寫入數(shù)據(jù)大體順序是:
- 寫入REDIS大寫。
- 補0填充長度。
- 寫入當(dāng)前redis版本號，以筆者源碼為例則是6。
- 遍歷數(shù)據(jù)庫寫入REDIS_RDB_OPCODE_SELECTDB表示開始存儲數(shù)據(jù)庫數(shù)據(jù)，這個值默認為254，redis會轉(zhuǎn)為八進制376寫入。
- 遍歷當(dāng)前數(shù)據(jù)庫鍵值對key長度和key，value長度和value寫入，后續(xù)數(shù)據(jù)庫都是如此往復(fù)。
- 所有數(shù)據(jù)庫寫完后補上REDIS_RDB_OPCODE_EOF和checksum用于后續(xù)rdb數(shù)據(jù)恢復(fù)的校驗。
為保證讀者更直觀的了解redis持久化寫入的內(nèi)容，我們可以刪除本地rdb文件，然后執(zhí)行如下執(zhí)行生成一個全新的rdb文件：
# 保存鍵值對
set key value
# 切換到1庫
select 1
# 保存鍵值對到1庫
set key-1 value
# 調(diào)用save進行數(shù)據(jù)持久化
save正常情況下我們打開rdb文件會得到一堆類型亂碼的內(nèi)容，我們無法知曉寫入的信息，我們可以直接鍵入od生成rdb文件16進制數(shù)據(jù)及其對應(yīng)的ASCII字符：
od -A x -t x1c -v dump.rdb最終我們就可以得到如下文件，可以看到數(shù)據(jù)格式和筆者上文所說基本一致：
# 大寫REDIS 補0 254的8進制 當(dāng)前數(shù)據(jù)庫索引 鍵值對`key`長度和`key`，`value`長度和`value`
#000000 52 45 44 49 53 30 30 30 36 fe 00 00 03 6b 65 79
R E D I S 0 0 0 6 376 \0 \0 003 k e y
000010 05 76 61 6c 75 65 fe 01 00 05 6b 65 79 2d 31 05
005 v a l u e
# 254的8進制 當(dāng)前數(shù)據(jù)庫索引1 鍵值對key長度和key，value長度和value
376 001 \0 005 k e y - 1 005
000020 76 61 6c 75 65 ff 76 eb e4 80 bd df 66 11
v a l u e
# EOF 255八進制 剩下8位是對應(yīng)的checksum
377 v 353 344 200 275 337 f 021
00002e對應(yīng)的我們給出這段源碼，對應(yīng)的寫入流程如上文筆者所述：
int rdbSaveRio(rio *rdb, int *error) {
dictIterator *di = NULL;
dictEntry *de;
char magic[10];
int j;
long long now = mstime();
uint64_t cksum;
if (server.rdb_checksum)
rdb->update_cksum = rioGenericUpdateChecksum;
snprintf(magic,sizeof(magic),"REDIS%04d",REDIS_RDB_VERSION);//對應(yīng)redis 3個0 然后版本號，當(dāng)前版本為6
if (rdbWriteRaw(rdb,magic,9) == -1) goto werr;//上述魔數(shù)寫入rdb文件
//遍歷數(shù)據(jù)庫
for (j = 0; j < server.dbnum; j++) {
redisDb *db = server.db+j;
dict *d = db->dict;
if (dictSize(d) == 0) continue;
di = dictGetSafeIterator(d);
if (!di) return REDIS_ERR;
/* Write the SELECT DB opcode */
if (rdbSaveType(rdb,REDIS_RDB_OPCODE_SELECTDB) == -1) goto werr;//寫入254，也就是內(nèi)容中的376
if (rdbSaveLen(rdb,j) == -1) goto werr;//寫入當(dāng)前庫索引
//遍歷當(dāng)前鍵值對寫入
while((de = dictNext(di)) != NULL) {
sds keystr = dictGetKey(de);
robj key, *o = dictGetVal(de);
long long expire;
initStaticStringObject(key,keystr);
expire = getExpire(db,&key);
if (rdbSaveKeyValuePair(rdb,&key,o,expire,now) == -1) goto werr;//寫入鍵值對
}
dictReleaseIterator(di);
}
//......
/* EOF opcode */
if (rdbSaveType(rdb,REDIS_RDB_OPCODE_EOF) == -1) goto werr;//寫入結(jié)束符254 八進制為377
cksum = rdb->cksum;
memrev64ifbe(&cksum);
if (rioWrite(rdb,&cksum,8) == 0) goto werr;//寫入8位數(shù)校驗和,其底層調(diào)用rioGenericUpdateChecksum，按照cksum到數(shù)組中獲取就對應(yīng)的值并
return REDIS_OK;
//......
}對應(yīng)的我們步入rdbSaveKeyValuePair即可看到redis獲取key長度和key，以及value長度和value并寫入rdb文件的核心流程:
int rdbSaveKeyValuePair(rio *rdb, robj *key, robj *val,
long long expiretime, long long now)
{
//......
/* Save type, key, value */
if (rdbSaveObjectType(rdb,val) == -1) return -1;//寫入類型以字符串形式就是0
if (rdbSaveStringObject(rdb,key) == -1) return -1;//寫入key長度和key
if (rdbSaveObject(rdb,val) == -1) return -1;//寫入value長度和value
return 1;
}
