memcache简单实例

q989

　　Memcache的Java客户端接口参见：http://code.google.com/p/memcached/wiki/Clients。示例程序如下：
　　（1）建立Manager类
　　package com.alisoft.sme.memcached;
　　import java.util.Date;
　　import com.danga.MemCached.MemCachedClient;
import com.danga.MemCached.SockIOPool;
　　public class MemCachedManager {
　　// 创建全局的唯一实例
 protected static MemCachedClient mcc = new MemCachedClient();
　　protected static MemCachedManager memCachedManager = new MemCachedManager();
　　// 设置与缓存服务器的连接池
 static {
  // 服务器列表和其权重
  String[] servers = { "127.0.0.1:11211" };
  Integer[] weights = { 3 };
　　// 获取socke连接池的实例对象
  SockIOPool pool = SockIOPool.getInstance();
　　// 设置服务器信息
  pool.setServers(servers);
  pool.setWeights(weights);
　　// 设置初始连接数、最小和最大连接数以及最大处理时间
  pool.setInitConn(5);
  pool.setMinConn(5);
  pool.setMaxConn(250);
  pool.setMaxIdle(1000 * 60 * 60 * 6);
　　// 设置主线程的睡眠时间
  pool.setMaintSleep(30);
　　// 设置TCP的参数，连接超时等
  pool.setNagle(false);
  pool.setSocketTO(3000);
  pool.setSocketConnectTO(0);
　　// 初始化连接池
  pool.initialize();
　　// 压缩设置，超过指定大小（单位为K）的数据都会被压缩
  mcc.setCompressEnable(true);
  mcc.setCompressThreshold(64 * 1024);
 }
　　
 protected MemCachedManager() {
　　}
　　
 public static MemCachedManager getInstance() {
  return memCachedManager;
 }
　　
 public boolean add(String key, Object value) {
  return mcc.add(key, value);
 }
　　public boolean add(String key, Object value, Date expiry) {
  return mcc.add(key, value, expiry);
 }
　　public boolean replace(String key, Object value) {
  return mcc.replace(key, value);
 }
　　public boolean replace(String key, Object value, Date expiry) {
  return mcc.replace(key, value, expiry);
 }
　　
 public Object get(String key) {
  return mcc.get(key);
 }
　　public static void main(String[] args) {
  MemCachedManager cache = MemCachedManager.getInstance();
  cache.add("hello", 234);
  System.out.print("get value : " + cache.get("hello"));
 }
}
　　（2）建立数据对象
　　package com.alisoft.sme.memcached;
　　import java.io.Serializable;
　　public class TBean implements Serializable {
 
 private static final long serialVersionUID = 1945562032261336919L;
　　 private String name;
　　 public String getName() {
  return name;
 }
　　 public void setName(String name) {
  this.name = name;
 }
}
　　--------------------------------------------------------------------------------------------------
　　创建测试用例：
　　package com.alisoft.sme.memcached.test;
　　import junit.framework.TestCase;
　　import org.junit.Test;
　　import com.alisoft.sme.memcached.MemCachedManager;
import com.alisoft.sme.memcached.TBean;
　　public class TestMemcached extends TestCase {
　　 private static MemCachedManager cache;
　　 @Test
 public void testCache() {
  
  TBean tb = new TBean();
  tb.setName("E网打进");
  cache.add("bean", tb);
  
  TBean tb1 = (TBean) cache.get("bean");
  System.out.println("name=" + tb1.getName());
  tb1.setName("E网打进_修改的");
  
  tb1 = (TBean) cache.get("bean");
  System.out.println("name=" + tb1.getName());
 }
　　 @Override
 protected void setUp() throws Exception {
  super.setUp();
  cache = MemCachedManager.getInstance();
 }
　　 @Override
 protected void tearDown() throws Exception {
  super.tearDown();
  cache = null;
 }
　　}