package com.chauvet.utils.memcached;import com.chauvet.utils.ConfigUtil;import com.danga.MemCached.MemCachedClient;import com.danga.MemCached.SockIOPool;public class MemcacheUtil {        private static MemcacheUtil util;    private static MemCachedClient cache = new MemCachedClient();           private MemcacheUtil() {    }    public static MemcacheUtil getInstance() {        if (util == null) {            util = new MemcacheUtil();        }        return util;    }                    static {        ConfigUtil configUtil = ConfigUtil.getInstance();        String memcacheServer = configUtil.getMemcacheServer(); // 从配置文件中获取memcache服务器地址        System.out.println(memcacheServer);                String[] servers ={// 设置缓存服务器列表，当使用分布式缓存的时，可以指定多个缓存服务器。                    memcacheServer                    /**                     * IP:端口，                     * IP:端口，                     * IP:端口                     */                };                      Integer[] weights = { 3 }; // 设置服务器权重               //创建一个实例对象SockIOPool             SockIOPool pool = SockIOPool.getInstance();                      // 设置servers 和  weights            pool.setServers( servers );               pool.setWeights( weights );                      // set some basic pool settings               // 5 initial, 5 min, and 250 max conns               // and set the max idle time for a conn               // to 6 hours               pool.setInitConn( 5 );               pool.setMinConn( 5 );               pool.setMaxConn( 250 );               pool.setMaxIdle( 1000 * 60 * 60 * 6 );                      // set the sleep for the maint thread               // it will wake up every x seconds and               // maintain the pool size               pool.setMaintSleep( 30 );                      // Tcp的规则就是在发送一个包之前，本地机器会等待远程主机            // 对上一次发送的包的确认信息到来；这个方法就可以关闭套接字的缓存，            // 以至这个包准备好了就发；            pool.setNagle( false );               //连接建立后对超时的控制            pool.setSocketTO( 3000 );            //连接建立时对超时的控制            pool.setSocketConnectTO( 0 );                      // initialize the connection pool               //初始化一些值并与MemutildServer段建立连接            pool.initialize();                                  // lets set some compression on for the client               // compress anything larger than 64k               //cache.setCompressEnable( true );               //cache.setCompressThreshold( 64 * 1024 );           }               public static void buildCacheWithKey(String key,String value){        cache.set(key, value); // 将key存入缓存    }        public static void bulidCache(){               //set(key,value,Date) ,Date是一个过期时间，如果想让这个过期时间生效的话，这里传递的new Date(long date) 中参数date，需要是个大于或等于1000的值。            //因为java client的实现源码里是这样实现的 expiry.getTime() / 1000 ，也就是说，如果 小于1000的值，除以1000以后都是0，即永不过期            cache.set("DEVICE_NETWORK_TYPE:01A111201406010214", "bulidCacheSuccess",0);       }        /** 清空cache**/    public static void flushAll(){        cache.flushAll();    }        public Object getValue(String key) {              return cache.get(key);    }               public static void main(String[] args){        flushAll();         bulidCache();        //MemCachedUtil.buildCacheWithKey("wwwwwww");        Object obj = MemcacheUtil.getInstance().getValue("DEVICE_NETWORK_TYPE:01A111201406010214");        System.out.println(obj);    }     }