asp.net(C\#)memcached 캐 시 대상 옮 겨 다 니 기

STATS 명령 은 memcached 캐 시 대상(C\#)을 옮 겨 다 니 는 청 초당 을 성능 을 고려 하여 memcached 는 옮 겨 다 니 는 기능 을 제공 하지 않 지만 다음 두 stats 명령 을 통 해 모든 캐 시 대상 을 얻 을 수 있 습 니 다.1.stats items 는 각 slab 의 item 수 를 표시 합 니 다.2、stats cachedump slab_id limit_num 은 어떤 slab 의 앞 limit 를 표시 합 니 다.num 개 key 목록,표시 형식:ITEM keyname [ value_length b; expire_time|access_time s 는 위의 두 개 를 제외 하고 memcached 는 다음 과 같은 명령 을 제공 합 니 다.3,stats 4,stats reset 5,stats malloc 6,stats maps 7,stats sizes 8,stats slabs 9,stats detail[on|of|dump]명령 의 용법 은 일일이 말 하지 않 고 자체 구 글 을 사용 하 십시오.memcached 에 대한 데이터 저장 과 메모리 할당 은 나중에 다시 쓸 수 있 습 니 다.캐 시 를 로 컬 에 몇 개의 key 를 추가 합 니 다.다음 과 같 습 니 다.프로그램 은 c\#호출 을 사용 해 야 하기 때문에 클 라 이언 트 가 STATS 명령 을 실행 해 야 합 니 다.이것 은 DiscuzNT 3.0 의 실현 을 직접 참고 할 수 있 습 니 다.DiscuzNT 다운로드 주소:http://download.comsenz.com/DiscuzNT/src/ 프로그램 을 다운로드 한 후,Discuz.cache 프로젝트 에서 이 두 가지 종 류 를 찾 습 니 다:MemCached.cs 와 MemCached Client.cs.우리 가 사용 하고 자 하 는 방법 은 MemCached.GetStats 코드

 
/// <summary> 
///                
/// </summary> 
/// <param name="serverArrayList">        </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"; 
//  stats     
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; 
} 

MemCached Client.Stats 코드

 
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
": command + "\r
"; 
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; 
} 

입 니 다.이 두 가지 방법 이 있 으 면 memcached 의 캐 시 항목 을 얻 을 수 있 습 니 다.기본 적 인 사 고 는 cache 의 모든 item(stats items)을 얻 은 다음 에 itemid 를 통 해 cachekey 와 cachevalue(stats cachedump)프로그램 을 꺼 내 다음 과 같이 실현 하 는 것 입 니 다.

 
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()); 
} 

실행 프로그램:왜 캐 시 항목 을 출력 하지 않 았 습 니까?DiscuzNT 3.0 의 bug 를 찾 아 보 니 DiscuzNT 3.0 의 bug 로 인 한 것 입 니 다.MemCached Client.Stats 에 이러한 코드 가 있 습 니 다.

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

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

원래 stats cachedump 의 결 과 는 ITEM 으로 시작 되 었 기 때문에 아무것도 출력 하지 않 았 습 니 다.간단하게 수정:

 
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; 
} 

출력 결 과 를 다시 한 번 보면 정상 입 니 다.