Redis 7.x 系列【21】主从复制

news2024/11/6 7:31:59

有道无术,术尚可求,有术无道,止于术。

本系列Redis 版本 7.2.5

源码地址:https://gitee.com/pearl-organization/study-redis-demo

文章目录

    • 1. 概述
    • 2. 工作原理
      • 2.1 建立连接
      • 2.2 全量复制
      • 2.3 命令传播
      • 2.4 增量复制
    • 3. 拓扑架构
      • 3.1 一主一从
      • 3.2 一主多从
    • 4. 案例演示
      • 4.1 安装
      • 4.2 修改配置
      • 4.3 启动
      • 4.4 测试

1. 概述

官方文档

主从复制(Master-Slave Replication)是一种常见的数据库复制技术,用于实现数据备份、读写分离和高可用。

Redis 也支持主从复制,可以将一个 Redis 服务器的数据复制到多个其他 Redis ,从服务器(Slave)保持与主服务器(Master)相同的数据副本。

基本概念:

  • 主节点Master):负责接收客户端的写操作,并将其同步到从节点。
  • 从节点Slave):只能接收读操作请求,不能进行写操作。从节点会复制主节点的数据,并保持与主节点的数据同步。

复制方式:

  • 全量复制:主节点将所有数据发送给从节点进行复制,适用于从节点第一次复制数据或从节点数据丢失需要重新复制的情况。
  • 增量复制:主节点只发送最新的修改数据给从节点进行复制,适用于从节点已经复制过数据,只需要同步最新数据的情况。

使用场景:

  • 读写分离:主节点提供写服务,由从节点提供读服务。在写少读多的场景下,通过多个从节点分担读负载,可以大大提高并发能力。
  • 数据备份与恢复:通过主从复制,可以将主服务器的数据实时复制到从服务器,以实现数据的备份和灾难恢复
  • 高可用基石:主从复制是哨兵模式和集群模式能够实施的基础。

2. 工作原理

Redis 主从复制大致可以分为以下三个阶段:

  • 建立连接
  • 全量复制
  • 命令传播
  • 增量复制

序列图如下:

在这里插入图片描述

2.1 建立连接

当从节点初次启动时,需要和主节点建立连接,为数据同步做好准备。

在下面的演示中,使用了 replicaof 配置了主节点 IP 、端口,从节点会根据地址建立 Socket 连接。建立成功后,节点会发送 Ping 命令,以检测连接是否可用。

如果主节点配置了密码认证,从节点还需要配置 masterauth 参数,通过向主节点发送 auth 命令进行认证认证。

建立连接后,Redis 使用心跳机制来监视主从复制中的各个节点的健康状态。主节点会定期向其所有从节点发送 PING 命令,从节点在收到 PING 命令后,会向主节点回复一个 PONG 响应。如果从节点长时间未能响应心跳,主节点可能会将其标记为下线,并尝试重新连接或者执行故障转移。

可以通过设置 repl_ping_replica_period 参数来设置心跳间隔,默认值为 10 秒:

repl-ping-replica-period 10

2.2 全量复制

第一次连接到主节点时,从节点会发送 psync 进行全量复制。主节点收到命令后,执行 bgsave 命令,后台生成 RDB 文件,并在复制缓冲区中记录所有的写命令。

主节点将 RDB 文件和复制缓冲区中的写命令,发送给从节点进行同步、执行,完成复制的初始化。

2.3 命令传播

全量复制完成后,主节点会将执行的写命令发送给从节点,从节点接收命令并执行。

2.4 增量复制

在主从复制环境中,可能会存在因为网络中断、从节点宕机等问题,造成数据传输不完整或中断。当从节点再次连上主节点后,主节点需要补发丢失数据给从节点。

重连前丢失的部分数据,会被保存在复制积压缓冲区中,默认为 1MB 。复制积压缓冲区(repl_backlog_buffer)是一个在主节点上维护的固定大小的先进先出(FIFO)队列。它用于存储主节点最近执行的写命令,以便在从节点连接断开后重新连接时,能够补发从节点在断开期间错过的命令。这样,从节点就可以通过部分复制来更新自己的数据,而不是进行全量复制,从而节省时间和带宽。

每个 Redis 节点启动后都会动态分配一个 40 位的十六进制字符串作为运行 ID,运行 ID 的主要作用是用来唯一识别 Redis 节点,可以使用 info server 命令查看:

主节点:0>info server
# Server
# 运行ID
run_id:e0004e896ede04b48ab9d7149ab7052932d32dac

