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

阿二的夢想船

 

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>
            欧美精品导航| 中文无字幕一区二区三区| 久久国产精品一区二区| 国产午夜精品美女视频明星a级| 欧美有码视频| 久久久久国内| 99在线精品视频在线观看| 日韩五码在线| 国产午夜精品美女视频明星a级 | 国产精品久久久久久久免费软件 | 亚洲黄色天堂| 欧美日韩黄视频| 欧美一区二区| 免费观看在线综合色| 亚洲一区区二区| 久久激情五月激情| 亚洲精品影视| 性色av一区二区三区在线观看| 在线欧美视频| 亚洲深夜福利| 亚洲欧洲美洲综合色网| 亚洲一区二区少妇| 亚洲国产婷婷| 亚洲一区在线播放| 亚洲品质自拍| 午夜精品一区二区三区在线视 | 国产精品羞羞答答| 欧美高清在线视频| 国产欧美日韩一区二区三区| 欧美不卡在线| 国产日韩av一区二区| 最近中文字幕mv在线一区二区三区四区 | 男女激情久久| 国产精品视频区| 亚洲国产精彩中文乱码av在线播放| 欧美午夜在线| 亚洲黄色有码视频| 国产亚洲精品福利| 亚洲一区二区三区四区中文| 亚洲裸体俱乐部裸体舞表演av| 亚欧成人精品| 亚洲自拍偷拍一区| 欧美日韩成人网| 欧美成人精品h版在线观看| 国产精品永久免费| 99国产精品久久久久久久成人热 | 永久免费毛片在线播放不卡| 国产精品久久久久久影视| 亚洲第一精品影视| 尹人成人综合网| 久久精品国产v日韩v亚洲 | 亚洲欧洲一区二区在线播放| 在线观看一区| 久久综合九色综合网站| 久久亚洲一区二区| 国内精品伊人久久久久av影院| 亚洲性av在线| 亚洲欧美影音先锋| 国产精品劲爆视频| 亚洲香蕉网站| 欧美在线一二三| 国产欧美日韩在线观看| 亚洲综合成人婷婷小说| 午夜精品久久| 国产欧美日韩视频一区二区三区 | 欧美在线免费视频| 久久久免费精品视频| 国产在线观看91精品一区| 午夜免费久久久久| 久久久久久久波多野高潮日日 | 国产精品劲爆视频| 亚洲欧美文学| 欧美.www| 日韩亚洲欧美综合| 欧美午夜不卡影院在线观看完整版免费| 亚洲国产精品成人va在线观看| 91久久国产综合久久| 欧美精品啪啪| 午夜天堂精品久久久久 | 一区二区三区毛片| 国产精品高潮久久| 午夜精品国产| 免费久久99精品国产| 亚洲精品一区二| 欧美日韩日本国产亚洲在线| 亚洲午夜国产成人av电影男同| 欧美一区二粉嫩精品国产一线天| 国产午夜精品久久久久久免费视 | 欧美亚洲三级| 亚洲国产精品久久久| 午夜免费日韩视频| 伊人一区二区三区久久精品| 欧美日产国产成人免费图片| 亚洲一区二区三区视频播放| 免费国产一区二区| 亚洲午夜精品17c| 国产一区二区三区成人欧美日韩在线观看 | 欧美日韩一区国产| 久久久久国产一区二区三区四区| 亚洲三级性片| 久久精选视频| 中文在线一区| 激情一区二区| 国产精品v欧美精品v日韩精品| 久久精品国产亚洲a| 亚洲精品一区在线| 久久久久综合| 午夜精品视频在线观看| 亚洲高清在线视频| 国产精品久久网| 欧美成人dvd在线视频| 亚洲在线中文字幕| 亚洲国产专区| 狼狼综合久久久久综合网| 亚洲一级在线| 日韩午夜中文字幕| 亚洲成色精品| 国产一区二区三区高清播放| 欧美色网一区二区| 欧美成人精品三级在线观看| 欧美一区二区三区四区在线观看 | 亚洲国产综合在线| 欧美a级片网站| 久久国产欧美精品| 亚洲特级片在线| 99国产精品视频免费观看| 一区二区三区我不卡| 国产欧美一区二区三区国产幕精品| 欧美精品一区二区蜜臀亚洲| 久久这里有精品15一区二区三区| 性色av香蕉一区二区| 亚洲一区二区高清| 一区二区三区蜜桃网| 亚洲日本成人网| 亚洲欧洲精品一区二区三区不卡 | 亚洲免费影院| 亚洲综合第一| 先锋影音久久久| 亚洲免费综合| 欧美在线不卡视频| 欧美一区二区精美| 久久爱www久久做| 午夜视频久久久久久| 欧美一区二区三区四区在线| 亚洲欧美在线一区| 久久精品国产v日韩v亚洲| 欧美在线观看一区| 久久国产一区二区三区| 久久av最新网址| 久久久久国产一区二区三区四区| 欧美在线日韩精品| 美女精品自拍一二三四| 美日韩在线观看| 欧美精品国产精品| 欧美天天综合网| 国产香蕉久久精品综合网| 国精品一区二区| 亚洲大片精品永久免费| 亚洲精品一区二区三区99| 亚洲视频欧美视频| 欧美一级在线亚洲天堂| 久久精品国产精品亚洲精品| 麻豆九一精品爱看视频在线观看免费| 欧美v国产在线一区二区三区| 亚洲国产婷婷| 亚洲一区免费看| 久久婷婷国产综合国色天香| 欧美福利精品| 国产精品扒开腿做爽爽爽软件| 国产一级揄自揄精品视频| 亚洲二区在线观看| 亚洲一区二区三区高清| 久久国产主播| 亚洲三级免费电影| 欧美在线观看视频| 欧美伦理在线观看| 国产一区视频在线看| 99国产成+人+综合+亚洲欧美| 性欧美xxxx大乳国产app| 欧美肥婆bbw| 亚洲欧美视频一区| 欧美精品一区二区三区视频| 国产亚洲一二三区| 亚洲社区在线观看| 美女视频黄a大片欧美| 亚洲午夜精品福利| 久久一区二区三区超碰国产精品| 欧美日韩在线播放一区| 黄色成人在线网站| 亚洲欧美精品在线| 亚洲高清二区| 欧美在线影院在线视频| 欧美午夜精彩| 99国产精品视频免费观看| 久久婷婷麻豆| 亚洲欧美日韩精品久久久久| 欧美国产精品一区| 在线免费观看成人网| 羞羞漫画18久久大片| 日韩午夜高潮|