前面我们谈了Redis Sharding多服务器集群技术，Redis Sharding是客户端Sharding技术，对于服务端来说，各个Redis服务器彼此是相互独立的，这对于服务端根据需要灵活部署Redis非常轻便，Redis Sharding具有很好的灵活性、可伸缩性，是一种轻量级集群技术。

本篇，介绍另外一种多Redis服务器集群技术，即Redis Cluster。Redis Cluster是一种服务器Sharding技术，3.0版本开始正式提供。

Redis Cluster中，Sharding采用slot(槽)的概念，一共分成16384个槽，这有点儿类似前面讲的pre sharding思路。对于每个进入Redis的键值对，根据key进行散列，分配到这16384个slot中的某一个中。使用的hash算法也比较简单，就是CRC16后16384取模。

Redis集群中的每个node(节点)负责分摊这16384个slot中的一部分，也就是说，每个slot都对应一个node负责处理。当动态添加或减少node节点时，需要将16384个槽做个再分配，槽中的键值也要迁移。当然，这一过程，在目前实现中，还处于半自动状态，需要人工介入。

Redis集群，要保证16384个槽对应的node都正常工作，如果某个node发生故障，那它负责的slots也就失效，整个集群将不能工作。

为了增加集群的可访问性，官方推荐的方案是将node配置成主从结构，即一个master主节点，挂n个slave从节点。这时，如果主节点失效，Redis Cluster会根据选举算法从slave节点中选择一个上升为主节点，整个集群继续对外提供服务。这非常类似前篇文章提到的Redis Sharding场景下服务器节点通过Sentinel监控架构成主从结构，只是Redis Cluster本身提供了故障转移容错的能力。

Redis Cluster的新节点识别能力、故障判断及故障转移能力是通过集群中的每个node都在和其它nodes进行通信，这被称为集群总线(cluster bus)。它们使用特殊的端口号，即对外服务端口号加10000。例如如果某个node的端口号是6379，那么它与其它nodes通信的端口号是16379。nodes之间的通信采用特殊的二进制协议。

对客户端来说，整个cluster被看做是一个整体，客户端可以连接任意一个node进行操作，就像操作单一Redis实例一样，当客户端操作的key没有分配到该node上时，Redis会返回转向指令，指向正确的node，这有点儿像浏览器页面的302 redirect跳转。

Redis Cluster是Redis 3.0以后才正式推出，时间较晚，目前能证明在大规模生产环境下成功的案例还不是很多，需要时间检验。

集群搭建R

下面，我们就实际操作建立一个Redis Cluster。我们将建立3个node，每个node架构成一主一从，故总共有6个redis实例，端口号从7000-7005。

Cluster下的Redis实例，和普通Redis实例一样，只是处于cluster模式方式下运行。

实操步骤如下：

1. 以3.0.5为例，建立cluster目录，其下再建6个子目录代表6实例环境

mkdir cluster

mkdir 7000 7001 7002 7003 7004 7005

2. 将redis.conf模板分别copy到上面6子目录中，并做如下修改，以7000为例：

修改如下信息

daemonize yes

pidfile /var/run/redis-7000.pid

port 7000

logfile "/var/log/redis-7000.log"

注释掉如下信息， 不需要RDB持久化

#save 900 1

#save 300 10

#save 60 10000

修改如下信息

appendonly yes

appendfilename "appendonly-7000.aof"

取消如下注释，让Redis在集群模式下运行

cluster-enabled yes 启动cluster模式

cluster-config-file nodes-7000.conf 集群信息文件名，由redis自己维护

cluster-node-timeout 15000 15秒中联系不到对方node，即认为对方有故障可能

3. 在各个目录下执行 redis-server redis.conf 启动redis实例

这时，这几个实例都是各自是一个集群状态在运行，并没有形成一个整体集群态，我们需要Redis提供的基于ruby开发的工具进行人工设置。

4.安装ruby环境

yum install ruby ruby-devel rubygems

5.安装Redis的ruby依赖接口

gem install redis

6.利用脚本工具建立集群

