当前位置: 首页 > news >正文

redis主从复制

主从复制

今天简单了解一下redis中的主从复制

将一台redis服务器上的数据复制到其他redis服务器上,分别是主节点和从节点,主节点和从节点是一对多,数据的复制是单向的,只能由主节点传向从节点,主节点执行写操作,从节点是读操作。主节点会将自己的数据变化通过异步的方式发送给从节点,从节点接收到主节点二点数据之后,更新自己的数据,这样就达到了数据一致的目的

通过配置文件修改从节点

数据同步psync

主从数据同步,同步过程为:全量复制和部分复制

全量复制:⼀般⽤于初次复制场景,Redis 早期⽀持的复制功能只有全量复制,它会把主节点全部数据⼀次性发送给从节点,当数据量较⼤时,会对主从节点和⽹络造成很⼤的开销。

部分复制:⽤于处理在主从复制中因⽹络闪断等原因造成的数据丢失场景,当从节点再次连上主节点后,如果条件允许,主节点会补发数据给从节点。因为补发的数据远⼩于全量数据,可以有效避免全量复制的过⾼开销。

 psync replicationid offset

replicationid : 是主节点启动的时候生成的复制id,每次启动id都不同,从节点和主节点建立了复制关系以后,就会从主节点这里获取到这个id

offset:表示偏移量。主节点会把存入的命令字节数进行累加,当从节点的偏移量和主节点的偏移量相同时,就表示从节点已经同步数据完毕。

当我们使用psync来同步时,psync replicationid -1就表示获取全量数据。psync replicationid 正整数则表示从当前偏移量位置来进行获取数据。

psync执行流程:

从节点发送 psync 命令给主节点,replid 和 offset 的默认值分别是 ? 和 -1.

主节点根据 psync 参数和⾃⾝数据情况决定响应结果:

如果回复 +FULLRESYNC replid offset,则从节点需要进⾏全量复制流程。

如果回复 +CONTINEU,从节点进⾏部分复制流程。

如果回复 -ERR,说明 Redis 主节点版本过低,不⽀持 psync 命令。从节点可以使⽤ sync 命令进⾏全量复制。

  1. psync ⼀般不需要⼿动执⾏. Redis 会在主从复制模式下⾃动调⽤执⾏.
  2. sync 会阻塞 redis server 处理其他请求. psync 则不会.

全量复制流程:

  • 从节点发送 psync 命令给主节点进⾏数据同步,由于是第⼀次进⾏复制,从节点没有主节点的运⾏ ID 和复制偏移量,所以发送 psync ? -1。
  • 主节点根据命令,解析出要进⾏全量复制,回复 +FULLRESYNC 响应。
  • 从节点接收主节点的运⾏信息进⾏保存。
  • 主节点执⾏ bgsave 进⾏ RDB ⽂件的持久化。
  • 主节点发送 RDB ⽂件给从节点,从节点保存 RDB 数据到本地硬盘。
  • 主节点将从⽣成 RDB 到接收完成期间执⾏的写命令,写⼊缓冲区中,等从节点保存完 RDB ⽂件后,主节点再将缓冲区内的数据补发给从节点,补发的数据仍然按照 rdb 的⼆进制格式追加写⼊到收到的 rdb ⽂件中. 保持主从⼀致性。
  • 从节点清空⾃⾝原有旧数据。
  • 从节点加载 RDB ⽂件得到与主节点⼀致的数据。
  • 如果从节点加载 RDB 完成之后,并且开启了 AOF 持久化功能,它会进⾏ bgrewrite 操作,得到最近的 AOF ⽂件。

部分复制

使⽤psync replicationId offset命令实现

过程

  • 当主从节点之间出现⽹络中断时,如果超过 repl-timeout 时间,主节点会认为从节点故障并终止复制连接。
  • 主从连接中断期间主节点依然响应命令,但这些复制命令都因⽹络中断⽆法及时发送给从节点,所以暂时将这些命令滞留在复制积压缓冲区中。
  • 当主从节点⽹络恢复后,从节点再次连上主节点。
  • 从节点将之前保存的 replicationId 和 复制偏移量offset作为 psync 的参数发送给主节点,请求进⾏部分复制。(主节点如果发现replicationid不一样,那就会进行全量复制,否则再使用offset进行部分复制)
  • 主节点接到 psync 请求后,进⾏必要的验证。随后根据 offset 去复制积压缓冲区查找合适的数据,并响应 +CONTINUE 给从节点。
  • 主节点将需要从节点同步的数据发送给从节点,最终完成⼀致性

注意:全量复制以后,主节点数据改动时,也会进行部分复制。

http://www.xdnf.cn/news/923887.html

相关文章:

  • go中的接口返回设计思想
  • AI Agent 与 Agentic AI 企业实践
  • 湖北理元理律师事务所:债务优化中的民生保障实践
  • 【C/C++】std::vector成员函数清单
  • 力扣HOT100之二分查找:33. 搜索旋转排序数组
  • Docke启动Ktransformers部署Qwen3MOE模型实战与性能测试
  • 如何理解ES6模块化方案的缓存机制?
  • SpringBoot离线应用的5种实现方式
  • 【python】RGB to YUV and YUV to RGB
  • 使用python实现奔跑的线条效果
  • 【八股消消乐】MySQL存储引擎InnoDB知识点汇总
  • 深入解析快速排序算法:原理、优化与应用
  • java内存模型JMM
  • 图上合成:用于大型语言模型持续预训练的知识合成数据生成
  • Python: 告别 ModuleNotFoundError, 解决 pipx 环境下 sshuttle 缺少 pydivert 依赖的终极指南
  • Redis Key过期策略
  • 关于 ​​Thread 与 Runnable​​ 以及 ​​线程生命周期​​ 的详细说明与示例
  • Protobuf 中的类型查找规则
  • ADB识别手机系统弹授权框-如何处理多重弹框叠加和重叠问题
  • 现代C++特性(一):基本数据类型扩展
  • Unity的日志管理类
  • 东芝Toshiba e-STUDIO2110AC打印机信息
  • 用电脑通过USB总线连接控制keysight示波器
  • csrf攻击学习
  • Java 8 Stream API 入门到实践详解
  • Robot Framework 一个通用的 自动化测试框架
  • 【DAY42】Grad-CAM与Hook函数
  • 大模型Agent智能体介绍和应用场景
  • SpiritTools:一款小而精的实用工具箱
  • nonlocal 与global关键字