欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Redis過(guò)期時(shí)間的設(shè)計(jì)與實(shí)現(xiàn)代碼

 更新時(shí)間:2024年08月25日 13:44:33   作者:逸風(fēng)尊者  
在?Redis?中,鍵的過(guò)期時(shí)間設(shè)計(jì)與實(shí)現(xiàn)是一個(gè)重要的功能,這使得?Redis?可以自動(dòng)刪除在指定時(shí)間后不再需要的鍵,下面詳細(xì)介紹?Redis?過(guò)期時(shí)間的設(shè)計(jì)和實(shí)現(xiàn),包括設(shè)置過(guò)期時(shí)間、過(guò)期鍵的存儲(chǔ)結(jié)構(gòu)、過(guò)期鍵的刪除策略等,需要的朋友可以參考下

1. 設(shè)置過(guò)期時(shí)間

Redis 提供了多個(gè)命令來(lái)設(shè)置鍵的過(guò)期時(shí)間,如 EXPIRE、PEXPIRE、EXPIREATPEXPIREAT。這些命令可以以秒或毫秒為單位設(shè)置鍵的過(guò)期時(shí)間,也可以設(shè)置具體的過(guò)期時(shí)間點(diǎn)。

  • EXPIRE key seconds
  • PEXPIRE key milliseconds
  • EXPIREAT key timestamp
  • PEXPIREAT key milliseconds-timestamp

示例:

void expireCommand(client *c) {
    long long seconds;
    if (getLongLongFromObjectOrReply(c, c->argv[2], &seconds, NULL) != C_OK)
        return;
    setExpire(c, c->db, c->argv[1], mstime() + seconds*1000);
    addReply(c, shared.cone);
}

2. 過(guò)期鍵的存儲(chǔ)結(jié)構(gòu)

每個(gè) Redis 數(shù)據(jù)庫(kù)實(shí)例(redisDb)中都有一個(gè)名為 expires 的字典,用于存儲(chǔ)鍵的過(guò)期時(shí)間。這個(gè)字典將鍵指針映射到以毫秒為單位的到期時(shí)間點(diǎn)。

typedef struct redisDb {
    dict *dict;                // 主字典,存儲(chǔ)所有鍵值對(duì)
    dict *expires;             // 過(guò)期字典,存儲(chǔ)鍵的過(guò)期時(shí)間
    ...
} redisDb;

3. 設(shè)置過(guò)期時(shí)間

通過(guò) setExpire 函數(shù)設(shè)置鍵的過(guò)期時(shí)間。如果鍵已經(jīng)存在于 expires 字典中,則更新其過(guò)期時(shí)間;否則,將其添加到 expires 字典中。

void setExpire(client *c, redisDb *db, robj *key, long long when) {
    dictEntry *de = dictFind(db->dict, key->ptr);
    if (de == NULL) return;

    /* Set the new expire time */
    if (dictAdd(db->expires, dictGetKey(de), (void*)when) == DICT_ERR) {
        dictReplace(db->expires, dictGetKey(de), (void*)when);
    }
}

4. 刪除過(guò)期鍵的策略

Redis 采用了以下三種策略來(lái)刪除過(guò)期鍵:

  • 惰性刪除(Lazy Deletion) :每次訪問(wèn)鍵時(shí)檢查其是否過(guò)期,如果已過(guò)期則刪除。這樣只在訪問(wèn)鍵時(shí)才進(jìn)行過(guò)期檢查,節(jié)省了資源。
robj *lookupKeyRead(redisDb *db, robj *key) {
    robj *val;
    expireIfNeeded(db,key);  // 檢查并刪除過(guò)期鍵
    val = lookupKey(db,key,LOOKUP_NONE);
    return val ? val : NULL;
}
  • 定期刪除(Periodic Deletion) :Redis 會(huì)周期性地隨機(jī)抽取一定數(shù)量的鍵進(jìn)行過(guò)期檢查,并刪除其中已過(guò)期的鍵。這一過(guò)程由后臺(tái)任務(wù)定期執(zhí)行,確保盡可能多的過(guò)期鍵被及時(shí)刪除。