主从节点会维护自身的复制偏移量 offset ,在主节点使用 info replication 命令可以查看到所有节点的偏移量:

主节点:0>info replication
# Replication
# 角色,可以是 master(主节点)或 slave(从节点)
role:master
# 从节点个数
connected_slaves:2
# 从节点的复制信息,包括 IP、端口、状态、偏移量
slave0:ip=192.168.56.102,port=6379,state=online,offset=656,lag=0
slave1:ip=192.168.56.103,port=6379,state=online,offset=656,lag=1
master_failover_state:no-failover
# 主节点的唯一标识符,用来标识当前主节点的身份
master_replid:2fefa8a05871dd44887cd4d809c8de98758508b7
master_replid2:0000000000000000000000000000000000000000
# 主节点的复制偏移量,表示主节点最后一次成功传输给从节点的数据位置
master_repl_offset:656
second_repl_offset:-1

当主节点写入命令时,会更新自身的偏移量:

最新偏移量=上次偏移量+命令的字节长度

同样,从节点在收到主节点发送的命令后,也会会更新自身的偏移量,并发送给主节点。如果偏移量不一致,则说明主从节点数据不一致。例如下图中, Slave1 因为网络原因断开连接后,偏移量会不一致:
在这里插入图片描述
当从节点重新连接后,发送 PSYNC 命令进行增量复制,命令的格式为:

# runId:主节点运行的id
# offset:当前从节点复制的数据偏移量
psync {runId} {offset}

主节点接收到 PSYNC 命令后,会检查并确定从节点的偏移量,然后开始将未发送的数据部分重新传输给从节点,以使其数据保持同步。

3. 拓扑架构

在部署 Redis 主从复制时,可以采用多种拓扑架构,常用的有:

  • 一主一从
  • 一主多从

3.1 一主一从

一主一从即只有一个主节点和一个从节点,简单易用,适用于小规模应用,单点故障风险高,无法处理主节点宕机情况。

一主一从架构用于主节点出现宕机时从节点提供故障转移支持,当应用写命令并发量较高且需要持久化时,可以只在从节点上开启 AOF,这样既保证数据安全性同时也避免了持久化对主节点的性能干扰。但是这里有一个坑,需要你注意,就是当主节点关闭持久化功能时, 如果主节点脱机要避免自动重启操作。因为主节点之前没有开启持久化功能自动重启后数据集为空,这时从节点如果继续复制主节点会导致从节点数据也被清空的情况,丧失了持久化的意义。安全的做法是在从节点上执行 slaveof no one 断开与主节点的复制关系,再重启主节点从而避免这一问题。

3.2 一主多从

一主多从即只有一个主节点和多个从节点,

一主多从架构可以实现读写分离来减轻主服务器的压力,对于读占比较大的场景,可以把读命令发送到 从节点来分担主节点压力。同时在日常开发中如果需要执行一些比较耗时的读命令,如:keys、sort等,可以在其中一台从节点上执行,防止慢查询对主节点造成阻塞从而影响线上服务的稳定性。对于写并发量较高的场景,多个从节点会导致主节点写命令的多次发送从而过度消耗网络带宽,同时也加重了主节点的负载影响服务稳定性。

4. 案例演示

在这里插入图片描述
一主两从需要三台服务器,部署的节点 IP

  • 主节点:192.168.56.101:6379
  • 从节点一:192.168.56.102:6379
  • 从节点二:192.168.56.103:6379

4.1 安装

这里使用CentOS 7进行演示,虽然CentOS 已经全面停止更新维护,这里只是演示学习,其他Linux安装步骤基本一致(三台服务器都需要安装 Redis)。

首先需要安装GCC环境,用于编译C语言程序,输入命令检查是否已安装:

[root@localhost ~]# gcc -v

如果已安装,版本需要大于4.8.5,未安装时输入以下命令安装GCC

[root@localhost ~]# yum -y install gcc-c++

GCC安装完成后,查看版本:
在这里插入图片描述
下载并安装Redis 7.2.5

# 下载
[root@localhost ~]# wget https://download.redis.io/releases/redis-7.2.5.tar.gz
# 解压
[root@localhost ~]# tar -zxvf redis-7.2.5.tar.gz 
# 安装 systemd 开发包,使用 systemd 管理Redis
[root@localhost ~]# yum -y install systemd-devel
# 编译,USE_SYSTEMD=yes:构建 systemd 支持
[root@localhost ~]# cd redis-7.2.5
[root@localhost ~]# make USE_SYSTEMD=yes
# 安装
[root@localhost ~]# make install
# 切换至命令目录
[root@localhost ~]#cd /usr/local/bin/
[root@localhost ~]#ll

