青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品

阿二的夢想船

 

redis如何刪除過期數據

隨著nosql風潮興起,redis作為當中一個耀眼的明星,也越來越多的被關注和使用,我在工作中也廣泛的用到了redis來充當cachekey-value DB,但當大家發現數據越來越多時,不禁有些擔心,redis能撐的住嗎,雖然官方已經有漂亮的benchmark,自己也可以做做壓力測試,但是看看源碼,也是確認問題最直接的辦法之一。比如目前我們要確認的一個問題是,redis是如何刪除過期數據的?

用一個可以"find reference"IDE,沿著setex(Set the value and expiration of a key)命令一窺究竟:

void setexCommand(redisClient *c) {
    c
->argv[3= tryObjectEncoding(c->argv[3]);
    setGenericCommand(c,
0,c->argv[1],c->argv[3],c->argv[2]);
}

setGenericCommand是一個實現set,setnx,setex的通用函數,參數設置不同而已。

void setCommand(redisClient *c) {
    c
->argv[2= tryObjectEncoding(c->argv[2]);
    setGenericCommand(c,
0,c->argv[1],c->argv[2],NULL);
}
 
void setnxCommand(redisClient *c) {
    c
->argv[2= tryObjectEncoding(c->argv[2]);
    setGenericCommand(c,
1,c->argv[1],c->argv[2],NULL);
}
 
void setexCommand(redisClient *c) {
    c
->argv[3= tryObjectEncoding(c->argv[3]);
    setGenericCommand(c,
0,c->argv[1],c->argv[3],c->argv[2]);
}

再看setGenericCommand

 1 void setGenericCommand(redisClient *c, int nx, robj *key, robj *val, robj *expire) {
 2     long seconds = 0/* initialized to avoid an harmness warning */
 3 
 4     if (expire) {
 5         if (getLongFromObjectOrReply(c, expire, &seconds, NULL) != REDIS_OK)
 6             return;
 7         if (seconds <= 0) {
 8             addReplyError(c,"invalid expire time in SETEX");
 9             return;
10         }
11     }
12 
13     if (lookupKeyWrite(c->db,key) != NULL && nx) {
14         addReply(c,shared.czero);
15         return;
16     }
17     setKey(c->db,key,val);
18     server.dirty++;
19     if (expire) setExpire(c->db,key,time(NULL)+seconds); 
20     addReply(c, nx ? shared.cone : shared.ok);
21 }
22 

13行處理"Set the value of a key, only if the key does not exist"的場景,17行插入這個key19行設置它的超時,注意時間戳已經被設置成了到期時間。這里要看一下redisDb(c->db)的定義:

typedef struct redisDb {
    dict 
*dict;                 /* The keyspace for this DB */
    dict 
*expires;              /* Timeout of keys with a timeout set */
    dict 
*blocking_keys;        /* Keys with clients waiting for data (BLPOP) */
    dict 
*io_keys;              /* Keys with clients waiting for VM I/O */
    dict 
*watched_keys;         /* WATCHED keys for MULTI/EXEC CAS */
    
int id;
} redisDb;

僅關注dictexpires,分別來存key-value和它的超時,也就是說如果一個key-value是有超時的,那么它會存在dict里,同時也存到expires里,類似這樣的形式:dict[key]:value,expires[key]:timeout.

當然key-value沒有超時,expires里就不存在這個key剩下setKeysetExpire兩個函數無非是插數據到兩個字典里,這里不再詳述。


那么redis是如何刪除過期key的呢。

通過查看dbDelete的調用者,首先注意到這一個函數,是用來刪除過期key的。

 1 int expireIfNeeded(redisDb *db, robj *key) {
 2     time_t when = getExpire(db,key);
 3 
 4     if (when < 0return 0/* No expire for this key */
 5 
 6     /* Don't expire anything while loading. It will be done later. */
 7     if (server.loading) return 0;
 8 
 9     /* If we are running in the context of a slave, return ASAP:
10      * the slave key expiration is controlled by the master that will
11      * send us synthesized DEL operations for expired keys.
12      *
13      * Still we try to return the right information to the caller, 
14      * that is, 0 if we think the key should be still valid, 1 if
15      * we think the key is expired at this time. */
16     if (server.masterhost != NULL) {
17         return time(NULL) > when;
18     }
19 
20     /* Return when this key has not expired */
21     if (time(NULL) <= when) return 0;
22 
23     /* Delete the key */
24     server.stat_expiredkeys++;
25     propagateExpire(db,key);
26     return dbDelete(db,key);
27 }
28 

ifNeed表示能刪則刪,所以4行沒有設置超時不刪,7行在"loading"時不刪,16行非主庫不刪,21行未到期不刪。25行同步從庫和文件。

再看看哪些函數調用了expireIfNeeded,有lookupKeyReadlookupKeyWritedbRandomKeyexistsCommandkeysCommand。通過這些函數命名可以看出,只要訪問了某一個key,順帶做的事情就是嘗試查看過期并刪除,這就保證了用戶不可能訪問到過期的key。但是如果有大量的key過期,并且沒有被訪問到,那么就浪費了許多內存。Redis是如何處理這個問題的呢。


dbDelete的調用者里還發現這樣一個函數:

 1 /* Try to expire a few timed out keys. The algorithm used is adaptive and
 2  * will use few CPU cycles if there are few expiring keys, otherwise
 3  * it will get more aggressive to avoid that too much memory is used by
 4  * keys that can be removed from the keyspace. */
 5 void activeExpireCycle(void) {
 6     int j;
 7 
 8     for (j = 0; j < server.dbnum; j++) {
 9         int expired;
10         redisDb *db = server.db+j;
11 
12         /* Continue to expire if at the end of the cycle more than 25%
13          * of the keys were expired. */
14         do {
15             long num = dictSize(db->expires);
16             time_t now = time(NULL);
17 
18             expired = 0;
19             if (num > REDIS_EXPIRELOOKUPS_PER_CRON)
20                 num = REDIS_EXPIRELOOKUPS_PER_CRON;
21             while (num--) {
22                 dictEntry *de;
23                 time_t t;
24 
25                 if ((de = dictGetRandomKey(db->expires)) == NULL) break;
26                 t = (time_t) dictGetEntryVal(de);
27                 if (now > t) {
28                     sds key = dictGetEntryKey(de);
29                     robj *keyobj = createStringObject(key,sdslen(key));
30 
31                     propagateExpire(db,keyobj);
32                     dbDelete(db,keyobj);
33                     decrRefCount(keyobj);
34                     expired++;
35                     server.stat_expiredkeys++;
36                 }
37             }
38         } while (expired > REDIS_EXPIRELOOKUPS_PER_CRON/4);
39     }
40 }
41 

這個函數的意圖已經有說明:刪一點點過期key,如果過期key較少,那也只用一點點cpu25行隨機取一個key38行刪key成功的概率較低就退出。這個函數被放在一個cron里,每毫秒被調用一次。這個算法保證每次會刪除一定比例的key,但是如果key總量很大,而這個比例控制的太大,就需要更多次的循環,浪費cpu,控制的太小,過期的key就會變多,浪費內存——這就是時空權衡了。

 

最后在dbDelete的調用者里還發現這樣一個函數:

/* This function gets called when 'maxmemory' is set on the config file to limit
 * the max memory used by the server, and we are out of memory.
 * This function will try to, in order:
 *
 * - Free objects from the free list
 * - Try to remove keys with an EXPIRE set
 *
 * It is not possible to free enough memory to reach used-memory < maxmemory
 * the server will start refusing commands that will enlarge even more the
 * memory usage.
 
*/
void freeMemoryIfNeeded(void)

這個函數太長就不再詳述了,注釋部分說明只有在配置文件中設置了最大內存時候才會調用這個函數,而設置這個參數的意義是,你把redis當做一個內存cache而不是key-value數據庫。


以上3種刪除過期key的途徑,第二種定期刪除一定比例的key是主要的刪除途徑,第一種“讀時刪除”保證過期key不會被訪問到,第三種是一個當內存超出設定時的暴力手段。由此也能看出redis設計的巧妙之處,

posted on 2011-11-29 19:57 阿二 閱讀(14899) 評論(1)  編輯 收藏 引用 所屬分類: redis

評論

# re: redis如何刪除過期數據 2011-11-30 09:25 zuhd

關注下 redis這么火 打算研究下  回復  更多評論   

導航

統計

常用鏈接

留言簿

隨筆分類

隨筆檔案

搜索

最新評論

閱讀排行榜

評論排行榜

青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品
  • <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>
            亚洲激情国产精品| 久久精品一区二区三区不卡牛牛| 亚洲欧美在线x视频| 欧美日韩一级大片网址| 亚洲三级免费电影| 一区二区三区精密机械公司 | 欧美专区在线观看一区| 亚洲自拍三区| 久久久久久久久岛国免费| 欧美日韩另类综合| 99精品国产在热久久| 亚洲福利电影| 美女国内精品自产拍在线播放| 一区二区三区我不卡| 看欧美日韩国产| 久久久夜精品| 亚洲国产黄色片| 91久久久久久久久| 国产精品jizz在线观看美国| 亚洲一区在线播放| 久久精品在线观看| 亚洲精选在线| 亚洲一区免费| 亚洲国产免费| 中文国产成人精品| 精久久久久久久久久久| 亚洲国产精品久久久| 欧美三级在线视频| 久久久久久高潮国产精品视| 久久综合狠狠| 久久青草福利网站| 欧美性色综合| 欧美与欧洲交xxxx免费观看| 免费在线亚洲| 午夜精品福利在线观看| 久久久水蜜桃| 性欧美长视频| 久久综合九九| 午夜精彩视频在线观看不卡 | 亚洲国产精品第一区二区三区| 亚洲国产欧美国产综合一区| 毛片基地黄久久久久久天堂| 亚洲专区一区| 免费人成网站在线观看欧美高清 | 国产精品video| 免费成人高清在线视频| 亚洲曰本av电影| 欧美日韩一级黄| 欧美亚洲一区三区| 欧美激情视频一区二区三区免费| 亚洲欧洲99久久| 裸体女人亚洲精品一区| 亚洲网友自拍| 久久久777| 欧美一区二区在线视频| 国产精品麻豆成人av电影艾秋| 欧美成人精品在线观看| 国产精品一区二区你懂得| 亚洲最新合集| 艳女tv在线观看国产一区| 免费看成人av| 美女日韩欧美| 狠狠做深爱婷婷久久综合一区| 欧美影院成年免费版| 亚洲影院免费观看| 欧美日韩亚洲一区二区| 91久久国产自产拍夜夜嗨| 国产亚洲欧美aaaa| 亚洲欧美一级二级三级| 9i看片成人免费高清| 欧美成人精品在线| 快射av在线播放一区| 久久亚洲欧美| 国产视频在线观看一区二区| 欧美在线播放一区| 久久国产精彩视频| 国产精品久久波多野结衣| 亚洲午夜小视频| 亚洲中字黄色| 国产日韩欧美在线| 欧美在线资源| 美女在线一区二区| 亚洲精品国产精品久久清纯直播| 久久手机精品视频| 亚洲欧洲日本在线| 亚洲午夜电影| 国产精品社区| 麻豆精品视频在线| 最近看过的日韩成人| 亚洲尤物视频在线| 国产一区二区中文| 麻豆亚洲精品| 亚洲一二三区精品| 久久精品国产久精国产一老狼| 亚洲丁香婷深爱综合| 欧美精品一区二区三区视频| 日韩视频国产视频| 欧美在线视频a| 亚洲电影在线| 欧美日韩国产综合视频在线观看中文 | 久久婷婷蜜乳一本欲蜜臀| 久久久久欧美精品| 亚洲国产日韩精品| 欧美日本在线看| 欧美在线播放视频| 欧美激情精品久久久久久大尺度| 久久国产精品一区二区| 亚洲欧洲另类国产综合| 午夜精品福利一区二区三区av| 影院欧美亚洲| 欧美亚一区二区| 久久精品中文字幕一区二区三区| 亚洲狼人综合| 久久人人爽人人爽| 亚洲欧美日韩国产一区| 欧美午夜精品久久久久久浪潮 | 午夜精品久久99蜜桃的功能介绍| 激情六月综合| 欧美三级资源在线| 欧美在线播放| 亚洲男人影院| 亚洲国产色一区| 久久在线免费| 午夜视频一区在线观看| 国产欧美一区二区色老头| 欧美绝品在线观看成人午夜影视| 亚洲在线一区| 亚洲免费观看| 亚洲国产天堂久久国产91| 亚洲欧美日韩国产精品| 一区二区三区免费在线观看| 国内精品模特av私拍在线观看| 国产精品欧美日韩久久| 欧美高清在线视频| 午夜免费日韩视频| 亚洲欧美国产高清va在线播| 亚洲人成在线观看| 国产一区香蕉久久| 欧美福利在线观看| 午夜精品久久久久久久久久久久久 | 欧美国产日韩xxxxx| 亚洲理伦在线| 在线精品视频一区二区三四| 国产精品海角社区在线观看| 亚洲毛片播放| 亚洲精品国产精品国自产观看| 国产一区二区精品| 国产精品视频福利| 国产欧美视频一区二区| 国产精品久久久久国产a级| 欧美视频一区二| 久久久久国产成人精品亚洲午夜| 在线精品视频一区二区| 亚洲欧洲精品一区二区三区| 在线激情影院一区| 亚洲精品永久免费| 亚洲国产91精品在线观看| 国产亚洲精品v| 亚洲大胆美女视频| 91久久精品国产91性色| 99在线视频精品| 亚洲午夜在线观看| 欧美一区二区三区免费观看视频| 欧美一区成人| 久久久久国色av免费观看性色| 欧美成人免费小视频| 欧美国产精品专区| 一区二区国产在线观看| 亚洲亚洲精品在线观看| 亚洲国产一二三| 亚洲午夜小视频| 午夜精品一区二区三区在线| 玖玖综合伊人| 欧美黄色影院| 国产精品视频你懂的| 国产一区视频观看| 亚洲国产精品激情在线观看| 亚洲自拍偷拍福利| 久久久久久免费| 日韩一级大片| 午夜精品一区二区三区在线| 欧美在线高清| 欧美理论大片| 国产丝袜美腿一区二区三区| 国产精品日本一区二区| 欧美视频在线观看免费| 国产精品美女久久久久av超清 | 老色批av在线精品| 国产伦精品一区二区三区免费迷| 国产日韩欧美综合在线| 日韩亚洲成人av在线| 欧美一区二区三区精品| 国产精品国色综合久久| 亚洲国产影院| 午夜亚洲福利在线老司机| 亚洲欧洲日本在线| 欧美一进一出视频| 欧美视频在线观看一区| 亚洲国产高潮在线观看| 亚洲女人天堂成人av在线|