int activeExpireCycle(int type) {
    unsigned int current_db = server.dbnum;
    long long start = ustime();
    long long timelimit = 1000000; // 1秒
    int dbs_per_call = CRON_DBS_PER_CALL;

    current_db = server.current_db;
    while(dbs_per_call--) {
        redisDb *db = server.db + (current_db % server.dbnum);
        activeExpireCycleTryExpire(db, cycle_tickets);
        current_db++;
    }

    long long elapsed = ustime()-start;
    return elapsed > timelimit;
}
  • 主動(dòng)刪除(Active Expiration) :在內(nèi)存使用接近最大限制時(shí),會(huì)觸發(fā)主動(dòng)刪除策略,通過(guò)掃描所有庫(kù)的鍵刪除過(guò)期數(shù)據(jù),以確保內(nèi)存使用量保持在設(shè)定范圍內(nèi)。
void evictExpiredKeys() {
    for (int j = 0; j < server.dbnum; j++) {
        redisDb *db = server.db+j;
        scanDatabaseForExpiredKeys(db);
    }
}
  • Redis 默認(rèn)采用以下兩種刪除過(guò)期鍵策略:

    惰性刪除(Lazy Deletion) :每次訪問(wèn)某個(gè)鍵時(shí)檢查其是否過(guò)期,如果過(guò)期則刪除。

    定期刪除(Periodic Deletion) :后臺(tái)任務(wù)定期掃描數(shù)據(jù)庫(kù)中的鍵,隨機(jī)抽取部分鍵進(jìn)行過(guò)期檢查并刪除其中已過(guò)期的鍵。

5. 檢查并刪除過(guò)期鍵

expireIfNeeded 函數(shù)用于檢查某個(gè)鍵是否過(guò)期,如果過(guò)期則刪除該鍵。

int expireIfNeeded(redisDb *db, robj *key) {
    mstime_t when = getExpire(db, key);
    if (when < 0) return 0;

    if (mstime() > when) {
        server.stat_expiredkeys++;
        propagateExpire(db,key);
        dbDelete(db,key);
        return 1;
    } else {
        return 0;
    }
}
  • getExpire:從 expires 字典中獲取鍵的過(guò)期時(shí)間。
  • mstime:返回當(dāng)前的毫秒時(shí)間戳。
  • 如果鍵已過(guò)期,則調(diào)用 dbDelete 刪除該鍵,并增加統(tǒng)計(jì)計(jì)數(shù)器 stat_expiredkeys。

6. 獲取過(guò)期時(shí)間

getExpire 函數(shù)用于獲取鍵的過(guò)期時(shí)間,如果鍵沒(méi)有設(shè)置過(guò)期時(shí)間則返回 -1。

mstime_t getExpire(redisDb *db, robj *key) {
    dictEntry *de;
    if (dictSize(db->expires) == 0 ||
        (de = dictFind(db->expires, key->ptr)) == NULL) return -1;

    return (mstime_t)dictGetSignedIntegerVal(de);
}

總結(jié)

Redis 的過(guò)期時(shí)間設(shè)計(jì)與實(shí)現(xiàn)包括以下幾個(gè)關(guān)鍵點(diǎn):

  • 設(shè)置過(guò)期時(shí)間:通過(guò) EXPIRE、PEXPIRE 等命令設(shè)置鍵的過(guò)期時(shí)間,并將過(guò)期時(shí)間存儲(chǔ)在 expires 字典中。

  • 過(guò)期字典:每個(gè)數(shù)據(jù)庫(kù)實(shí)例都有一個(gè) expires 字典,用于存儲(chǔ)鍵的過(guò)期時(shí)間。

  • 刪除策略

    • 惰性刪除:每次訪問(wèn)鍵時(shí)檢查其是否過(guò)期,如果已過(guò)期則刪除。
    • 定期刪除:通過(guò)后臺(tái)任務(wù)周期性地檢測(cè)并刪除過(guò)期鍵。
    • 主動(dòng)刪除:在內(nèi)存使用接近最大限制時(shí)觸發(fā),掃描所有鍵并刪除過(guò)期鍵。