./redis-trib.rb create --replicas 1 192.168.1.142:7000 192.168.1.142:7001 192.168.1.142:7002 192.168.1.142:7003 192.168.1.142:7004 192.168.1.142:7005

该脚本自动执行节点分配方案，将前3个redis实例作为主节点，后三个作为从节点，如图：

按提示敲入"yes"，执行方案，将6个节点组成集群，3主3从。

执行redis-cli -p 7000 info Replication 命令，观察7000这个节点，发现其复制配置信息已配置成主节点，并有一个从节点7003

再执行redis-cli -p 7003 info Replication发现，该节点已设置成从节点。这些主从设置，都是在创建集群时自动完成的。

至此，3主3从的Redis集群建立起来了。接下来我们做个故障转移试验，将主节点7001 shutdown掉，看看发生什么？

我们看到，从节点7004会上升为主节点继续提供集群服务。那又重新启动7001节点呢？

我们发现7001节点已经成为从节点，不会成为取代7004成为主节点。那如果将主节点7001和从节点7004都shutdown掉呢？

这时，整个cluster是拒绝提供服务的。因为原来7001分配的slot现在无节点接管，需要人工介入重新分配slots。

增删集群节点R

下面我们操作下，如果修改集群节点架构：

删除一个从节点。注意，如果删除主节点，其负责的slots必须为空。

./redis-trib.rb del-node 192.168.1.142:7000 ee2fc0ea6e630f54e3b811caedf8896b26a99cba

将7001节点的slot都转移到7000

./redis-trib.rb reshard 192.168.1.142:7000

按提示操作即可。

加一个节点。注意新添加的节点还没有分配slot，用reshard给它分配一定比例的slots

./redis-trib.rb add-node 192.168.1.142:7001 192.168.1.142:7000

给指定一个主节点添加一个从节点。

./redis-trib.rb add-node --slave --master-id f4d17d56a9dda1a102da7cd799192beff7cba69e 192.168.1.142:7004 192.168.1.142:7000

注意如果此redis实例参与过集群，需先cluster reset 清除重置一下。

Jedis客户端访问R

上面介绍了服务端Redis Cluster搭建过程。下面来看看客户端如何使用？

Java语言的客户端驱动Jedis是支持Redis Cluster的。我们具体实操下：

1. pom.xml中配置jedis jar包

<dependency>

<groupId>redis.clients</groupId>

<artifactId>jedis</artifactId>

<version>2.8.0</version> <!-- 最近升级了 -->

</dependency>

2. spring配置文件中配置JedisCluster

<bean id="poolConfig" class="redis.clients.jedis.JedisPoolConfig">

<property name="maxTotal" value="4096"/>

<property name="maxIdle" value="200"/>

<property name="maxWaitMillis" value="3000"/>

<property name="testOnBorrow" value="true" />

<property name="testOnReturn" value="true" />

</bean>

<bean id = "jedisCluster" class = "redis.clients.jedis.JedisCluster">

<constructor-arg index="0">

<set>

<bean class="redis.clients.jedis.HostAndPort">

<constructor-arg index="0" value="192.168.1.142" />

<constructor-arg index="1" value="7002" />

</bean>

</set>

</constructor-arg>

<constructor-arg index="1" value="2000" type="int"/>

<constructor-arg index="2" value="2" type="int"/>

<constructor-arg index="3" ref="poolConfig"/>

</bean>

3.编写测试代码

@Test

public void basicOpTestForCluster(){

long begin = System.currentTimeMillis();

for(int i=0;i<10000; i++){

jedis.set("person." + i + ".name", "frank");

jedis.set("person." + i + ".city", "beijing");

String name = jedis.get("person." + i + ".name");

String city = jedis.get("person." + i + ".city");

assertEquals("frank",name);

assertEquals("beijing",city);

jedis.del("person." + i + ".name");

Boolean result = jedis.exists("person." + i + ".name");

assertEquals(false,result);

result = jedis.exists("person." + i + ".city");

assertEquals(true,result);

}

long end = System.currentTimeMillis(); 

System.out.println("total time: " + (end-begin)/1000);

}