默认安装在 /usr/local/bin/ 位置:

在这里插入图片描述

4.2 修改配置

接下来需要修改所有节点的配置文件,首先从源码中将 Redis 配置文件复制到配置目录:

[root@localhost /]# mkdir /etc/redis
[root@localhost /]# cp ~/redis-7.2.5/redis.conf /etc/redis/
[root@localhost bin]# vim redis.conf

三个节点都需要修改的配置:

# 允许后台启动
daemonize yes
# 关闭保护模式
protected-mode no
# 允许本机以外的地址访问
# bind 127.0.0.1
# 设置密码
requirepass 123456

两个从节点需要单独添加的复制配置:

# 配置主节点 IP、端口
replicaof 192.168.56.101 6379 
# 主节点的认证密码
masterauth "123456"

4.3 启动

这里直接使用命令启动,首先启动主节点,再启动从节点:

./redis-server /etc/redis/redis.conf &

从节点启动日志如下:
在这里插入图片描述

4.4 测试

使用可视化工具,连接所有节点,在任一节点中,可以使用 info replication 命令查看节点信息:

主节点:0>info replication
"# Replication
role:master
# 从节点个数
connected_slaves:2
# 从节点信息
slave0:ip=192.168.56.102,port=6379,state=online,offset=656,lag=0
slave1:ip=192.168.56.103,port=6379,state=online,offset=656,lag=1
master_failover_state:no-failover
master_replid:2fefa8a05871dd44887cd4d809c8de98758508b7
master_replid2:0000000000000000000000000000000000000000
master_repl_offset:656
second_repl_offset:-1
repl_backlog_active:1
repl_backlog_size:1048576
repl_backlog_first_byte_offset:1
repl_backlog_histlen:656
"

在主节点中存入数据:

在这里插入图片描述
可以在从节点中看到,数据被自动复制过来了:

在这里插入图片描述
在从节点中,是不允许执行写操作的:

在这里插入图片描述

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/1912996.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

Git分支结构

目录 1. 线性分支结构 2. 分叉与合并结构 3. 分支与标签的关系 4. 并行开发与分支管理策略 测试(本机系统为Rocky_linux9.4) 合并失败解决 删除分支 删除本地分支 删除远程分支 Git 中的分支结构是版本控制中非常重要的概念之一,它描…

Golang | Leetcode Golang题解之第225题用队列实现栈