定期刪除activeExpireCycle函數(shù)詳細(xì)解析

void activeExpireCycle(int type) {
    static unsigned int current_db = 0;  // 記錄上一次處理的數(shù)據(jù)庫(kù)索引
    static int timelimit_exit = 0;       // 用于指示是否超出時(shí)間限制
    unsigned int j;
    // 每次要處理的數(shù)據(jù)庫(kù)數(shù)量
    unsigned int dbs_per_call = CRON_DBS_PER_CALL;
    long long start = ustime();          // 開(kāi)始時(shí)間
    long long timelimit;                 // 時(shí)間限制

    if (type == ACTIVE_EXPIRE_CYCLE_FAST) {
        /* Fast cycle: 1 ms */
        timelimit = 1000;
    } else {
        /* Slow cycle: 25% CPU time p. DB / Configurable percentage. */
        timelimit = server.hz < 100 ? 1000 : 10;
        if (server.active_expire_effort != 1)
            timelimit *= server.active_expire_effort-1;
        timelimit /= server.dbnum;
        timelimit_exit = 0;
    }

    for (j = 0; j < dbs_per_call; j++) {
        redisDb *db = server.db + (current_db % server.dbnum);
        current_db++;
        int expired, sampled;

        do {
            long now = mstime();
            expireEntry *de;
            dictEntry *d;

            /* Sample a few keys in the database */
            expired = 0;
            sampled = 0;
            while ((de = dictGetRandomKey(db->expires)) != NULL &&
                   mstime() - now < timelimit) {
                long long ttl = dictGetSignedIntegerVal(de) - mstime();
                if (ttl < 0) {
                    d = dictFind(db->dict, dictGetKey(de));
                    dbDelete(db, dictGetKey(d));
                    server.stat_expiredkeys++;
                    expired++;
                }
                sampled++;
            }
        } while (expired > ACTIVE_EXPIRE_CYCLE_LOOKUPS_PER_LOOP / 2);

        elapsed = ustime() - start;
        if (elapsed > timelimit) {
            timelimit_exit = 1;
            break;
        }
    }
}

關(guān)鍵步驟解析

1. 初始化變量

static unsigned int current_db = 0;
static int timelimit_exit = 0;
unsigned int j;
unsigned int dbs_per_call = CRON_DBS_PER_CALL;
long long start = ustime();
long long timelimit;
  • current_db:靜態(tài)變量,用于記錄上一次處理的數(shù)據(jù)庫(kù)索引。
  • timelimit_exit:用于指示是否耗盡了時(shí)間配額,防止無(wú)限循環(huán)。
  • dbs_per_call:每次掃描的數(shù)據(jù)庫(kù)數(shù)量,通常由配置決定。
  • start:記錄開(kāi)始執(zhí)行此函數(shù)的時(shí)間戳。
  • timelimit:本次調(diào)用允許消耗的最大時(shí)間(以微秒為單位)。

2. 確定時(shí)間限制

if (type == ACTIVE_EXPIRE_CYCLE_FAST) {
    timelimit = 1000;  // 快速模式:1 毫秒
} else {
    timelimit = server.hz < 100 ? 1000 : 10;
    if (server.active_expire_effort != 1)
        timelimit *= server.active_expire_effort - 1;
    timelimit /= server.dbnum;
    timelimit_exit = 0;
}
  • 如果是快速模式,時(shí)間限制為 1 毫秒。
  • 如果是慢速模式,時(shí)間限制根據(jù) Redis 配置和當(dāng)前服務(wù)器負(fù)載情況計(jì)算。
  • server.active_expire_effort 參數(shù)可以調(diào)整過(guò)期鍵清理的力度。

3. 遍歷數(shù)據(jù)庫(kù)

每次調(diào)用 activeExpireCycle 時(shí),會(huì)遍歷一定數(shù)量的數(shù)據(jù)庫(kù),并在每個(gè)數(shù)據(jù)庫(kù)中隨機(jī)抽取鍵進(jìn)行過(guò)期檢查和刪除。

