基于Netty以及Zookeeper封装的Memcached客户端,性能较Xmemcached有一定的提升
使用方式见test package
不使用 zookeeper 下的使用方式
MemcachedClient client = new MemcachedClient("127.0.0.1", 12000)
.build("127.0.0.1", 12001).build("127.0.0.1", 12002) ;
boolean b1 = client.set(key1, value1 ) ;
String value = (String)client.get( key ) ;
boolean b2 = client.set(key2, new User( 1002, "fangliang_1002" ) ) ;
User valueUser = (User)client.get( key2 ) ;
详见 test包
使用 zookeeper 情形下ZkMemcachedClient client = new ZkMemcachedClient("zk1.com:2181,zk2.com:2181,zk2.com:2182,zk3.com:2181,zk3.com:2182" , "/zk/memcached", "wap") ;
其中 zk1.com:2181,zk2.com:2181,zk2.com:2182,zk3.com:2181,zk3.com:2182 为 zookeeper server 的地址请确保 zookeeper 下有上述路径 /zk/memcached/wap
可以根据不同的子空间实力化不同的 ZkMemcachedClient 比如 下属路径
/zk/memcached
--/zk/memcached/wap
----/zk/memcached/wap/127.0.0.1:12000
----/zk/memcached/wap/127.0.0.1:12001
----/zk/memcached/wap/127.0.0.1:12002
--/zk/memcached/www
----/zk/memcached/www/127.0.0.1:xxxxx
----/zk/memcached/www/127.0.0.1:xxxxx
--/zk/memcached/ishare
--/zk/memcached/xxxx
ZkMemcachedClient client = new ZkMemcachedClient("zk1.com:2181,zk2.com:2181,zk2.com:2182,zk3.com:2181,zk3.com:2182"
, "/zk/memcached", "www") ;
ZkMemcachedClient client = new ZkMemcachedClient("zk1.com:2181,zk2.com:2181,zk2.com:2182,zk3.com:2181,zk3.com:2182"
, "/zk/memcached", "ishare") ;
ZkMemcachedClient client = new ZkMemcachedClient("zk1.com:2181,zk2.com:2181,zk2.com:2182,zk3.com:2181,zk3.com:2182"
, "/zk/memcached", "xxxx") ;
后面的调用方式与未使用 zookeeper 情形下想同。
系统实现动态添加 memcache 节点 , key 通过一致性hash 分布在对应的server 上面
增加 zookeeper 节点 create /zk/memcached/wap/127.0.0.1:12003 127.0.0.1:12003 删除 zookeeper 节点 delete /zk/memcached/wap/127.0.0.1:12003