### 集群伸缩
Redis 集群提供了灵活的节点扩容和收缩方案。在**不影响集群对外服务**的情况下,可以为集群添加节点进行扩容也可以下线部分节点进行缩容。
![](https://img.kancloud.cn/51/fc/51fce519a97033fcb241ea721cb07ca3_749x447.png)
#### 1、槽和数据与节点的对应关系
当主节点分别维护自己负责的槽和对应的数据,如果希望加入1个节点实现集群扩容时,需要通过相关命令把一部分槽和数据迁移给新节点。
![](https://img.kancloud.cn/fe/b9/feb9266b3ff6f0677a25fc48c4f7fd1f_897x546.png)
上面图里的每个节点把一部分槽和数据迁移到新的节点newredis,每个节点负责的槽和数据相比之前变少了从而达到了集群扩容的目的,**集群伸缩=槽和数据在节点之间的移动**。
##### 扩容操作
###### 1.准备新机器
需要提前准备好新节点并**运行在集群模式下**,新节点建议跟集群内的节点配置保持一致,便于管理统一。
###### 2.加入集群
通过 `redis-trib.rb add-node ip:6397 ip:6391` 实现节点添加。
###### 3.迁移槽和数据
**加入集群后需要为新节点迁移槽和相关数据,槽在迁移过程中集群可以正常提供读写服务,迁移过程是集群扩容最核心的环节,下面详细讲解。**
槽是 Redis 集群管理数据的基本单位,首先需要为新节点制定槽的迁移计划,确定原有节点的哪些槽需要迁移到新节点。迁移计划需要确保每个节点负责相似数量的槽,从而保证各节点的数据均匀,比如之前是三个节点,现在是四个节点,把节点槽分布在四个节点上。
![](https://img.kancloud.cn/21/d5/21d5be0109f9ebae5ed894732118e648_876x325.png)
槽迁移计划确定后开始逐个把槽内数据从源节点迁移到目标节点.
![](https://img.kancloud.cn/7e/f1/7ef1d8dd2a802dceed73ba70908c62bf_858x318.png)
数据迁移过程是逐个槽进行的
流程说明:
1)对目标节点发送导入命令,让目标节点准备导入槽的数据。
2)对源节点发送导出命令,让源节点准备迁出槽的数据。
3)源节点循环执行迁移命令,将槽跟数据迁移到目标节点。
![](https://img.kancloud.cn/27/b8/27b8df5500aa31be8d7bb4c68d2c0527_609x383.png)
`redis-trib` 提供了槽重分片功能,命令如下:
redis-trib.rb reshard host:port --from <arg> --to <arg> --slots <arg> --yes --timeout <arg> --pipeline <arg>
参数说明:
`·host:port:`必传参数,集群内任意节点地址,用来获取整个集群信息。
`·--from:`制定源节点的 id,如果有多个源节点,使用逗号分隔,如果是all源节点变为集群内所有主节点,在迁移过程中提示用户输入。
`·--to:`需要迁移的目标节点的id,目标节点只能填写一个,在迁移过程中提示用户输入。
`·--slots:`需要迁移槽的总数量,在迁移过程中提示用户输入。
`·--yes:`当打印出 reshard 执行计划时,是否需要用户输入yes确认后再执行 reshard。
`·--timeout:`控制每次 migrate 操作的超时时间,默认为60000毫秒。
`·--pipeline:`控制每次批量迁移键的数量,默认为10。
**迁移操作**
redis-trib.rb reshard ip:6379
打印出集群每个节点信息后,reshard 命令需要确认迁移的槽数量,这里我们根据节点个数输入对应的值:
![](https://img.kancloud.cn/1c/56/1c56171000cdd02b5231d5512c3131dc_465x75.png)
输入某个节点的节点 ID 作为目标节点,目标节点只能指定一个:
What is the receiving node ID xxxx
![](https://img.kancloud.cn/ea/7a/ea7ad627bd5fe6af1e4be203baaa6335_554x151.png)
之后输入源节点的 ID,这里分别输入相应的节点 ID 最后用 done 表示结束:
数据迁移之前会打印出所有的槽从源节点到目标节点的计划,确认计划无误后输入 yes 执行迁移工作
redis-trib 工具会打印出每个槽迁移的进度:
![](https://img.kancloud.cn/26/4a/264a5298d7bf9e37aa25bbdff760a187_468x73.png)
查看节点的信息cluster-node
![](https://img.kancloud.cn/58/63/586376461364673dacc787ae55cd7949_554x88.png)
输入 `redis-trib.rb rebalance ip:port`
![](https://img.kancloud.cn/4b/6c/4b6c0850ffdcbdd7dbcdb263e8c82b6f_487x115.png)
**主从节点设置**
扩容之初我们把6397、6398节点加入到集群,节点6397迁移了部分槽和数据作为主节点,但相比其他主节点目前还没有从节点,因此该节点不具备故障转移的能力。
这时需要把节点6398作为6397的从节点,从而保证整个集群的高可用。使用 `cluster replicate{masterNodeId}`命令为主节点添加对应从节点。
#### 收缩集群
收缩集群意味着缩减规模,需要从现有集群中安全下线部分节点,下线节点过程。持续更新中。。。
- 微服务
- 服务器相关
- 操作系统
- 极客时间操作系统实战笔记
- 01 程序的运行过程:从代码到机器运行
- 02 几行汇编几行C:实现一个最简单的内核
- 03 黑盒之中有什么:内核结构与设计
- Rust
- 入门:Rust开发一个简单的web服务器
- Rust的引用和租借
- 函数与函数指针
- Rust中如何面向对象编程
- 构建单线程web服务器
- 在服务器中增加线程池提高吞吐
- Java
- 并发编程
- 并发基础
- 1.创建并启动线程
- 2.java线程生命周期以及start源码剖析
- 3.采用多线程模拟银行排队叫号
- 4.Runnable接口存在的必要性
- 5.策略模式在Thread和Runnable中的应用分析
- 6.Daemon线程的创建以及使用场景分析
- 7.线程ID,优先级
- 8.Thread的join方法
- 9.Thread中断Interrupt方法学习&采用优雅的方式结束线程生命周期
- 10.编写ThreadService实现暴力结束线程
- 11.线程同步问题以及synchronized的引入
- 12.同步代码块以及同步方法之间的区别和关系
- 13.通过实验分析This锁和Class锁的存在
- 14.多线程死锁分析以及案例介绍
- 15.线程间通信快速入门,使用wait和notify进行线程间的数据通信
- 16.多Product多Consumer之间的通讯导致出现程序假死的原因分析
- 17.使用notifyAll完善多线程下的生产者消费者模型
- 18.wait和sleep的本质区别
- 19.完善数据采集程序
- 20.如何实现一个自己的显式锁Lock
- 21.addShutdownHook给你的程序注入钩子
- 22.如何捕获线程运行期间的异常
- 23.ThreadGroup API介绍
- 24.线程池原理与自定义线程池一
- 25.给线程池增加拒绝策略以及停止方法
- 26.给线程池增加自动扩充,闲时自动回收线程的功能
- JVM
- C&C++
- GDB调试工具笔记
- C&C++基础
- 一个例子理解C语言数据类型的本质
- 字节顺序-大小端模式
- Php
- Php源码阅读笔记
- Swoole相关
- Swoole基础
- php的五种运行模式
- FPM模式的生命周期
- OSI网络七层图片速查
- IP/TCP/UPD/HTTP
- swoole源代码编译安装
- 安全相关
- MySql
- Mysql基础
- 1.事务与锁
- 2.事务隔离级别与IO的关系
- 3.mysql锁机制与结构
- 4.mysql结构与sql执行
- 5.mysql物理文件
- 6.mysql性能问题
- Docker&K8s
- Docker安装java8
- Redis
- 分布式部署相关
- Redis的主从复制
- Redis的哨兵
- redis-Cluster分区方案&应用场景
- redis-Cluster哈希虚拟槽&简单搭建
- redis-Cluster redis-trib.rb 搭建&原理
- redis-Cluster集群的伸缩调优
- 源码阅读笔记
- Mq
- ELK
- ElasticSearch
- Logstash
- Kibana
- 一些好玩的东西
- 一次折腾了几天的大华摄像头调试经历
- 搬砖实用代码
- python读取excel拼接sql
- mysql大批量插入数据四种方法
- composer好用的镜像源
- ab
- 环境搭建与配置
- face_recognition本地调试笔记
- 虚拟机配置静态ip
- Centos7 Init Shell
- 发布自己的Composer包
- git推送一直失败怎么办
- Beyond Compare过期解决办法
- 我的Navicat for Mysql
- 小错误解决办法
- CLoin报错CreateProcess error=216
- mysql error You must reset your password using ALTER USER statement before executing this statement.
- VM无法连接到虚拟机
- Jetbrains相关
- IntelliJ IDEA 笔记
- CLoin的配置与使用
- PhpStormDocker环境下配置Xdebug
- PhpStorm advanced metadata
- PhpStorm PHP_CodeSniffer