for (j = 0; j < dbs_per_call; j++) {
    redisDb *db = server.db + (current_db % server.dbnum);
    current_db++;
    int expired, sampled;

    do {
        long now = mstime();
        expireEntry *de;
        dictEntry *d;

        expired = 0;
        sampled = 0;
        while ((de = dictGetRandomKey(db->expires)) != NULL &&
               mstime() - now < timelimit) {
            long long ttl = dictGetSignedIntegerVal(de) - mstime();
            if (ttl < 0) {
                d = dictFind(db->dict, dictGetKey(de));
                dbDelete(db, dictGetKey(d));
                server.stat_expiredkeys++;
                expired++;
            }
            sampled++;
        }
    } while (expired > ACTIVE_EXPIRE_CYCLE_LOOKUPS_PER_LOOP / 2);

    elapsed = ustime() - start;
    if (elapsed > timelimit) {
        timelimit_exit = 1;
        break;
    }
}

關(guān)鍵點(diǎn)解析:

選擇數(shù)據(jù)庫(kù)

redisDb *db = server.db + (current_db % server.dbnum);
current_db++;

使用循環(huán)方式選擇下一個(gè)要檢查的數(shù)據(jù)庫(kù)實(shí)例。current_db 記錄上一次處理的數(shù)據(jù)庫(kù)索引,通過(guò)取模操作確保索引在有效范圍內(nèi)。

初始化變量

int expired, sampled;
expired = 0;
sampled = 0;

過(guò)期檢查循環(huán)

while ((de = dictGetRandomKey(db->expires)) != NULL && mstime() - now < timelimit) {
    long long ttl = dictGetSignedIntegerVal(de) - mstime();
    if (ttl < 0) {
        d = dictFind(db->dict, dictGetKey(de));
        dbDelete(db, dictGetKey(d));
        server.stat_expiredkeys++;
        expired++;
    }
    sampled++;
}
    • 從 expires 字典中隨機(jī)獲取一個(gè)鍵 de。
    • 檢查當(dāng)前時(shí)間是否超過(guò)了本次周期的時(shí)間限制 timelimit
    • 如果鍵已經(jīng)過(guò)期(ttl < 0),則刪除該鍵,并增加已過(guò)期鍵的計(jì)數(shù)器 expired。
    • 增加已檢查鍵的計(jì)數(shù)器 sampled。

多輪過(guò)期檢查

do {
    ...
} while (expired > ACTIVE_EXPIRE_CYCLE_LOOKUPS_PER_LOOP / 2);
  • 如果在一輪檢查中刪除的過(guò)期鍵數(shù)量超過(guò)預(yù)設(shè)值的一半,則繼續(xù)下一輪檢查。

4. 時(shí)間限制檢查

在每次處理完一個(gè)數(shù)據(jù)庫(kù)后,檢查是否超出時(shí)間限制:

elapsed = ustime() - start;
if (elapsed > timelimit) {
    timelimit_exit = 1;
    break;
}
  • 計(jì)算已耗費(fèi)的時(shí)間 elapsed。
  • 如果已耗費(fèi)時(shí)間超過(guò) timelimit,設(shè)置 timelimit_exit 為 1 并跳出循環(huán)。

總結(jié)

Redis 的 activeExpireCycle 函數(shù)通過(guò)以下步驟實(shí)現(xiàn)定期刪除過(guò)期鍵:

  • 初始化變量并確定時(shí)間限制:根據(jù)當(dāng)前的模式(快速或慢速)和配置參數(shù),計(jì)算本次函數(shù)調(diào)用的時(shí)間限制。
  • 遍歷數(shù)據(jù)庫(kù):循環(huán)遍歷一定數(shù)量的數(shù)據(jù)庫(kù)。
  • 過(guò)期檢查與刪除:從每個(gè)數(shù)據(jù)庫(kù)中隨機(jī)抽取鍵,檢查其是否過(guò)期并進(jìn)行刪除,直到達(dá)到時(shí)間限制或刪除了一定數(shù)量的過(guò)期鍵。
  • 時(shí)間限制檢查:確保函數(shù)不會(huì)超出規(guī)定的時(shí)間配額,以避免影響 Redis 的其他操作。

