前面我们介绍过了Redis主从哨兵的方案。在redis3.0以前的版本要实现集群一般是借助哨兵sentinel工具来监控master节点的状态，如果master节点异常，则会做主从切换，将某一台slave作为master，哨兵的配置略微复杂，并且性能和高可用性等各方面表现一般，特别是在主从切换的瞬间存在【访问瞬断】的情况，而且哨兵模式只有一个主节点对外提供服务，没法支持很高的并发，且单个主节点内存也不宜设置得过大，否则会导致持久化文件过大，影响数据恢复或主从同步的效率 为了解决上面说的问题，Redis3,0之后，推出了Redis集群方案。Redis集群是一个：由多个主从节点群组成的分布式服务器群。它具有复制、高可用和分片特性。Redis集群不需要sentinel哨兵也能完成节点移除和故障转移的功能。需要将每个节点设置成集群模式，这种集群模式没有中心节点，可水平扩展，据官方文档称可以线性扩展到上万个节点(官方推荐不超过1000个节点)。redis集群的性能和高可用性均优于之前版本的哨兵模式，且集群配置非常简单 。
二、Redis集群架构搭建（单机搭建）Redis集群需要至少3个master节点，我们这里搭建3个master节点，并且给每个master再搭建1个slave节点，总共6个redis节点。由于本菜鸟手上的云服务器资源有限，这里用一台机器部署6个redis实例，并且将他们集群化。 3主的端口分别为：8001、8002、8003；3从的端口分别为：8004、8005、8006 搭建集群的步骤如下：
2.1 在服务器下新建各个节点的配置存放目录 我的程序目录在/usr/software/redis-cluster，所以先：cd /usr/software/redis-cluster然后在当前路径下新建目录：mkdir -p cluster-1/8001，mkdir -p cluster-1/8004，mkdir -p cluster-2/8002，mkdir -p cluster-2/8005，mkdir -p cluster-3/8003，mkdir -p cluster-3/8006。分别创建3组，6个用来Redis实例的配置以及数据文件的目录（PS：mkdir -p不懂的去菜鸟教程查查看）最后，分别cd进入每个节点的目录下，比如：cd /usr/software/redis-cluster/cluster-1/8001，把/usr/software/redis-cluster下的redis.conf复制到此cp ../../redis.conf ./redis-8001.conf，即可。最后结果如下： 不需要这么急着复制配置文件到其他节点，建议弄好redis-8001.conf之后，我们再把处理好的复制到其他目录下，然后使用Linux vi/vim的%s/匹配字符串/目标字符串/g命令，批量替换 2.2 修改配置（以redis-8001.conf为例）进入/usr/software/redis-cluster/cluster-1目录，开始修改redis-8001.conf
首先，先修改一些基本运行信息 # 分别对每个机器的端口号进行设置port 8001# 把pid进程号写入pidfile配置的文件pidfile /var/run/redis_8001.pid # 指定数据文件存放位置，必须要指定不同的目录位置，不然会丢失数据dir /usr/software/redis-cluster/cluster-1/8001/# 建议直接注释，我们联系搭建没必要关注这些，没点网络基础可能会陷入麻烦# （bind绑定的是自己机器网卡的ip，如果有多块网卡可以配多个ip，代表允许客户端通过机器的哪些网卡ip去访问，内网一般可以不配置bind，注释掉即可）# bind 127.0.0.1# 关闭保护模式protected-mode no 下面，是搭建集群比较关键的几个点 # 启动集群模式cluster-enabled yes# 集群节点信息文件，这里800x最好和port对应上cluster-config-file nodes-8001.conf# 集群节点超时时间，不建议设置很小cluster-node-timeout 10000 到这里配置文件就修改完了，把这个配置文件分别复制到其他节点上，使用如下命令直接替换字符串 分别启动6个redis实例，然后检查是否启动成功用redis‐cli创建整个redis集群（注意：下面的1xx.xx.xx.xx是我的外网地址） # 下面命令里的1代表为每个创建的主服务器节点创建一个从服务器节点# 执行这条命令需要确认三台机器之间的redis实例要能相互访问，可以先简单把所有机器防火墙关掉# 如果不关闭防火墙则需要打开redis服务端口和集群节点gossip通信端口16379(默认是在redis端口号上加1W# 关闭防火墙# systemctl stop firewalld # 临时关闭防火墙# systemctl disable firewalld # 禁止开机启动# 注意：下面这条创建集群的命令大家不要直接复制，里面的空格编码可能有问题导致创建集群不成功/usr/software/redis-cluster/src/redis-cli --cluster create --cluster-replicas 1 10.xx.xx.xx:8001 10.xx.xx.xx:8002 10.xx.xx.xx:8003 10.xx.xx.xx:8004 10.xx.xx.xx:8005 10.xx.xx.xx:8006 验证集群。连接任意一个客户端即可。连接之后使用cluster info或者cluster nodes查看 # (‐c表示集群模式，指定ip地址和端口号）./redis‐cli ‐p# 如：/usr/software/redis‐cluster/src/redis‐cli ‐c ‐p 8001cluster info信息： cluster nodes信息： 从上面这张图可以看到，哪个端口的实例是主节点，哪些是从节点，并且是谁的从节点
三、Java代码实战首先，你需要确保你的redis集群已经启动并且搭建好。另外，如果你的集群是在云服务器上的，然后你是想通过外网访问集群，那务必需要保证你创建集群的时候是外网绑定的。
借助redis的java客户端jedis可以操作以上集群，引用jedis版本的maven坐标，pom.xml如下：
<dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId><version>2.9.0</version></dependency>Java代码如下：
public class JedisClusterTest {public static void main(String[] args) throws IOException {JedisPoolConfig config = new JedisPoolConfig();config.setMaxTotal(100);config.setMaxIdle(50);config.setMinIdle(10);Set<HostAndPort> jedisClusterNode = new HashSet<HostAndPort>();jedisClusterNode.add(new HostAndPort("11x.xx.xx.xx", 8001));jedisClusterNode.add(new HostAndPort("11x.xx.xx.xx", 8002));jedisClusterNode.add(new HostAndPort("11x.xx.xx.xx", 8003));jedisClusterNode.add(new HostAndPort("11x.xx.xx.xx", 8004));jedisClusterNode.add(new HostAndPort("11x.xx.xx.xx", 8005));jedisClusterNode.add(new HostAndPort("11x.xx.xx.xx", 8006));JedisCluster jedisCluster = null;try {// connectionTimeout：指的是连接一个url的连接等待时间// soTimeout：指的是连接上一个url，获取response的返回等待时间jedisCluster = new JedisCluster(jedisClusterNode, config);System.out.println(jedisCluster.set("hoby", "hehe"));System.out.println(jedisCluster.get("hoby"));} catch (Exception e) {e.printStackTrace();} finally {if (jedisCluster != null)jedisCluster.close();}}}外网搭建注意事项： 1.创建集群的时候，ip地址设置成外网，如：redis-cli --cluster create --cluster-replicas 1 1xx.xx.xx.xx:8001 1xx.xx.xx.xx:8002。 参考文章：https://blog.csdn.net/future_1024/article/details/104909263 2.外网搭建redis集群会有另一个问题，部分ip地址会变成内网地址。所以需要手动修改，参考文章：https://blog.csdn.net/weixin_42260270/article/details/103032367
四、Redis集群原理分析Redis Cluster 将所有数据划分为 16384 个 slots（槽位），每个节点负责其中一部分槽位。槽位的信息存储于每个节点中。 当 Redis Cluster 的客户端来连接集群时，它也会得到一份集群的槽位配置信息并将其缓存在客户端本地。这样当客户端要查找某个 key 时，可以直接定位到目标节点。同时因为槽位的信息可能会存在客户端与服务器不一致的情况，还需要纠正机制来实现槽位信息的校验调整。
4.1 槽位定位算法Cluster 默认会对 key 值使用 crc16 算法进行 hash 得到一个整数值，然后用这个整数值对 16384 进行取模来得到具体槽位。 HASH_SLOT = CRC16(key) mod 16384
4.2 跳转重定位当客户端向一个错误的节点发出了指令，该节点会发现指令的 key 所在的槽位并不归自己管理，这时它会向客户端发送一个特殊的跳转指令携带目标操作的节点地址，告诉客户端去连这个节点去获取数据。客户端收到指令后除了跳转到正确的节点上去操作，还会同步更新纠正本地的槽位映射表缓存，后续所有 key 将使用新的槽位映射表。 如上图所示，我在8001端口的客户端上执行set user name，集群帮我重定向到了8002端口节点上
4.3 Redis集群节点间的通信机制redis cluster节点间采取gossip协议进行通信。维护集群的元数据（集群节点信息，主从角色，节点数量，各节点共享的数据等）有两种方式：集中式和gossip。
集中式：优点在于元数据的更新和读取，时效性非常好，一旦元数据出现变更立即就会更新到集中式的存储中，其他节点读取的时候立即就可以立即感知到；不足在于所有的元数据的更新压力全部集中在一个地方，可能导致元数据的存储压力。 很多中间件都会借助zookeeper集中式存储元数据gossip：gossip协议包含多种消息，包括ping，pong，meet，fail等等。gossip协议的优点在于元数据的更新比较分散，不是集中在一个地方，更新请求会陆陆续续，打到所有节点上去更新，有一定的延时，降低了压力；缺点在于元数据更新有延时可能导致集群的一些操作会有一些滞后。 meet：某个节点发送meet给新加入的节点，让新节点加入集群中，然后新节点就会开始与其他节点进行通信；ping：每个节点都会频繁给其他节点发送ping，其中包含自己的状态还有自己维护的集群元数据，互相通过ping交换元数据(类似自己感知到的集群节点增加和移除，hash slot信息等)pong：对ping和meet消息的返回，包含自己的状态和其他信息，也可以用于信息广播和更新fail: 某个节点判断另一个节点fail之后，就发送fail给其他节点，通知其他节点，指定的节点宕机了 4.4 gossip通信的10000端口每个节点都有一个专门用于节点间gossip通信的端口，就是自己提供服务的端口号+10000，比如7001，那么用于节点间通信的就是17001端口。 每个节点每隔一段时间都会往另外几个节点发送ping消息，同时其他几点接收到ping消息之后返回pong消息。
4.5 网络抖动真实世界的机房网络往往并不是风平浪静的，它们经常会发生各种各样的小问题。比如网络抖动就是非常常见的一种现象，突然之间部分连接变得不可访问，然后很快又恢复正常。 为解决这种问题，Redis Cluster 提供了一种选项cluster-node-timeout，表示当某个节点持续 timeout 的时间失联时，才可以认定该节点出现故障，需要进行主从切换。如果没有这个选项，网络抖动会导致主从频繁切换 （数据的重新复制）
4.6 Redis集群选举原理分析当slave发现自己的master变为FAIL状态时，便尝试进行Failover，以期成为新的master。由于挂掉的master可能会有多个slave，从而存在多个slave竞争成为master节点的过程， 其过程如下：
slave发现自己的master变为FAIL将自己记录的集群currentEpoch加1，并广播FAILOVER_AUTH_REQUEST信息其他节点收到该信息，只有master响应，判断请求者的合法性，并发送FAILOVER_AUTH_ACK，对每一个epoch只发送一次ack尝试failover的slave收集master返回的FAILOVER_AUTH_ACKslave收到超过半数master的ack后变成新Master(这里解释了集群为什么至少需要三个主节点，如果只有两个，当其中一个挂了，只剩一个主节点是不能选举成功的)slave广播Pong消息通知其他集群节点从节点并不是在主节点一进入 FAIL 状态就马上尝试发起选举，而是有一定延迟，一定的延迟确保我们等待FAIL状态在集群中传播，slave如果立即尝试选举，其它masters或许尚未意识到FAIL状态，可能会拒绝投票 延迟计算公式： DELAY = 500ms + random(0 ~ 500ms) + SLAVE_RANK * 1000ms SLAVE_RANK表示此slave已经从master复制数据的总量的rank。Rank越小代表已复制的数据越新。这种方式下，持有最新数据的slave将会首先发起选举（理论上）。
4.7 集群脑裂数据丢失问题redis集群没有过半机制会有脑裂问题，网络分区导致脑裂后多个主节点对外提供写服务，一旦网络分区恢复，会将其中一个主节点变为从节点，这时会有大量数据丢失。 规避方法可以在redis配置里加上参数(这种方法不可能百分百避免数据丢失，参考集群leader选举机制)：
min-replicas-to-write 1 //写数据成功最少同步的slave数量，这个数量可以模仿大于半数机制配置，比如集群总共三个节点可以配置1，加上leader就是2，超过了半数
注意：这个配置在一定程度上会影响集群的可用性，比如slave要是少于1个，这个集群就算leader正常也不能提供服务了，需要具体场景权衡选择。
Q1：集群是否完整才能对外提供服务 答：当redis.conf的配置cluster-require-full-coverage为no时，表示当负责一个插槽的主库下线且没有相应的从库进行故障恢复时，集群仍然可用，如果为yes则集群不可用。
Q2：Redis集群为什么至少需要三个master节点，并且推荐节点数为奇数？ 答：因为新master的选举需要大于半数的集群master节点同意才能选举成功，如果只有两个master节点，当其中一个挂了，是达不到选举新master的条件的。 奇数个master节点可以在满足选举该条件的基础上节省一个节点，比如三个master节点和四个master节点的集群相比，大家如果都挂了一个master节点都能选举新master节点，如果都挂了两个master节点都没法选举新master节点了，所以奇数的master节点更多的是从节省机器资源角度出发说的。
4.8 Redis集群对批量操作命令的支持对于类似mset，mget这样的多个key的原生批量操作命令，redis集群只支持所有key落在同一slot的情况，如果有多个key一定要用mset命令在redis集群上操作，则可以在key的前面加上{XX}，这样参数数据分片hash计算的只会是大括号里的值，这样能确保不同的key能落到同一slot里去，示例如下： mset {user1}:1:name zhuge {user1}:1:age 18 假设name和age计算的hash slot值不一样，但是这条命令在集群下执行，redis只会用大括号里的 user1 做hash slot计算，所以算出来的slot值肯定相同，最后都能落在同一slot。
4.9 哨兵leader选举流程当一个master服务器被某sentinel视为下线状态后，该sentinel会与其他sentinel协商选出sentinel的leader进行故障转移工作。每个发现master服务器进入下线的sentinel都可以要求其他sentinel选自己为sentinel的leader，选举是先到先得。同时每个sentinel每次选举都会自增配置纪元(选举周期)，每个纪元中只会选择一个sentinel的leader。如果所有超过一半的sentinel选举某sentinel作为leader。之后该sentinel进行故障转移操作，从存活的slave中选举出新的master，这个选举过程跟集群的master选举很类似。 哨兵集群只有一个哨兵节点，redis的主从也能正常运行以及选举master，如果master挂了，那唯一的那个哨兵节点就是哨兵leader了，可以正常选举新master。 不过为了高可用一般都推荐至少部署三个哨兵节点。为什么推荐奇数个哨兵节点原理跟集群奇数个master节点类似。
五、Redis集群节点管理 3.1 增加redis实例在当前集群中，新增新的节点也很简单。例如：在/usr/software/redis-cluster下新建一个cluster-4目录，并且在cluster-4下面创建8007和8008文件夹，并拷贝8001文件夹下的redis-8001.conf文件到8007和8008这两个文件夹下，然后按照前面介绍过的方法修改配置文件。操作步骤如下：
cd /usr/software/redis-clustermkdir cluster-4cd cluster-4mkdir 8007 mkdir 8008cp ../cluster-1/8001/redis-8001.conf /usr/local/redis-cluster/8007/cp ../cluster-1/8001/redis-8001.conf /usr/local/redis-cluster/8008/# 修改8007文件夹下的redis.conf配置文件vim /usr/software/redis-cluster/cluster-4/8007/redis-8007.conf# 修改如下内容：port:8007dir /usr/software/redis-cluster/cluster-4/8007/cluster-config-file nodes-8007.conf# 修改8008文件夹下的redis.conf配置文件vim /usr/software/redis-cluster/cluster-4/8008/redis-8008.conf修改内容如下：port:8008dir /usr/software/redis-cluster/cluster-4/8008/cluster-config-file nodes-8008.conf# 启动8007和8008俩个服务并查看服务状态/usr/local/redis-5.0.3/src/redis-server /usr/local/redis-cluster/8007/redis.conf/usr/local/redis-5.0.3/src/redis-server /usr/local/redis-cluster/8008/redis.confps -el | grep redis 3.2 查看redis集群的命令帮助 cd /usr/software/redis-clustersrc/redis-cli --cluster help通过上图，我们可以看到redis客户端的一些常用命令：
create：创建一个集群环境host1:port1 … hostN:portNcall：可以执行redis命令add-node：将一个节点添加到集群里，第一个参数为新节点的ip:port，第二个参数为集群中任意一个已经存在的节点的ip:portdel-node：移除一个节点reshard：重新分片check：检查集群状态 3.3 配置8007为集群主节点使用add-node命令新增一个主节点8007(master)，前面的ip:port为新增节点，后面的ip:port为已知存在节点，看到日志最后有"[OK] New node added correctly"提示代表新节点加入成功
/usr/software/redis-cluster/src/redis-cli --cluster add-node 1xx.xx.xx.xx:8007 1xx.xx.xx.xx:8001新增节点后查看集群状态：
/usr/software/redis-cluster/src/redis-cli -c -h 1xx.xx.xx.xx -p 80011xx.xx.xx.xx:8001> cluster nodes注意：当添加节点成功以后，新增的节点不会有任何数据，因为它还没有分配任何的slot(hash槽)，我们需要为新节点手工分配hash槽。 使用redis-cli命令为8007分配hash槽，找到集群中的任意一个主节点，对其进行重新分片工作。
/usr/software/redis-cluster/src/redis-cli --cluster reshard 1xx.xx.xx.xx:8001执行上述命令后，输出如下：
... ...How many slots do you want to move (from 1 to 16384)? 600(ps:需要多少个槽移动到新的节点上，自己设置，比如600个hash槽)What is the receiving node ID? 2728a594a0498e98e4b83a537e19f9a0a3790f38(ps:把这600个hash槽移动到哪个节点上去，需要指定节点id)Please enter all the source node IDs.Type 'all' to use all the nodes as source nodes for the hash slots.Type 'done' once you entered all the source nodes IDs.Source node 1:all(ps:输入all为从所有主节点(8001,8002,8003)中分别抽取相应的槽数指定到新节点中，抽取的总槽数为600个)... ...Do you want to proceed with the proposed reshard plan (yes/no)? yes(ps:输入yes确认开始执行分片任务)操作完后，查看下最新的集群状态输出如下：
/usr/software/redis-cluster/src/redis-cli -c -h 1xx.xx.xx.xx -p 80011xx.xx.xx.xx:8001> cluster nodes 3.4 配置8008为8007的从节点添加从节点8008到集群中去并查看集群状态：
/usr/software/redis-cluster/src/redis-cli --cluster add-node 1xx.xx.xx.xx:8008 1xx.xx.xx.xx:8001如图所示，还是一个master节点，没有被分配任何的hash槽。 我们需要执行replicate命令来指定当前节点(从节点)的主节点id为哪个,首先需要连接新加的8008节点的客户端，然后使用集群命令进行操作，把当前的8008(slave)节点指定到一个主节点下(这里使用之前创建的8007主节点)
/usr/software/redis-cluster/src/redis-cli -c -h 1xx.xx.xx.xx -p 8008#后面这串id为8007的节点id1xx.xx.xx.xx:8008> cluster replicate 2728a594a0498e98e4b83a537e19f9a0a3790f38查看集群状态，8008节点已成功添加为8007节点的从节点：
3.5 删除8008从节点用del-node删除从节点8008，指定删除节点ip和端口，以及节点id(红色为8008节点id)
/usr/software/redis-clustersrc/redis-cli --cluster del-node 1xx.xx.xx.xx:8008 a1cfe35722d151cf70585cee21275565393c0956再次查看集群状态，如下图所示，8008这个slave节点已经移除，并且该节点的redis服务也已被停止：
3.6 删除8007主节点最后，我们尝试删除之前加入的主节点8007，这个步骤相对比较麻烦一些，因为主节点的里面是有分配了hash槽的，所以我们这里必须先把8007里的hash槽放入到其他的可用主节点中去，然后再进行移除节点操作，不然会出现数据丢失问题(目前只能把master的数据迁移到一个节点上，暂时做不了平均分配功能)，执行命令如下：
/usr/software/redis-cluster/src/redis-cli --cluster reshard 1xx.xx.xx.xx:8007输出如下：
How many slots do you want to move (from 1 to 16384)? 600What is the receiving node ID? dfca1388f124dec92f394a7cc85cf98cfa02f86f(ps:这里是需要把数据移动到哪？8001的主节点id)Please enter all the source node IDs.Type 'all' to use all the nodes as source nodes for the hash slots.Type 'done' once you entered all the source nodes IDs.Source node 1:2728a594a0498e98e4b83a537e19f9a0a3790f38(ps:这里是需要数据源，也就是我们的8007节点id)Source node 2:done(ps:这里直接输入done 开始生成迁移计划)... ...Do you want to proceed with the proposed reshar至此，我们已经成功的把8007主节点的数据迁移到8001上去了，我们可以看一下现在的集群状态如下图，你会发现8007下面已经没有任何hash槽了，证明迁移成功！ 最后我们直接使用del-node命令删除8007主节点即可：
/usr/software/redis-cluster/src/redis-cli --cluster del-node 1xx.xx.xx.xx:8007 2728a594a0498e98e4b83a537e19f9a0a3790f38查看集群状态，一切还原为最初始状态啦！大功告成！
学习总结 感谢感谢大佬future_1024的文章《Redis集群搭建：解决java程序外网无法连接集群》 感谢大佬future_1024的文章《解决 阿里云 搭建redis集群 ip变成内网》