题目: 题解: type MyStack struct {queue []int }/** Initialize your data structure here. */ func Constructor() (s MyStack) {return }/** Push element x onto stack. */ func (s *MyStack) Push(x int) {n : len(s.queue)s.queue append(s.queu…

【学术会议征稿】第三届人工智能与智能信息处理国际学术会议(AIIIP 2024)

第三届人工智能与智能信息处理国际学术会议(AIIIP 2024) 2024 3rd International Conference on Artificial Intelligence and Intelligent Information Processing 第三届人工智能与智能信息处理国际学术会议(AIIIP 2024)将于…

初始化线程的4种方式

1. 继承Thread 缺点:无法获取线程的运算结果。 public class ThreadTest{public static void main(String[] args){Thread01 thread new Thread01();thread.start();}public static class Thread01 extends Thread{public void run(){System.out.println("当前…

Qt(一)概念 信号与槽

文章目录 一、概念(一)Qt工具1. Assistant:帮助手册2. Designer:Qt设计师3. xxx.uic文件4. rcc资源文件5. moc:元对象编译器6. qmake7. Qtcreator:集成化的开发软件 (二)创建第一个Q…

C 语言中的联合(Union)的用途是什么?

🍅关注博主🎗️ 带你畅游技术世界,不错过每一次成长机会! 📙C 语言百万年薪修炼课程 通俗易懂,深入浅出,匠心打磨,死磕细节,6年迭代,看过的人都说好。 文章目…

飞速(FS)10G光模块选择指南

飞速(FS)的10G SFP光模块专为万兆每秒(10 Gbps)的数据传输设计,满足多样化网络需求。该光模块支持多种传输距离,具备热插拔和数字诊断监控功能,全面适配200品牌,为客户提供更灵活的选…

智慧灌区信息化系统完整解决方案

一、背景 随着科技的快速发展,智慧灌区信息化系统正逐渐成为提高农业灌溉效率、优化水资源配置的重要手段。本文将详细介绍智慧灌区信息化系统的完整解决方案,包括系统、功能、应用以及优势分析等方面,旨在为灌区的现代化和高效管理提供有力…

clickhouse-jdbc-bridge rce

clickhouse-jdbc-bridge 是什么 JDBC bridge for ClickHouse. It acts as a stateless proxy passing queries from ClickHouse to external datasources. With this extension, you can run distributed query on ClickHouse across multiple datasources in real time, whic…

爆破器材期刊

《爆破器材》简介   《爆破器材》自1958年创刊以来,深受广大读者喜爱,是中国兵工学会主办的中央级技术刊物,在国内外公开发行,近几年已发行到10个国家和地区。《爆破器材》杂志被美国著名检索机构《化学文摘》(CA&a…

Spin Image(旋转图像)

Spin Image特征描述子原理 Spin Image是Johnson于1999年提出,Lazebnik于2005年完善的基于点云空间分布的特征描述方法,其思想是将一定区域的点云分布转换成二维的Spin Image,然后对场景和模型的Spin Image进行相似性度量。Spin Image方法与通…

数据结构--二叉树收尾

1.二叉树销毁 运用递归方法 分类: 根节点左子树右子树(一般都是这个思路,不断进行递归即可) 选择方法(分析): 前序:如果直接销毁根就无法找到左子树右子树 中序:也会导致丢失其…

Linux|背景 环境搭建

目录 一、简述Linux发展史 1.1计算机的诞生 1.2操作系统的诞生 1.3Linux操作系统开源 1.4Linux发行版本 二、搭建Linux环境 三、使用shell远程登入到Linux 一、简述Linux发展史 可能大家未听说过Linux,或者只知道它是一个搭配在计算机上的操作系统&#xff0…

详细谈谈负载均衡的startupProbe探针、livenessProbe探针、readnessProbe探针如何使用以及使用差异化

文章目录 startupProbe探针startupProbe说明示例配置参数解释 使用场景说明实例——要求: 容器在8秒内完成启动,否则杀死对应容器工作流程说明timeoutSeconds: 和 periodSeconds: 参数顺序说明 livenessProbe探针livenessProbe说明示例配置参数解释 使用…

OpenCV MEI相机模型(全向模型)

文章目录 一、简介二、实现代码三、实现效果参考文献一、简介 对于针孔相机模型,由于硬件上的限制(如进光量等),他的视野夹角往往有效区域只有140度左右,因此就有研究人员为每个针孔相机前面再添加一个镜片,如下所示: 通过折射的方式增加了相机成像的视野,虽然仍然达不…

RequestContextHolder多线程获取不到request对象

RequestContextHolder多线程获取不到request对象,调用feign接口时,在Feign中的RequestInterceptor也获取不到HttpServletRequest问题解决方案。 1.RequestContextHolder多线程获取不到request对象 异常信息,报错如下: 2024-07-0…

光学传感器图像处理流程(一)

光学传感器图像处理流程(一) 1. 处理流程总览2. 详细处理流程2.1. 图像预处理2.1.1. 降噪处理2.1.2. 薄云处理2.1.3. 阴影处理 2.2. 辐射校正2.2.1. 辐射定标2.2.2. 大气校正2.2.3. 地形校正 2.3. 几何校正2.3.1. 图像配准2.3.2. 几何粗校正2.3.3. 几何精…

深入了解线程锁的使用及锁的本质

文章目录 线程锁的本质局部锁的使用 锁的封装及演示线程饥饿问题 线程加锁本质可重入和线程安全死锁问题 根据前面内容的概述, 上述我们已经知道了在linux下关于线程封装和线程互斥,锁的相关的概念, 下面就来介绍一下关于线程锁的一些其他概念. 线程锁的本质 当这个锁是全局的…

5.更多

发现一个项目与 MkDocs 类似的项目 PyMdown 拓展文档 ,等待探索。 1.排版模仿 以下网站使用 MkDocs 构建 Material for MkDocs 的美化 - Charles Les Notebook (charleschile.com) Documentation - Home Assistant (home-assistant.io) Godot Docs – master bra…

什么是数据同步服务RSYNC?

大家好呀!这里是码农后端。今天来介绍一下数据同步服务RSYNC,作为Linux/Unix系统中远程或本地复制同步(复制)文件和目录最常用的命令,相比于scp命令,其具有增量备份、数据同步时保持文件的原有属性等优点。…