AOF、RDB和復(fù)制功能對(duì)過(guò)期鍵的處理

在 Redis 中,AOF(Append Only File)、RDB(Redis DataBase)和復(fù)制(Replication)功能對(duì)過(guò)期鍵的處理方式有所不同。下面詳細(xì)介紹這些機(jī)制如何處理過(guò)期鍵:

AOF 持久化

  • 記錄過(guò)期時(shí)間

    • 在 AOF 文件中,除了寫(xiě)入每個(gè)鍵值的設(shè)置操作外,還會(huì)寫(xiě)入 EXPIRE 或 PEXPIRE 命令來(lái)記錄鍵的過(guò)期時(shí)間。
  • 重寫(xiě)(Rewrite)過(guò)程

    • 當(dāng) AOF 文件需要重寫(xiě)時(shí),Redis 會(huì)檢查每個(gè)鍵,如果鍵已過(guò)期,則不會(huì)將其寫(xiě)入新的 AOF 文件。
  • 加載 AOF 文件

    • 當(dāng) Redis 重啟并加載 AOF 文件時(shí),會(huì)執(zhí)行文件中的所有命令,包括設(shè)置鍵值和設(shè)置過(guò)期時(shí)間的命令。如果某些鍵已經(jīng)過(guò)期,這些鍵會(huì)立即被刪除。

RDB 持久化

  • 保存快照

    • 當(dāng) Redis 創(chuàng)建 RDB 快照時(shí),它會(huì)將所有鍵及其剩余的過(guò)期時(shí)間一起保存到快照文件中。
  • 加載快照

    • 當(dāng) Redis 從 RDB 文件恢復(fù)數(shù)據(jù)時(shí),會(huì)載入所有鍵值對(duì),同時(shí)載入它們的過(guò)期時(shí)間。如果某個(gè)鍵在載入時(shí)已經(jīng)過(guò)期,Redis 會(huì)立即將其刪除。

復(fù)制(Replication)

  • 主從同步

    • 在主從復(fù)制架構(gòu)中,主節(jié)點(diǎn)會(huì)將過(guò)期鍵的刪除操作傳播給從節(jié)點(diǎn)。
    • 如果一個(gè)鍵在主節(jié)點(diǎn)上過(guò)期并被刪除,主節(jié)點(diǎn)會(huì)向從節(jié)點(diǎn)發(fā)送 DEL 操作,從而在從節(jié)點(diǎn)上也刪除該鍵。
  • 延遲過(guò)期

    • 從節(jié)點(diǎn)可能因?yàn)榫W(wǎng)絡(luò)延遲等原因,對(duì)過(guò)期鍵的處理會(huì)稍有滯后,但最終主從節(jié)點(diǎn)的數(shù)據(jù)將保持一致。

總結(jié)

  • AOF:

    • 通過(guò)記錄 EXPIRE/PEXPIRE 命令來(lái)處理過(guò)期時(shí)間。
    • 在重寫(xiě)過(guò)程中跳過(guò)已過(guò)期的鍵。
    • 加載時(shí)刪除已過(guò)期的鍵。
  • RDB:

    • 將過(guò)期時(shí)間與鍵值一起保存。
    • 加載時(shí)立即刪除已過(guò)期的鍵。
  • 復(fù)制:

    • 主節(jié)點(diǎn)將刪除過(guò)期鍵的操作同步到從節(jié)點(diǎn)。
    • 確保主從節(jié)點(diǎn)數(shù)據(jù)的一致性。

以上就是Redis過(guò)期時(shí)間的設(shè)計(jì)與實(shí)現(xiàn)代碼的詳細(xì)內(nèi)容,更多關(guān)于Redis過(guò)期時(shí)間的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章!

