共計 3614 個字符,預計需要花費 10 分鐘才能閱讀完成。
這篇文章將為大家詳細講解有關 redis 之 RDB、AOF 與復制時對過期鍵怎么處理,丸趣 TV 小編覺得挺實用的,因此分享給大家做個參考,希望大家閱讀完這篇文章后可以有所收獲。
生成 RDB 文件
在執行 SAVE 命令或者 BGSAVE 命令創建一個新的 RDB 文件時,程序會對數據庫中的鍵進行檢查,已過期的鍵不會被保存到新創建的 RDB 文件中。
舉個例子,如果數據庫中包含三個鍵 k1、k2、k3,并且 k2 已經過期,那么當執行 SAVE 命令或者 BGSAVE 命令時,程序只會將 k1 和 k3 的數據保存到 RDB 文件中,而 k2 則會被忽略。
因此,數據庫中包含過期鍵不會對生成新的 RDB 文件造成影響。
可參考 rdb.c 中函數 rdbSave() 函數源碼:
/* Iterate this DB writing every entry
*
* 遍歷數據庫,并寫入每個鍵值對的數據
*/
while((de = dictNext(di)) != NULL) { sds keystr = dictGetKey(de);
robj key, *o = dictGetVal(de);
long long expire;
// 根據 keystr ,在棧中創建一個 key 對象
initStaticStringObject(key,keystr);
// 獲取鍵的過期時間
expire = getExpire(db, key);
// 保存鍵值對數據
if (rdbSaveKeyValuePair( rdb, key,o,expire,now) == -1) goto werr;
}
rdbSaveKeyValuePair 函數實現如下:
/* Save a key-value pair, with expire time, type, key, value.
*
* 將鍵值對的鍵、值、過期時間和類型寫入到 RDB 中。 *
* On error -1 is returned.
*
* 出錯返回 -1 。 *
* On success if the key was actually saved 1 is returned, otherwise 0
* is returned (the key was already expired).
*
* 成功保存返回 1 ,當鍵已經過期時,返回 0 。 */
int rdbSaveKeyValuePair(rio *rdb, robj *key, robj *val,
long long expiretime, long long now)
/* Save the expire time
*
* 保存鍵的過期時間
*/
if (expiretime != -1) {
/* If this key is already expired skip it
*
* 不寫入已經過期的鍵
*/
if (expiretime now) return 0;
if (rdbSaveType(rdb,REDIS_RDB_OPCODE_EXPIRETIME_MS) == -1) return -1;
if (rdbSaveMillisecondTime(rdb,expiretime) == -1) return -1;
}
/* Save type, key, value
*
* 保存類型,鍵,值
*/
if (rdbSaveObjectType(rdb,val) == -1) return -1;
if (rdbSaveStringObject(rdb,key) == -1) return -1;
if (rdbSaveObject(rdb,val) == -1) return -1;
return 1;
}
載入 RDB 文件
在啟動 Redis 服務器時,如果服務器開啟了 RDB 功能,那么服務器將對 RDB 文件進行載入:
如果服務器以主服務器模式運行,那么在載入 RDB 文件時,程序會對文件中保存的鍵進行檢查,未過期的鍵會被載入到數據庫中,而過期鍵則會被忽略,所以過期鍵對載入 RDB 文件的主服務器不會造成影響;
如果服務器以從服務器模式運行,那么在載入 RDB 文件時,文件中保存的所有鍵,不論是否過期,都會被載入到數據庫中。不過,因為主從服務器在進行數據同步的時候,從服務器的數據庫就會被清空,所以一般來講,過期鍵對載入 RDB 文件的從服務器也不會造成影響;
這部分代碼可以查看 rdb.c 中 rdbLoad() 函數源碼:
/* Check if the key already expired. This function is used when loading
* an RDB file from disk, either at startup, or when an RDB was
* received from the master. In the latter case, the master is
* responsible for key expiry. If we would expire keys here, the
* snapshot taken by the master may not be reflected on the slave.
*
* 如果服務器為主節點的話, * 那么在鍵已經過期的時候,不再將它們關聯到數據庫中去
*/
if (server.masterhost == NULL expiretime != -1 expiretime now) { decrRefCount(key);
decrRefCount(val);
// 跳過
continue;
}
AOF 文件寫入
當服務器以 AOF 持久化模式運行時,如果數據庫中的某個鍵已經過期,但它還沒有被惰性刪除或者定期刪除,那么 AOF 文件不會因為這個過期鍵而產生任何影響。
當過期鍵被惰性刪除或者定期刪除之后,程序會向 AOF 文件追加(append)一條 DEL 命令,來顯式地記錄該鍵已被刪除。
舉個例子,如果客戶端使用 GET message 命令,試圖訪問過期的 message 鍵,那么服務器將執行以下三個動作:
1)從數據庫中刪除 message 鍵。
2)追加一條 DEL message 命令到 AOF 文件。(根據 AOF 文件增加的特點,AOF 只有在客戶端進行請求的時候才會有這個 DEL 操作)
3)向執行 GET 命令的客戶端返回空回復。
這部分就是 Redis 中的惰性刪除策略中 expireIfNeeded 函數的使用。關于惰性刪除策略這一部分在 Redis 惰性刪除策略一篇中有講。所以這里就不贅述了。
需要提示一下的是:expireIfNeeded 函數是在 db.c/lookupKeyRead() 函數中被調用,lookupKeyRead 函數用于在執行讀取操作時取出鍵 key 在數據庫 db 中的值。
AOF 重寫
和生成 RDB 文件時類似,在執行 AOF 重寫的過程中,程序會對數據庫中的鍵進行檢查,已過期的鍵不會被保存到重寫后的 AOF 文件中。
舉個例子,如果數據庫中包含三個鍵 k1、k2、k3,并且 k2 已經過期,那么在進行重寫工作時,程序只會對 k1 和 k3 進行重寫,而 k2 則會被忽略。
這一部分如果掌握了 AOF 重寫的方法的話,那就自然理解了。
復制
當服務器運行在復制模式下時,從服務器的過期鍵刪除動作由主服務器控制:
主服務器在刪除一個過期鍵之后,會顯式地向所有從服務器發送一個 DEL 命令,告知從服務器刪除這個過期鍵;
從服務器在執行客戶端發送的讀命令時,即使碰到過期鍵也不會將過期鍵刪除,而是繼續像處理未過期的鍵一樣來處理過期鍵;
從服務器只有在接到主服務器發來的 DEL 命令之后,才會刪除過期鍵。
舉個例子,有一對主從服務器,它們的數據庫中都保存著同樣的三個鍵 message、xxx 和 yyy,其中 message 為過期鍵,如圖所示
如果這時有客戶端向從服務器發送命令 GET message,那么從服務器將發現 message 鍵已經過期,但從服務器并不會刪除 message 鍵,而是繼續將 message 鍵的值返回給客戶端,就好像 message 鍵并沒有過期一樣。
假設在此之后,有客戶端向主服務器發送命令 GET message,那么主服務器將發現鍵 message 已經過期:主服務器會刪除 message 鍵,向客戶端返回空回復,并向從服務器發送 DEL message 命令,如圖所示:
從服務器在接收到主服務器發來的 DEL message 命令之后,也會從數據庫中刪除 message 鍵,在這之后,主從服務器都不再保存過期鍵 message 了,如圖所示:
關于“redis 之 RDB、AOF 與復制時對過期鍵怎么處理”這篇文章就分享到這里了,希望以上內容可以對大家有一定的幫助,使各位可以學到更多知識,如果覺得文章不錯,請把它分享出去讓更多的人看到。