Redis Cluster slots 迁移过程

2023-12-04 10:48

本文主要是介绍Redis Cluster slots 迁移过程,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

一、Redis Cluster 背景知识

Redis Cluster是无中心化的架构,他没有集中化的控制组件和proxy,客户端可以向集群中的任意一台节点发送请求,然后根据节点的返回值做重定向(MOVE或ASK)操作,客户端本地也会缓存slot表,并根据每次的重定向信息来更新这个表。

在这里插入图片描述

由于没有中心化组件存储,因此redis cluster使用gossip在集群间同步路由表和集群拓扑信息,在经过一段时间后,理想情况下及群众给每个节点都掌握了整个集群的路由信息

二、slot迁移过程

将一个Redis节点上指定的slot下的所有key迁移到其他redis节点上,需要两步:
1、先获取这个slot下所有的key
2、对每个key发送迁移命令

Redis cluster直接使用migrate命令进行key的迁移,这个命令是同步阻塞的,redis是单线程的,当migrate过程耗时太久(比如网络慢、迁移bigkey)时,会导致主线程无法处理用户请求。

2.1、slot迁移的难点

1、如使用同步阻塞的方式,bigkey或网络慢,会阻塞主线程正常服务
2、对bigkey迁移需要特殊处理,否则bigkey的序列号、发送、反序列号时,都可能导致源redis实例和目标redis实例主线程阻塞。
3、单个key的迁移过程需要保证原子性,即要么一个key全部迁移成功,要么全部迁移失败,不能存在中间状态
4、对迁移中slot的读写出出力,即一个slot如果正处于迁移过程中,其中的key(已经迁移走、迁移中、或等待迁移)是否可以被正常读写。

2.2、Redis Cluster的slot迁移实现

2.2.1、slot分配

redis-cluster为了支持slot迁移,改造引擎加入了key和slot的映射关系。Redis-cluster使用rax树来维护key和slot的映射关系。因此在新建集群、集群扩缩容的时候,都会涉及到slot分配、删除等操作,这些操作通过以下命令实现:

  • cluster addslots [slot …] 将一个或多个槽(slot)指派(assign)给当前节点。
  • cluster delslots [slot …] 移除一个或多个槽对当前节点的指派。
  • cluster flushslots 移除指派给当前节点的所有槽,让当前节点变成一个没有指派任何槽的节点。
  • cluster setslot node <node_id> 将槽 slot 指派给 node_id 指定的节点,如果槽已经指派给另一个节点,那么先让另一个节点删除该槽>,然后再进行指派。

2.2.2、key-slot操作

一旦key和slot的映射关系建立好,就可以执行key相关的slot命令,redis-cluster提供了以下命令:

  • cluster slot 计算键 key 应该被放置在哪个槽上。
  • cluster countkeysinslot 返回槽 slot 目前包含的键值对数量。
  • cluster getkeysinslot 返回 count 个 slot 槽中的键。

2.2.3、slot的迁移流程

  • 对目标节点发送 cluster setslot importing 命令,让目标节点准备导入槽的数据。
  • 对源节点发送 cluster setslot migrating 命令,让源节点准备迁出槽的数据。
  • 源节点循环执行 cluster getkeysinslot 命令,获取count个属于槽slot的键。
  • 在源节点上执行 migrate “” 0 keys <keys…> 命令,把获取的键通过流水线(pipeline)机制批量迁移到目标节点。
  • 重复执行步骤3和步骤4直到槽下所有的键值数据迁移到目标节点。
  • 向集群内所有主节点发送cluster setslot node 命令,通知槽分配给目标节点。为了保证槽节点映射变更及时传播,需要遍历发送给所有主节点更新被迁移的槽指向新节点。

2.4、key迁移的原子性

由于migrate命令是同步阻塞的(同步发送同步接收),迁移过程中会阻塞该引擎上的所有key的读写,只有在迁移响应成功之后,才会将本地的key删除,因此在redis cluster中迁移是原子的。

2.5、迁移过程中的读写冲突

