asp.net(C#)遍歷memcached緩存對(duì)象

更新時(shí)間：2010年03月04日 19:38:43 作者：

出于性能考慮，memcached沒(méi)有提供遍歷功能，不過(guò)我們可以通過(guò)以下兩個(gè)stats命令得到所有的緩存對(duì)象。

STATS命令

遍歷memcached緩存對(duì)象（C#）轉(zhuǎn)載之青草堂
出于性能考慮，memcached沒(méi)有提供遍歷功能，不過(guò)我們可以通過(guò)以下兩個(gè)stats命令得到所有的緩存對(duì)象。
1、stats items

顯示各個(gè)slab中item的數(shù)目。
2、stats cachedump slab_id limit_num
顯示某個(gè)slab中的前l(fā)imit_num個(gè)key列表，顯示格式：ITEM key_name [ value_length b; expire_time|access_time s]
除了上面兩個(gè)，memcached還提供了以下命令：

3、stats
4、 stats reset
5、 stats malloc
6、 stats maps
7、 stats sizes
8、 stats slabs
9、 stats detail [on|off|dump]
命令的用法就不一一說(shuō)了，請(qǐng)自行g(shù)oogle。關(guān)于memcached的數(shù)據(jù)存儲(chǔ)和內(nèi)存分配以后有機(jī)會(huì)再寫(xiě)。

添加緩存
在本地添加幾個(gè)key，如下：

程序?qū)崿F(xiàn)
因?yàn)橐胏#調(diào)用，所以需要客戶端執(zhí)行 STATS 命令，這個(gè)可以直接參考DiscuzNT3.0中的實(shí)現(xiàn)。
DiscuzNT下載地址：http://download.comsenz.com/DiscuzNT/src/
下載完程序以后，在Discuz.Cache項(xiàng)目中找到這兩個(gè)類：MemCached.cs和MemCachedClient.cs。
我們要用到的方法有：
MemCached.GetStats
代碼

復(fù)制代碼代碼如下:

 
/// <summary> 
/// 獲取服 務(wù)器端緩存的數(shù)據(jù)信息 
/// </summary> 
/// <param name="serverArrayList">要訪問(wèn)的服務(wù)列表</param> 
/// <returns>返 回信息</returns> 
public static ArrayList GetStats(ArrayList serverArrayList, Stats statsCommand, string param) 
{ 
ArrayList statsArray = new ArrayList(); 
param = Utils.StrIsNullOrEmpty(param) ? "" : param.Trim().ToLower(); 
string commandstr = "stats"; 
//轉(zhuǎn)換stats命令參數(shù) 
switch (statsCommand) 
{ 
case Stats.Reset: { commandstr = "stats reset"; break; } 
case Stats.Malloc: { commandstr = "stats malloc"; break; } 
case Stats.Maps: { commandstr = "stats maps"; break; } 
case Stats.Sizes: { commandstr = "stats sizes"; break; } 
case Stats.Slabs: { commandstr = "stats slabs"; break; } 
case Stats.Items: { commandstr = "stats"; break; } 
case Stats.CachedDump: 
{ 
string[] statsparams = Utils.SplitString(param, " "); 
if(statsparams.Length == 2) 
if(Utils.IsNumericArray(statsparams)) 
commandstr = "stats cachedump " + param; 
break; 
} 
case Stats.Detail: 
{ 
if(string.Equals(param, "on") || string.Equals(param, "off") || string.Equals(param, "dump")) 
commandstr = "stats detail " + param.Trim(); 
break; 
} 
default: { commandstr = "stats"; break; } 
} 
//加載返回值 
Hashtable stats = MemCachedManager.CacheClient.Stats(serverArrayList, commandstr); 
foreach (string key in stats.Keys) 
{ 
statsArray.Add(key); 
Hashtable values = (Hashtable)stats[key]; 
foreach (string key2 in values.Keys) 
{ 
statsArray.Add(key2 + ":" + values[key2]); 
} 
} 
return statsArray; 
} 

MemCachedClient.Stats
代碼

