使用Java代码遍历Memcached的Items

import java.net.URLDecoder;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.Hashtable;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import com.able.util.LogUtil;
import com.danga.MemCached.MemCachedClient;
import com.danga.MemCached.SockIOPool;
import com.danga.MemCached.SockIOPool.SockIO;

public class MemCacheInvoke {
 protected static MemCachedClient mc = new MemCachedClient();

 static {

  // 设置缓存服务器列表
  String[] servers = { "192.168.9.160:11211"};

  // 设置服务器权重
  Integer[] weights = { 10 };

  // 创建一个Socked连接池实例
  SockIOPool pool = SockIOPool.getInstance();

  // 向连接池设置服务器和权重
  pool.setServers(servers);
  pool.setWeights(weights);

  // set some TCP settings
  // disable nagle
  // set the read timeout to 3 secs
  // and don't set a connect timeout
  pool.setNagle(false);
  pool.setSocketTO(3000);
  pool.setSocketConnectTO(0);

  // initialize the connection pool
  pool.initialize();
 }

 public static void main(String[] args) {
  //  mcc.set("foo3", "This is a test String");
  // mcc.delete("foo");
  // String bar = mcc.get("foo3").toString();
  long startDate = System.currentTimeMillis();

  for (int i = 0; i < 100; i++) { 
    mc.add("test"+i , "中国"+i); 
  } 
  
  System.out.print(" get value : " + mc.get("test1"));
  long endDate = System.currentTimeMillis();

  long nowDate = (endDate - startDate) / 1000;

  //  System.out.println(nowDate); 

  // System.out.println("="+mc.statsItems());

      MemCacheInvoke aa=new MemCacheInvoke();
      aa.getKeys();

  // System.out.println("aa="+ mc.statsCacheDump(0, 100).toString());

 }

 public void getKeys() {
  List<String> logs = new ArrayList<String>();
  System.out.println(mc.stats());
  logs.add(mc.stats().toString());
  logs.add(" -- end stats --");
  //ArrayList keys = new ArrayList();
  // 取得 所有 memcached server ,可能有多台 server
  Map slabs = mc.statsItems();
  logs.add(slabs.toString());
  logs.add(" -- end statsItems --");
  // key= ip:port, ex: 192.168.1.2:11211,192.168.1.2:11212...
  Iterator itemsItr = slabs.keySet().iterator();

  // 以server IP key值去迴圈,可能有多台 server
  while (itemsItr.hasNext()) {
   String serverInfo1 = itemsItr.next().toString();
   // 取得這個server的各種 status [itemname:number:field=value]
   Map itemNames = (Map) slabs.get(serverInfo1);
   Iterator itemNameItr = itemNames.keySet().iterator();

   // 以status key值去迴圈
   while (itemNameItr.hasNext()) {
    String itemName = itemNameItr.next().toString();
    // 拆解status 欄位
    // itemAtt[0] = itemname
    // itemAtt[1] = CacheDump的參數
    // itemAtt[2] = field:number or age
    String[] itemAtt = itemName.split(":");
    // 要取得field為number的CacheDump參數
    if (itemAtt[2].startsWith("number")) {
     // 以status取到的參數,取得cachedDump Map...(下面Map名稱命錯了)
     // ServerIP<cachekey<byte size;unix timestamp>>
     Map chcheDump = mc.statsCacheDump(Integer.parseInt(itemAtt[1]), 0);
     //ystem.out.println(chcheDump);
     Iterator itr = chcheDump.keySet().iterator();
     // 以server IP key值去迴圈,可能有多台 server
     int i = 0;
     while (itr.hasNext()) {
      // key=ip:port
      String serverInfo2 = itr.next().toString();
      // 取得Cached Key Map...<-終於,這才是我要的Key集合
      Map items = (Map) chcheDump.get(serverInfo2);
      //System.out.println(items);
      Iterator keyItr = items.keySet().iterator();
      //以Cached Key 去迴圈,取key出來,或是要取size,unix timestamp 也有
      while (keyItr.hasNext()) {
       String key = keyItr.next().toString();
       String memKey = key;
       i++;
       try {
        key = URLDecoder.decode(key, "UTF-8");
        String value = ((String) items.get(memKey));
        value = value.substring(value.indexOf(";") + 2, value.indexOf(" s"));
        Date date = new Date();
        date.setTime(Long.valueOf(value + "000"));
        logs.add(key + " --- " + items.get(memKey) + " -- " + value + " -- " + date);
        //System.out.println(key + " --- " + items.get(memKey) + " -- " + value + " -- " + date);
       } catch (Exception ex) {
        logs.add("error:" + ex.getMessage());
        //System.out.println("error:" + ex.getMessage());
       }
      }
     }
    }
   }
  }
  LogUtil.commandlog(logs,"/var/www/log/memcached.log");
 }

}