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

1、xmemcached是什么？

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

实际上是基于我实现的一个简单nio框架 http://code.google.com/p/yanf4j/ 的基础上实现的(目前是基于yanf4j 0.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目录下即可使用。

示例参考：

<!---->package  net.rubyeye.xmemcached.test;

import  java.util.ArrayList;
import  java.util.List;
import  java.util.Map;
import  java.io.Serializable;

import  net.rubyeye.xmemcached.XMemcachedClient;

class  Name  implements  Serializable {
    String firstName;
    String lastName;
     int  age;
     int  money;

     public  Name(String firstName, String lastName,  int  age,  int  money) {
         super ();
         this .firstName  =  firstName;
         this .lastName  =  lastName;
         this .age  =  age;
         this .money  =  money;
    }

     public  String toString() {
         return   " [ "   +  firstName  +   "   "   +  lastName  +   " ,age= "   +  age  +   " ,money= "
                 +  money  +   " ] " ;
    }

}

public   class  Example {
     public   static   void  main(String[] args) {
         try  {
            String ip  =   " 192.168.222.100 " ;

             int  port  =   11211 ;
            XMemcachedClient client  =   new  XMemcachedClient(ip, port);
             //  存储操作
             if  ( ! client.set( " hello " ,  0 ,  " dennis " )) {
                System.err.println( " set error " );
            }
            client.add( " hello " ,  0 ,  " dennis " );
            client.replace( " hello " ,  0 ,  " dennis " );

             //  get操作
            String name  =  (String) client.get( " hello " );
            System.out.println(name);

             //  批量获取
            List < String >  keys  =   new  ArrayList < String > ();
            keys.add( " hello " );
            keys.add( " test " );
            Map < String, Object >  map  =  client.get(keys);
            System.out.println( " map size: " + map.size());

             //  delete操作
             if  ( ! client.delete( " hello " ,  1000 )) {
                System.err.println( " delete error " );
            }

             //  incr,decr
            client.incr( " a " ,  4 );
            client.decr( " a " ,  4 );

             //  version
            String version  =  client.version();
            System.out.println(version);
             //  增删改查自定义对象
            Name dennis  =   new  Name( " dennis " ,  " zhuang " ,  26 ,  - 1 );
            System.out.println( " dennis: "   +  dennis);
            client.set( " dennis " ,  0 , dennis);

            Name cachedPerson  =  (Name) client.get( " dennis " );
            System.out.println( " cachedPerson: "   +  cachedPerson);
            cachedPerson.money  =   - 10000 ;

            client.replace( " dennis " ,  0 , cachedPerson);
            Name cachedPerson2  =  (Name) client.get( " dennis " );
            System.out.println( " cachedPerson2: "   +  cachedPerson2);

             //  delete
            client.delete( " dennis " );
            System.out.println( " after delete: "   +  client.get( " dennis " ));
            client.shutdown();
        }  catch  (Exception e) {
            e.printStackTrace();
        }

    }
}

4、xmemcached的计划？

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

2)、性能优化、重构

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

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

评论

11 楼 hw7777777 2016-05-17  

非常感谢作者提供这么好的工具，在使用的过程中遇到一些问题？
1、使用连接池后，当一个节点断开连接后会一直尝试连接并报出connect refused 异常？是因为有重试机制吗？
2、动态添加节点addserver时当节点服务通信异常也会抛出connect refused 异常，并一直重试？

麻烦作者提供解决思路，非常感谢

10 楼 shhbobby 2011-02-17  

项目使用中，向作者学习

9 楼 cmjcmj8080 2009-12-09  

不好意思,列表是倒序排的,看了半天才看到在前面了  .还以为缓存没更新过来呢...

8 楼 cmjcmj8080 2009-12-09  

你好,请问使用xmemcached的时候,怎么样使缓存中的数据同步?
比如 我要缓存一个在线社员列表,是登录一个添加一个,登出一个删除一个key
还是写个定时任务 扫描数据库 有更新的替换全部列表呢?

7 楼 cmjcmj8080 2009-12-09  

你好,请问使用xmemcached的时候,怎么样使缓存中的数据同步?
比如 我要缓存一个在线社员列表,是登录一个添加一个,登出一个删除一个key
还是写个定时任务 扫描数据库 有更新的替换全部列表呢?

6 楼 yuyee 2009-11-10  

5 楼 dennis_zane 2009-11-03  

yuyee 写道

有没中文版的....

http://code.google.com/p/xmemcached/wiki/Example_zh
中文指南

4 楼 yuyee 2009-11-03  

有没中文版的....

3 楼 pan_java 2009-08-17  

相关文档太少了,注解不全,希望完善!

2 楼 dennis_zane 2009-05-27  

fly_hyp 写道

测试过了性能非常的好。

呵呵，谢谢，欢迎使用，有任何BUG和建议，请及时发给我，我的email [e-mail]

1 楼 fly_hyp 2009-05-27  

测试过了性能非常的好。