相關(guān)文章

  • Redis分布式可重入鎖實(shí)現(xiàn)方案

    Redis分布式可重入鎖實(shí)現(xiàn)方案

    在單進(jìn)程環(huán)境下,要保證一個(gè)代碼塊的同步執(zhí)行,直接用synchronized 關(guān)鍵字或ReetrantLock 即可,在分布式環(huán)境下,要保證多個(gè)節(jié)點(diǎn)的線程對(duì)代碼塊的同步訪問(wèn),就必須要用到分布式鎖方案,本文介紹一下基于 Redis實(shí)現(xiàn)的分布式鎖方案,感興趣的朋友一起看看吧
    2024-02-02
  • Redis數(shù)據(jù)庫(kù)安裝部署及基本操作詳解

    Redis數(shù)據(jù)庫(kù)安裝部署及基本操作詳解

    這篇文章主要介紹了Redis數(shù)據(jù)庫(kù)安裝部署及基本操作,本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
    2021-08-08
  • 詳解如何發(fā)現(xiàn)并解決Redis熱點(diǎn)Key問(wèn)題

    詳解如何發(fā)現(xiàn)并解決Redis熱點(diǎn)Key問(wèn)題

    Redis 熱點(diǎn) Key 是指在某一時(shí)間段內(nèi),被大量的讀寫(xiě)操作命中的 Key,這種情況可能會(huì)導(dǎo)致性能瓶頸,數(shù)據(jù)一致性問(wèn)題,緩存擊穿等問(wèn)題,所以本文給大家介紹了如何發(fā)現(xiàn)并解決Redis熱點(diǎn)Key問(wèn)題,需要的朋友可以參考下
    2024-05-05
  • Redis中有序集合的內(nèi)部實(shí)現(xiàn)方式的詳細(xì)介紹

    Redis中有序集合的內(nèi)部實(shí)現(xiàn)方式的詳細(xì)介紹

    本文主要介紹了Redis中有序集合的內(nèi)部實(shí)現(xiàn)方式的詳細(xì)介紹,文中通過(guò)示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2022-03-03
  • Python Redis如何執(zhí)行Lua腳本

    Python Redis如何執(zhí)行Lua腳本

    這篇文章主要介紹了Python Redis如何執(zhí)行Lua腳本問(wèn)題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2024-02-02
  • Redis實(shí)現(xiàn)多人多聊天室功能

    Redis實(shí)現(xiàn)多人多聊天室功能

    這篇文章主要為大家詳細(xì)介紹了Redis實(shí)現(xiàn)多人多聊天室功能,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2016-11-11
  • Redis教程(十二):服務(wù)器管理命令總結(jié)

    Redis教程(十二):服務(wù)器管理命令總結(jié)

    這篇文章主要介紹了Redis教程(十二):服務(wù)器管理命令總結(jié),本文講解了CONFIGGETparameter、CONFIG SETparameter value、FLUSHALL等命令,需要的朋友可以參考下
    2015-04-04
  • Redis的Spring客戶端使用小結(jié)

    Redis的Spring客戶端使用小結(jié)

    在Spring中使用Redis,可以極大地提升應(yīng)用程序的性能和響應(yīng)速度,本文主要介紹了Redis的Spring客戶端使用小結(jié),具有一定的參考價(jià)值,感興趣的可以了解一下
    2025-04-04
  • redis主從復(fù)制的原理及實(shí)現(xiàn)

    redis主從復(fù)制的原理及實(shí)現(xiàn)

    Redis主從復(fù)制是一種數(shù)據(jù)同步機(jī)制,它通過(guò)將一個(gè)Redis實(shí)例的數(shù)據(jù)復(fù)制到其他Redis,本文主要介紹了redis主從復(fù)制的原理及實(shí)現(xiàn),具有一定的參考價(jià)值,感興趣的可以了解一下
    2023-08-08
  • 聊一聊Redis與MySQL雙寫(xiě)一致性如何保證

    聊一聊Redis與MySQL雙寫(xiě)一致性如何保證

    一致性就是數(shù)據(jù)保持一致,在分布式系統(tǒng)中,可以理解為多個(gè)節(jié)點(diǎn)中數(shù)據(jù)的值是一致的。本文給大家分享Redis與MySQL雙寫(xiě)一致性該如何保證,感興趣的朋友一起看看吧
    2021-06-06

最新評(píng)論