基于java nio的memcached客户端——xmemcached

JavamemcachedGoogle编程Gmail

1、xmemcached是什么？

xmemcached是基于javanio实现的memcached客户端API。

实际上是基于我实现的一个简单nio框架http://code.google.com/p/yanf4j/的基础上实现的(目前是基于yanf4j0.52)，核心代码不超过1000行，序列化机制直接挪用spymemcached的Transcoder。

性能方面，在读写简单类型上比之spymemcached还是有差距，在读写比较大的对象（如集合）有效率优势。

当前0.50-beta版本，仅支持单个memcached服务器，以后考虑扩展。目前已经支持get、set、add、replace、delete、incr、decr、version这几个协议。API为阻塞模型，而非spymemcached的异步模式，异步模型在批处理的时候有优势，但是阻塞模式在编程难度和使用上会容易很多。

2、为什么叫xmemcached?

因为我在厦门（XM）混饭......

3、xmemcached的下载和使用

项目主页：http://code.google.com/p/xmemcached/

下载地址：http://code.google.com/p/xmemcached/downloads/list

下载的压缩包中包括了依赖库、源码和打包后的jar，放到项目的lib目录下即可使用。

示例参考：

<!---->packagenet.rubyeye.xmemcached.test;

importjava.util.ArrayList;

importjava.util.List;

importjava.util.Map;

importjava.io.Serializable;

importnet.rubyeye.xmemcached.XMemcachedClient;

classNameimplementsSerializable{

StringfirstName;

StringlastName;

intage;

intmoney;

publicName(StringfirstName,StringlastName,intage,intmoney){

super();

this.firstName=firstName;

this.lastName=lastName;

this.age=age;

this.money=money;

}

publicStringtoString(){

return"["+firstName+""+lastName+",age="+age+",money="

+money+"]";

}

}

publicclassExample{

publicstaticvoidmain(String[]args){

try{

Stringip="192.168.222.100";

intport=11211;

XMemcachedClientclient=newXMemcachedClient(ip,port);

//存储操作

if(!client.set("hello",0,"dennis")){

System.err.println("seterror");

}

client.add("hello",0,"dennis");

client.replace("hello",0,"dennis");

//get操作

Stringname=(String)client.get("hello");

System.out.println(name);

//批量获取

List<String>keys=newArrayList<String>();

keys.add("hello");

keys.add("test");

Map<String,Object>map=client.get(keys);

System.out.println("mapsize:"+map.size());

//delete操作

if(!client.delete("hello",1000)){

System.err.println("deleteerror");

}

//incr,decr

client.incr("a",4);

client.decr("a",4);

//version

Stringversion=client.version();

System.out.println(version);

//增删改查自定义对象

Namedennis=newName("dennis","zhuang",26,-1);

System.out.println("dennis:"+dennis);

client.set("dennis",0,dennis);

NamecachedPerson=(Name)client.get("dennis");

System.out.println("cachedPerson:"+cachedPerson);

cachedPerson.money=-10000;

client.replace("dennis",0,cachedPerson);

NamecachedPerson2=(Name)client.get("dennis");

System.out.println("cachedPerson2:"+cachedPerson2);

//delete

client.delete("dennis");

System.out.println("afterdelete:"+client.get("dennis"));

client.shutdown();

}catch(Exceptione){

e.printStackTrace();

}

}

}

4、xmemcached的计划？

1)、添加多服务器和集群支持

2)、性能优化、重构

3)、添加cas原子操作以及更多协议支持

有兴趣的瞧瞧，提提建议。