Memcached 客户端程序三种API的比较

chenkehao

Memcached 客户端程序
Memcached的java客户端已经存在三种了：
?  官方提供的基于传统阻塞io由Greg Whalin维护的客户端
?  Dustin Sallings实现的基于java nio的Spymemcached
?  XMemcached

1. 三种API比较
1)      memcached client for java
较早推出的memcached JAVA客户端API，应用广泛，运行比较稳定。

2)      spymemcached
A simple, asynchronous, single-threaded memcached client written in java. 支持异步，单线程的memcached客户端，用到了java1.5版本的concurrent和nio，存取速度会高于前者，但是稳定性不好，测试中常 报timeOut等相关异常。

3)      xmemcached
XMemcached同样是基于java nio的客户端，java nio相比于传统阻塞io模型来说，有效率高（特别在高并发下）和资源耗费相对较少的优点。传统阻塞IO为了提高效率，需要创建一定数量的连接形成连接 池，而nio仅需要一个连接即可（当然,nio也是可以做池化处理），相对来说减少了线程创建和切换的开销，这一点在高并发下特别明显。因此 XMemcached与Spymemcached在性能都非常优秀，在某些方面（存储的数据比较小的情况下）Xmemcached比 Spymemcached的表现更为优秀，具体可以看这个Java Memcached Clients Benchmark。

2.  建议
由于memcached client for java发布了新版本，性能上有所提高，并且运行稳定，所以建议使用memcached client for java。
XMemcached也使用得比较广泛，而且有较详细的中文API文档，具有如下特点：高性 能、支持完整的协议、支持客户端分布、允许设置节点权重、动态增删节点、支持JMX、与Spring框架和Hibernate-memcached的集 成、客户端连接池、可扩展性好等。
下面给出这三种客户端的示例程序。

3.  示例程序
1)      memcached client for java
从前面介绍的Java环境的Memcached客户端程序项目网址里，下载最新版的客户端程 序包：java_memcached-release_2.5.1.zip，解压后，文件夹里找到java_memcached- release_2.5.1.jar，这个就是客户端的JAR包。将此JAR包添加到项目的构建路径里，则项目中，就可以使用Memcached了。
示例代码如下：
package temp;

import com.danga.MemCached.*;
import org.apache.log4j.*;

public class CacheTest {
public static void main(String[] args) {
/**
* 初始化SockIOPool，管理memcached的连接池
* */
String[] servers = { "10.11.15.222:10000" };
SockIOPool pool = SockIOPool.getInstance();
pool.setServers(servers);
pool.setFailover(true);
pool.setInitConn(10);
pool.setMinConn(5);
pool.setMaxConn(250);
pool.setMaintSleep(30);
pool.setNagle(false);
pool.setSocketTO(3000);
pool.setAliveCheck(true);
pool.initialize();
/**
* 建立MemcachedClient实例
* */
MemCachedClient memCachedClient = new MemCachedClient();
for (int i = 0; i < 1000; i++) {
/**
* 将对象加入到memcached缓存
* */
boolean success = memCachedClient.set(&quot;&quot; + i, &quot;Hello!&quot;);
/**
* 从memcached缓存中按key值取对象
* */
String result = (String) memCachedClient.get(&quot;&quot; + i);
System.out.println(String.format(&quot;set( %d ): %s&quot;, i, success));
System.out.println(String.format(&quot;get( %d ): %s&quot;, i, result));
}
}
}

2)      spymemcached
spymemcached当前版本是2.5版本，官方网址是：http://code.google.com/p/spymemcached/。可以从地址：http://spymemcached.googlecode.com/files/memcached-2.5.jar 下载最新版本来使用。
示例代码如下：
package temp;

import java.net.InetSocketAddress;
import java.util.concurrent.Future;

import net.spy.memcached.MemcachedClient;

public class TestSpyMemcache {
public static void main(String[] args) {
// 保存对象
try {
/* 建立MemcachedClient 实例，并指定memcached服务的IP地址和端口号 */
MemcachedClient mc = new MemcachedClient(new InetSocketAddress(&quot;10.11.15.222&quot;, 10000));
Future<Boolean> b = null;
/* 将key值，过期时间(秒)和要缓存的对象set到memcached中 */
b = mc.set(&quot;neea:testDaF:ksIdno&quot;, 900, &quot;someObject&quot;);
if (b.get().booleanValue() == true) {
mc.shutdown();
}
} catch (Exception ex) {
ex.printStackTrace();
}
// 取得对象
try {
/* 建立MemcachedClient 实例，并指定memcached服务的IP地址和端口号 */
MemcachedClient mc = new MemcachedClient(new InetSocketAddress(&quot;10.11.15.222&quot;, 10000));
/* 按照key值从memcached中查找缓存，不存在则返回null */
Object b = mc.get(&quot;neea:testDaF:ksIdno&quot;);
System.out.println(b.toString());
mc.shutdown();
} catch (Exception ex) {
ex.printStackTrace();
}
}
}

3)      xmemcached
Xmemcached的官方网址是：http://code.google.com/p/xmemcached/，可以从其官网上下载最新版本的1.2.4 来使用。地址是：http://xmemcached.googlecode.com/files/xmemcached-1.2.4-src.tar.gz 。
示例代码如下：
package temp;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

import net.rubyeye.xmemcached.utils.AddrUtil;
import net.rubyeye.xmemcached.MemcachedClient;
import net.rubyeye.xmemcached.MemcachedClientBuilder;
import net.rubyeye.xmemcached.XMemcachedClientBuilder;
import net.rubyeye.xmemcached.exception.MemcachedException;

public class TestXMemcache {
public static void main(String[] args) {
MemcachedClientBuilder builder = new XMemcachedClientBuilder(AddrUtil
.getAddresses(&quot;10.11.15.222:10000&quot;));
MemcachedClient memcachedClient;
try {
memcachedClient = builder.build();
memcachedClient.set(&quot;hello&quot;, 0, &quot;Hello,xmemcached&quot;);
String value = memcachedClient.get(&quot;hello&quot;);
System.out.println(&quot;hello=&quot; + value);
memcachedClient.delete(&quot;hello&quot;);
value = memcachedClient.get(&quot;hello&quot;);
System.out.println(&quot;hello=&quot; + value);
// close memcached client
memcachedClient.shutdown();
} catch (MemcachedException e) {
System.err.println(&quot;MemcachedClient operation fail&quot;);
e.printStackTrace();
} catch (TimeoutException e) {
System.err.println(&quot;MemcachedClient operation timeout&quot;);
e.printStackTrace();
} catch (InterruptedException e) {
// ignore
}catch (IOException e) {
System.err.println(&quot;Shutdown MemcachedClient fail&quot;);
e.printStackTrace();
}
}
}