论坛 › Memcached › java MemCache client application Model

缘来路过 发表于 2017-4-15 09:05:43

java MemCache client application Model

这段时间解决系统的瓶颈，首要是对memcache的优化，今天得空将目前在用的memcache整理了一下，贴个客户端实体类-----这里设置的参数都是通过配置文件的。道理很简单，以戒后用
（注：http://code.google.com/p/memcache-client-forjava/downloads/list 本次使用的是来自这里的封装包，网上结论说alisoft memcache 性能不高，经高压下使用，个人感觉确实不妥。
可考虑使用 http://www.whalin.com/memcached/#download ）
package yixun.wap.cache;

/** *//**
* @deprecated mem-cache缓存类 备用类
* @author Administrator
* @date 2009-11-15 14:08:02 更新
*/
import java.util.Date;
import com.alisoft.xplatform.asf.cache.memcached.client.MemCachedClient;
import com.alisoft.xplatform.asf.cache.memcached.client.SockIOPool;
import yixun.wap.resourcesload.MemcacheConfig;

public class MemCache {
    private static MemCachedClient mcc = null;
    static {
      mcc = new MemCachedClient();
      Boolean nagle = false;
      Boolean ce = true;
      
//         获取socke连接池的实例对象
      SockIOPool pool = SockIOPool.getInstance();
      
//         设置服务器信息
      pool.setServers(MemcacheConfig.getServers().split(";"));
      String[] weights = MemcacheConfig.getWeights().split(";");
      Integer[] wei = new Integer;
      for (int i = 0; i < weights.length; i++) {
            wei = Integer.parseInt(weights);
      }
      pool.setWeights(wei);
      
      
//         设置初始连接数、最小和最大连接数以及最大处理时间
      pool.setInitConn(Integer.parseInt(MemcacheConfig.getInitconn()));
      pool.setMinConn(Integer.parseInt(MemcacheConfig.getMinconn()));
      pool.setMaxConn(Integer.parseInt(MemcacheConfig.getMaxconn()));
      pool.setMaxIdle(Long.parseLong(MemcacheConfig.getMaxidle()));
      
//         设置主线程的睡眠时间
      pool.setMaintSleep(Long.parseLong(MemcacheConfig.getMaintsleep()));
      if (!MemcacheConfig.getNagle().equals("false")) {
            nagle = true;
      }
      
//         设置TCP的参数，连接超时等
      pool.setNagle(nagle);
      pool.setSocketTO(Integer.parseInt(MemcacheConfig.getSocketTO()));
      pool.setSocketConnectTO(Integer.parseInt(MemcacheConfig.getSocketConnectTO()));
      
//         初始化连接池
      pool.initialize();
      
//         压缩设置，超过指定大小（单位为K）的数据都会被压缩
      if (MemcacheConfig.getCompressEnable().equals("false")) {
            ce = false;
      }      
      mcc.setCompressEnable(ce);
      mcc.setCompressThreshold(Long.parseLong(MemcacheConfig.getCompressThreshold()));
      
    }
    private MemCache(){
      
    }
    private static MemCache instance;
    public synchronizedstatic MemCache getInstance() {
      if(instance == null) {
            return new MemCache();
      }
      return instance;
    }
   
   
//    在memcache中对数据进行存、取、删、更新
    public boolean set(String key, Object value) {
      return mcc.set(key, value);
    }

    public boolean set(String key, Object value, String time) {
      return mcc.set(key, value, new Date(Long.parseLong(time)));
    }

    public Object get(String key) {
      return mcc.get(key);
    }

    public boolean delete(String key) {
      return mcc.delete(key);
    }
   
    public boolean update(String key, Object obj) {
      return mcc.replace(key, obj);
    }
   
    public boolean update(String key, Object value, Date expiry) {
      return mcc.replace(key, value, expiry);
    }
   
    public void flush_all() {
      mcc.flushAll();
    }


    public MemCachedClient getMcc() {
      return mcc;
    }


    public void setMcc(MemCachedClient mcc) {
      this.mcc = mcc;
    }

}

查看完整版本: java MemCache client application Model