转载

jredis cluster客户端使用

一.序言

前面搭建了个3个msater-slave 的本地集群测试，这里用java 的客户端进行一些简单测试，看看集群是否生效。

redis client 推荐：http://redis.io/clients

我使用的：https://github.com/xetorthio/jedis

二.测试

maven:

<dependency>  <groupId>redis.clients</groupId>  <artifactId>jedis</artifactId>  <version>2.7.2</version>  <type>jar</type>  <scope>compile</scope> </dependency>

@org.junit.Test public  void cluster(){  String key = "2";  // 这东西 可以直接看到key 的分片数，就能知道放哪个 节点  System.out.println(JedisClusterCRC16.getSlot(key));  Set<HostAndPort> jedisClusterNodes = new HashSet<HostAndPort>();  jedisClusterNodes.add(new HostAndPort("127.0.0.1", 7000));  jedisClusterNodes.add(new HostAndPort("127.0.0.1", 7001));  jedisClusterNodes.add(new HostAndPort("127.0.0.1", 7002));  // 3个master 节点  JedisCluster jc = new JedisCluster(jedisClusterNodes);  System.out.println(jc.get(key));  jc.setnx(key, "bar");  String value = jc.get(key);  System.out.println(value); }

别人的例子，我测试：

Set<HostAndPort> jedisClusterNodes = new HashSet<HostAndPort>(); jedisClusterNodes.add(new HostAndPort("127.0.0.1", 7000)); jedisClusterNodes.add(new HostAndPort("127.0.0.1", 7001)); jedisClusterNodes.add(new HostAndPort("127.0.0.1", 7002)); JedisCluster jc = new JedisCluster(jedisClusterNodes); for (int i = 1; i <= 10000; i++) {  long start = System.currentTimeMillis();  jc.set("k:" + i, "v" + i);  System.out.print("set " + i +"th value in " + (System.currentTimeMillis() - start) + " ms");  start = System.currentTimeMillis();  jc.get("k:" + i);  System.out.println(", get " + i +"th value in " + (System.currentTimeMillis() - start) + " ms"); }

由于是本机固态硬盘，速度杠杆的。

三.测试反馈：

1.集群正常，基本操作都OK

2.如果某个master 挂了，比如7001, 集群依然可用，会存放到对应的salve 7004 上去。

3.如果master -slave 都挂了，会导致整个集群不可用，异常，因此最好配有M-S 的结构

4.我默认配置，有rdb 和 aof 持久化，因此master 挂了，重启，数据可以从salve 上恢复

5.存放的key 会根据返回的位置，放在不同的slot 上，实现均衡

小结：

1.这里仅仅是最基本的配置，和简单测试

2.如果配置文件以及更多命令得参考文档

2.1 客户端命令：http://redis.io/topics/clients

2.2 中文jredis API:http://www.360doc.com/content/15/0328/12/5054188_458684113.shtml 建议看源码用例