因为migrate命令是同步阻塞的,因此不会存在一个key正在被迁移又同时被读写的情况,但由于一个slot下可能有部分key被迁移完成,部分key正在等待迁移的情况,因此如果读写的key所属的slot正在被迁移,redis-cluster做如下处理:

  • 客户端根据本地slots缓存发送命令到源节点,如果存在键对象则直接指向并返回结果给客户端。
  • 如果key对象不存在,但key所在的slot属于本节点,则可能存在于目标节点,这时源节点会回复ASK重定向异常。例如如:error)ASK :。
  • 客户端从ASK重定向异常提取出目标节点的信息,发送asking命令到目标节点打开客户端连接标识,再执行key命令。如果存在则执行,不存在则返回不存在信息。
  • 如果key所在的slot不属于本节点,则返回MOVE重定向。格式如下:(error)ASK :。
  • 客户端从ASK重定向异常提取出目标节点信息,发送asking命令到目标节点打开客户端连接标识,再执行键命令。如果存在则执行,不存在则返回不存在信息
  • 如果key所在的slot不属于本节点,则返回MOVE重定向。格式如下:(error)MOVED :。

这篇关于Redis Cluster slots 迁移过程的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/453192

相关文章

Redis中Stream详解及应用小结

《Redis中Stream详解及应用小结》RedisStreams是Redis5.0引入的新功能,提供了一种类似于传统消息队列的机制,但具有更高的灵活性和可扩展性,本文给大家介绍Redis中Strea... 目录1. Redis Stream 概述2. Redis Stream 的基本操作2.1. XADD

MySQL 迁移至 Doris 最佳实践方案(最新整理)

《MySQL迁移至Doris最佳实践方案(最新整理)》本文将深入剖析三种经过实践验证的MySQL迁移至Doris的最佳方案,涵盖全量迁移、增量同步、混合迁移以及基于CDC(ChangeData... 目录一、China编程JDBC Catalog 联邦查询方案(适合跨库实时查询)1. 方案概述2. 环境要求3.

Linux进程CPU绑定优化与实践过程

《Linux进程CPU绑定优化与实践过程》Linux支持进程绑定至特定CPU核心,通过sched_setaffinity系统调用和taskset工具实现,优化缓存效率与上下文切换,提升多核计算性能,适... 目录1. 多核处理器及并行计算概念1.1 多核处理器架构概述1.2 并行计算的含义及重要性1.3 并

Spring boot整合dubbo+zookeeper的详细过程

《Springboot整合dubbo+zookeeper的详细过程》本文讲解SpringBoot整合Dubbo与Zookeeper实现API、Provider、Consumer模式,包含依赖配置、... 目录Spring boot整合dubbo+zookeeper1.创建父工程2.父工程引入依赖3.创建ap

Linux下进程的CPU配置与线程绑定过程

《Linux下进程的CPU配置与线程绑定过程》本文介绍Linux系统中基于进程和线程的CPU配置方法,通过taskset命令和pthread库调整亲和力,将进程/线程绑定到特定CPU核心以优化资源分配... 目录1 基于进程的CPU配置1.1 对CPU亲和力的配置1.2 绑定进程到指定CPU核上运行2 基于

Knife4j+Axios+Redis前后端分离架构下的 API 管理与会话方案(最新推荐)

《Knife4j+Axios+Redis前后端分离架构下的API管理与会话方案(最新推荐)》本文主要介绍了Swagger与Knife4j的配置要点、前后端对接方法以及分布式Session实现原理,... 目录一、Swagger 与 Knife4j 的深度理解及配置要点Knife4j 配置关键要点1.Spri

Java进程异常故障定位及排查过程

《Java进程异常故障定位及排查过程》:本文主要介绍Java进程异常故障定位及排查过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、故障发现与初步判断1. 监控系统告警2. 日志初步分析二、核心排查工具与步骤1. 进程状态检查2. CPU 飙升问题3. 内存

SpringBoot整合liteflow的详细过程

《SpringBoot整合liteflow的详细过程》:本文主要介绍SpringBoot整合liteflow的详细过程,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋...  liteflow 是什么? 能做什么?总之一句话:能帮你规范写代码逻辑 ,编排并解耦业务逻辑,代码

Redis出现中文乱码的问题及解决

《Redis出现中文乱码的问题及解决》:本文主要介绍Redis出现中文乱码的问题及解决,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1. 问题的产生2China编程. 问题的解决redihttp://www.chinasem.cns数据进制问题的解决中文乱码问题解决总结

Java中调用数据库存储过程的示例代码

《Java中调用数据库存储过程的示例代码》本文介绍Java通过JDBC调用数据库存储过程的方法,涵盖参数类型、执行步骤及数据库差异,需注意异常处理与资源管理,以优化性能并实现复杂业务逻辑,感兴趣的朋友... 目录一、存储过程概述二、Java调用存储过程的基本javascript步骤三、Java调用存储过程示