復(fù)制代碼代碼如下:

 
public Hashtable Stats(ArrayList servers, string command) 
{ 
// get SockIOPool instance 
SockIOPool pool = SockIOPool.GetInstance(_poolName); 
// return false if unable to get SockIO obj 
if(pool == null) 
{ 
//if(log.IsErrorEnabled) 
//{ 
// log.Error(GetLocalizedString("unable to get socket pool")); 
//} 
return null; 
} 
// get all servers and iterate over them 
if (servers == null) 
servers = pool.Servers; 
// if no servers, then return early 
if(servers == null || servers.Count <= 0) 
{ 
//if(log.IsErrorEnabled) 
//{ 
// log.Error(GetLocalizedString("stats no servers")); 
//} 
return null; 
} 
// array of stats Hashtables 
Hashtable statsMaps = new Hashtable(); 
for(int i = 0; i < servers.Count; i++) 
{ 
SockIO sock = pool.GetConnection((string)servers[i]); 
if(sock == null) 
{ 
//if(log.IsErrorEnabled) 
//{ 
// log.Error(GetLocalizedString("unable to connect").Replace("$$Server$$", servers[i].ToString())); 
//} 
continue; 
} 
// build command 
command = Discuz.Common.Utils.StrIsNullOrEmpty(command) ? "stats\r\n": command + "\r\n"; 
try 
{ 
sock.Write(UTF8Encoding.UTF8.GetBytes(command)); 
sock.Flush(); 
// map to hold key value pairs 
Hashtable stats = new Hashtable(); 
// loop over results 
while(true) 
{ 
string line = sock.ReadLine(); 
//if(log.IsDebugEnabled) 
//{ 
// log.Debug(GetLocalizedString("stats line").Replace("$$Line$$", line)); 
//} 
if(line.StartsWith(STATS)) 
{ 
string[] info = line.Split(' '); 
string key = info[1]; 
string val = info[2]; 
//if(log.IsDebugEnabled) 
//{ 
// log.Debug(GetLocalizedString("stats success").Replace("$$Key$$", key).Replace("$$Value$$", val)); 
//} 
stats[ key ] = val; 
} 
else if(END == line) 
{ 
// finish when we get end from server 
//if(log.IsDebugEnabled) 
//{ 
// log.Debug(GetLocalizedString("stats finished")); 
//} 
break; 
} 
statsMaps[ servers[i] ] = stats; 
} 
} 
catch//(IOException e) 
{ 
//if(log.IsErrorEnabled) 
//{ 
// log.Error(GetLocalizedString("stats IOException"), e); 
//} 
try 
{ 
sock.TrueClose(); 
} 
catch//(IOException) 
{ 
//if(log.IsErrorEnabled) 
//{ 
// log.Error(GetLocalizedString("failed to close some socket").Replace("$$Socket$$", sock.ToString())); 
//} 
} 
sock = null; 
} 
if(sock != null) 
sock.Close(); 
} 
return statsMaps; 
} 

有了這兩個(gè)方法我們就可以得到memcached中的緩存項(xiàng)了。
基本思路是，先得到cache中所有的item（stats items），再通過(guò)itemid 取出cachekey和cachevalue（stats cachedump）
程序?qū)崿F(xiàn)如下：

復(fù)制代碼代碼如下:

 
private void GetItems() 
{ 
ArrayList itemarr = new ArrayList(); 
ArrayList arrayList = new ArrayList(); 
StringBuilder sb = new StringBuilder(); 
foreach (string server in MemCachedManager.ServerList) 
{ 
arrayList.Add(server); 
} 
ArrayList arr = MemCachedManager.GetStats(arrayList, MemCachedManager.Stats.Items, null); 
foreach (string a in arr) 
{ 
string[] tmparr = a.Split(':'); 
if (tmparr.Length > 1) 
{ 
int item_id = 0; 
int.TryParse(tmparr[1], out item_id); 
bool find = false; 
foreach (int item in itemarr) 
{ 
if (item == item_id) 
find = true; 
} 
if (!find && item_id > 0 && item_id != 11211) 
itemarr.Add(item_id); 
} 
} 
foreach (int item in itemarr) 
{ 
sb.Append("item " + item + "<br />"); 
ArrayList cachearr = MemCachedManager.GetStats(arrayList, MemCachedManager.Stats.CachedDump, "" + item + " 10"); 
foreach (string cache in cachearr) 
{ 
sb.Append(cache); 
sb.Append("<br />"); 
} 
} 
Response.Write(sb.ToString()); 
} 

運(yùn)行程序：

為什么沒(méi)有輸出緩存項(xiàng)呢？

DiscuzNT3.0中的bug

于是我找啊找，發(fā)現(xiàn)是DiscuzNT3.0中的一個(gè)bug導(dǎo)致。

在MemCachedClient.Stats中，有這樣的一段代碼：

復(fù)制代碼代碼如下:

 
if(line.StartsWith(STATS)) 
{ 
string[] info = line.Split(' '); 
string key = info[1]; 
string val = info[2]; 
stats[ key ] = val; 

} 
else if(END == line) 
{ 
break; 
} 

原來(lái)是忽略了stats cachedump 的結(jié)果是以ITEM開(kāi)頭的，所以什么都沒(méi)有輸出。簡(jiǎn)單修改一下：

復(fù)制代碼代碼如下:

 
if(line.StartsWith(STATS) ) 
{ 
string[] info = line.Split(' '); 
string key = info[1]; 
string val = info[2]; 
stats[ key ] = val; 

} 
else if (line.StartsWith("ITEM")) 
{ 
string[] info = line.Split('['); 
string key = info[0].Split(' ')[1]; 
string val = "[" + info[1]; 

stats[key] = val; 
} 
else if (END == line) 
{ 
break; 
} 