memcache简单实例

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

}