|
|
4 n, R: T0 ~* h; g0 F+ s1 N0 F2 T<p>上一节提到了 Redis 的持久性，也就是在服务器实例宕机或故障时，拥有再恢复的能力。但是在这个服务器实例宕机恢复期间，是无法接受新的数据请求。对于整体服务而言这是无法容忍的，因此我们可以使用多个服务器实例，在一个实例宕机中断时，另外的服务器实例可以继续对外提供服务，从而不中断业务。Redis 是如何做的呢？Redis 做法是<strong>增加冗余副本</strong>，<strong>将一份数据同时保存在多个实例</strong>上。那么如何保存各个实例之间的数据一致性呢？Redis 采用<strong>主从库读写分离模式</strong>来保证数据副本的一致性。</p>4 E$ I3 h4 O! \7 @, Y
<h2 id="一主从复制介绍">一、主从复制介绍</h2>
, x7 T8 @" C* A; r. P, W7 k# ^7 d% K<p>在 Redis 中提供复制的服务器称为主服务器（master）,被主服务器进行复制的服务器称为从服务器（slave ）。但是在复制方式上有所区别，主从库之间采用的是读写分离的方式：</p>
, k! c) j& f A" ]7 J5 b) m<ul>. d; |; O% q' Z/ a5 C3 O' t
<li><strong>读操作</strong>：主库和从库都可接收</li>
, s7 W6 f, V. V" z' D9 Y<li><strong>写操作</strong>：写操作先在主库中执行，然后再将操作同步给从库</li>
! S4 p" O* C0 J- x) P* Z</ul>: ?' ]+ T- t& W% `1 Z9 x9 D
<p><img src="https://img2022.cnblogs.com/blog/1707576/202202/1707576-20220211213252722-390582213.jpg" ></p> J t, D4 k" ]
<p>为何要采用读写分离，因为如果在不同实例上执行修改操作，要保证实例之间的一致性就必须加锁、实例间的协商等操作，会带来巨额的开销。如果采用读写分离，数据的修改迁移到主库上进行，然后再同步到从库上，就可以达到不使用锁达到数据一致性的效果。</p>
; @. w, z% [' D<h2 id="二主从复制原理">二、主从复制原理</h2>
& k! I3 x. p0 G, u& l# [7 u. Z<p>主从复制是如何进行复制的，是一次性全部复制，还是分批一批一批的复制？而且如果复制中网络中断，数据还能保持一致性吗，其内部原理是怎样的？Redis 的复制功能主要有两个操作：</p>
+ g2 e: y- o U5 P! R<ul># }) `: O- _0 b7 \8 I; i
<li>1 U1 O, J. X& I6 _/ P) T
<p><strong>同步（sync）</strong>：同步操作是将从库的数据状态更新至主库当前所处的状态，主要有全量复制和增量复制两种</p>
, V& x# [) [( v6 p</li>* ?4 ]" s/ V( ^. x
<li>. H8 t5 C4 V" j' j! W
<p><strong>命令传播（command propagate）</strong>：命令传播是作用在主库的数据库状态被修改后，主从库之间的数据库状态出现不一致，让主从服务器的数据库状态重新回到一致性。</p>
2 \4 }! N. p# u% f4 W</li>) P1 S- m# o2 q* I& |4 a8 T6 r' u
</ul>
4 H& S6 j% ^" t# ~+ {<h3 id="21-同步操作">2.1 同步操作</h3>
, |# x* s5 s1 v1 Z: V3 [* o<h4 id="211-全量复制">2.1.1 全量复制</h4>
+ n- j* p& c9 S4 d0 L<p>在同步操作中，我们首先来看看全量复制，顾名思义也就是主库将所有的数据传送给从库。因为主从库初始化需要传输全部数据，所以第一次同步其实就是一次全量复制。当启动多个 Redis 实例时，主从库间就可以通过 <code>replicaof</code>(Redis 5.0 前使用的是 <code>slaveof</code>)命令形成主从库的关系，在这期间从库就会全量复制当前主库的数据库状态。主要分为三个阶段：</p>
3 `2 K2 G( E4 `( g<ol>5 J* o" h2 w; S% A# Q, R
<li>
* _$ N7 [; a# ^( Z8 P, {/ [<p><strong>主从库建立连接</strong>：主要是为全量复制做准备，在这一步，从库和主库建立起连接，告知主库进行数据同步，待主库确认回复后，主从库之间可以开始同步。主要的操作是从库给主库发送 <code>psync</code> 命令，主库根据这个命令参数来启动复制。而 <code>psync</code> 命令包含了主库的 <code>runID</code> 和 复制进度 <code>offset</code>两个参数：</p>/ r% y6 s/ p2 n6 O
<ul>3 d# K1 z1 L( i G1 W: |: f
<li><strong><code>runID</code></strong>: 是每个 Redis 实例启动时随机生成的 ID，它是用来唯一标记这个实例。而当主从库第一次复制时，从库不知道主库的 <code>runID</code> 。因此将 <code>runID</code> 设置为 “？”。</li>7 k. \# N3 }9 v, k1 W& ~
<li><strong><code>offset</code></strong>：第一次设置为 -1，表示第一次复制</li>
/ }: u8 ^/ q6 B8 h& ]6 f</ul>, `& X4 u% n5 z9 X+ Z
<p>主库在接收到 psync 命令后，会利用 FULLRESYNC 响应命令带上两个参数：主库 <code>runID</code>和主库目前的复制进度 <code>offset</code> 来返回给从库。而从库在收到响应后会记录下主库传递的这两个参数。</p>
4 ]: ^5 s! `1 C J% i</li>, X# f! z `, V( h, d! V
<li>
1 E/ U( Z4 X# M+ D$ B<p><strong>主库将所有数据同步给从库</strong>：数据同步给从库后，从库接收到数据后，在本地完成数据加载。这个过程主要依赖于内存快照生成的 RDB 文件。</p>
H: ^6 B1 z) e( V4 x' @: f% k0 y( o; y, x<p>内部具体的流程是，主库先执行 <code>bgsave</code> 命令，执行持久化生成 RDB 文件，并将该文件发送给从库。从库在接收到 RDB 文件后，会先清空当前数据库，然后再加载 RDB 文件。</p>
4 {# L) W/ w* h+ |, f3 A<p>在主库同步从库过程中，我们知道 <code>bgsave</code>命令系统会 fork 一个子线程来创建 RDB 文件，另外的主线程可以继续处理命令请求。而在同步过程中的新增的写操作，主库会在内存中用专门的 <code>replication buffer</code> 来记录这些写操作。</p>; u8 D* {9 [5 `$ i3 M
</li>4 _8 j/ B6 R! L& p; H1 a2 Z
<li>
4 }, L# p* j9 {( s+ K<p><strong>主库将新接收的写操作再发送给从库</strong>：当主库完成 RDB 文件发送后，就会将 <code>replication buffer</code> 中的写操作发送给从库，从库再执行这些写操作。到此完成所有的操作数据同步。</p>
( Y/ b5 J L8 O7 z; p" U</li>4 i( v a0 p5 ?2 O) p; Q
</ol>
% I& |/ |+ q! R& L: g2 L- C<p>结合一个实例来展示三个阶段：</p>% B' r! e+ d/ |* F' N3 f5 T
<p>现有两个实例，实例1（ip: 172.16.19.3）和实例 2（ip: 172.16.19.5）。在从实例2上执行以下命令后，实例2 就变成了实例 1 的从实例。执行以下命令后，实例2 就变成了实例1 的从库，并开始复制数据：</p>
" P: }9 `* y( l- X, l<pre><code class="language-sh">replicaof 172.16.19.3 6379
, m2 l8 s4 z) F5 C& P% I5 e</code></pre>
6 y0 i& v2 L! I* m<p><img src="https://img2022.cnblogs.com/blog/1707576/202202/1707576-20220211213311291-1707870632.jpg" ></p>
$ p# f! s2 m! w0 e0 }$ m<h4 id="212-主从从模式复制">2.1.2 主从从模式复制</h4>: F; m9 N( n( t1 E$ Z
<p>在一次全量复制中，对于主库而言需要完成两个消耗资源的操作：发送 RDB 文件和 <code>repl buffer</code> 文件。所以如果请求的从库数量较多时，虽然主库会 fork 子线程进行生成 RDB 文件，但是从库请求数量过多，也会导致主线程 fork 操作过多，最终也会阻塞主线程的其他正常请求。所以，为了解决这个问题，我们可以<strong>通过 “主-从-从”模式来将主库生成 RDB 和传输 RDB 的压力，以级联的方式分散到从库上</strong>。如下图：</p>& K4 z" F" t$ I5 o9 I
<p><img src="https://img2022.cnblogs.com/blog/1707576/202202/1707576-20220211213330954-674647319.jpg" ></p>1 Z+ i0 y. j) A! ?$ f6 B
<p>具体操作是: 在部署主从集群的时候，手动选择一个从库（比如选择内存资源配置较高的从库）用于级联其他的从库。然后可以再选择一些从库（如三分之一的从库），在这些从库上执行下面命令，让它们和刚才所选的从库建立起主从关系：</p>3 x6 K7 ~) ]) I- T& w/ I
<pre><code class="language-sh">replicaof 所选从库的IP 6379; w; B9 k9 ^) r( g+ r, ^: f% w3 z
</code></pre>3 [2 ?; l$ V2 D5 R5 }
<p>这样，这些级联的从库不用和主库进行交互，而只需要和连接的从库进行写操作同步即可。这样就可以减轻主库的压力了。</p>4 H2 T2 l( e5 g: `" H) p
<h4 id="213-增量复制">2.1.3 增量复制</h4>2 M9 c7 |9 X; a8 B! q, W) {
<p>在主从库完成第一次的全量复制后，它们会形成一个网络连接，主库会通过这个连接将后续收到的命令操作再同步给从库。这个过程也称作为<strong>基于长连接的命令传播</strong>。这个长连接可以避免频繁的建立连接开销，后续我们会再提命令传播。</p>
. D2 L& M+ s" m" L: d* i<p>那么为什么需要增量复制呢，因为连接过程中存在着<strong>网络连接和阻塞</strong>，如果网络连接中断，主从库之间就无法实现命令传播。那如果再次进行全量复制，其开销就有点得不偿失。所以新设计出了增量复制，而与全量复制不相同，增量复制只会把主从库网络断联期间主库收到的命令同步给从库。其中重点就是利用<code>repl_backlog_buffer</code> 缓冲区，上面我们知道，在全量复制时，主库会把写操作命令写入 <code>replication buffer</code> ，与此同时，也会把这些操作命令写入 <code>repl_backlog_buffer</code> 缓冲区中（<code>repl_backlog_buffer</code> 是一个环形缓冲区，主库会记录自己写到的位置，从库则会记录自己已经读到的位置）。如下图：</p>
$ v( Q/ ^! X0 E2 J9 [<p><img src="https://img2022.cnblogs.com/blog/1707576/202202/1707576-20220211213421342-676422844.jpg" ></p>* P* S' @1 p$ ?& A9 J
<p>主库在缓冲区的写位置偏移量就是 <code>master_repl_offset</code>，从库的读位置偏移量是 <code>slave_repl_offset</code>。正常情况下两个偏移量基本相等。</p>0 R" \1 W2 O! Z. ^4 G
<p>接下来我们看看网络连接断开时，主库有可能会收到新的写操作命令，一般而言，<code>master_repl_offset</code>会大于 <code>slave_repl_offset</code>。所以当主从库网络连接后，主库只需要将 <code>master_repl_offset</code> 和 <code>slave_repl_offset</code> 中间的命令操作同步给从库。</p>
z* i$ G# P+ R0 e3 Y1 \<p>如上图中的 <code>repl_backlog_buffer</code>示意图，主库和从库之间相差了<code>put d e</code>和 <code>put d f</code> 两个操作，在增量复制时，主库只需要将它们同步给从库即可。</p>
: L) N0 b+ T9 a% ~ W<p>我们再来看一下增量复制的流程：</p>
$ j. I- Z/ f# a% f" C( ]<p><img src="https://img2022.cnblogs.com/blog/1707576/202202/1707576-20220211213439896-844044503.jpg" ></p>
% {: E) D$ Q' B6 [* [1 ~& R<p><code>repl_backlog_buffer</code> 是一个环形缓冲区，所以存在这样的情况：在缓冲区写满后，主库会继续写入，这样就会覆盖之前的写操作，那么这有可能就会导致主从库之间的数据不一致。此时，我们可以调整 <code>repl_backlog_size</code> 这个参数，实际情况下可以根据应用调整 <code>repl_backlog_size</code> 的大小。</p> s4 H" l4 e2 ~8 x6 J
<h3 id="22-命令传播">2.2 命令传播</h3>
* A& [1 n7 k3 [: T, t4 f<p>在上述初始化全量复制结束后，主从库两者的数据库状态达到一致完成了同步，后面两者则处于长连接状态。此时主库只需要一直将自己执行的写命令发送给从库，从库一直接收并执行主库发来的写命令即可保证主从库的数据一致性了。这个时候主从库会互相成为对方的客户端。</p>: A. M1 i# i7 a3 f M& Z; B d+ @
<h4 id="221-主库的命令传播">2.2.1 主库的命令传播</h4>
& v9 ~6 C- ^! f, e<p>当完成了同步之后，主从库就会进入命令传播阶段，这时主库只要一直将自己执行的写命令发送给从库，而从库只要一 直接收并执行主库发来的写命令，就可以保证主从库保持数据操作一致性。</p>
' h9 I+ F$ x) ^1 i! m<h4 id="222-从库的心跳检测">2.2.2 从库的心跳检测</h4>7 i- c$ w2 x/ z+ _1 [: c1 i E3 W R
<p>在该阶段，从库默认会以每秒一次的频率向主库发送命令：</p>7 Q2 G+ C G7 k
<pre><code class="language-sh">REPLCONF ACK <replication_offset>- `% V Q. |4 \
</code></pre>9 {( l7 n4 }- q$ e% t) }
<ul>
% l. f8 W, ?+ b7 U<li>8 Q/ S0 _) C: ~8 ^6 x$ E$ A+ T
<p>replication_offset 是从库当前的复制偏移量</p>
# }! g9 G, }6 w8 J& w</li>6 y2 ]% w0 f! j8 @) Z( |2 v2 }
<li>
; F/ d3 B* h# U* D# r6 G7 b4 k<p>REPLCONF ACK 命令的作用有</p>4 b7 o0 l/ j* L- m: k* F
<ul>
. Z" r H3 l4 k<li>- X; n8 i& J. T
<p>检测主从库的网络连接状态：当主库超过一秒钟未收到从库发来的 REPLCONF ACK 命令，那么主库就会知道主从库之间连接出现问题。</p>
/ H) b9 }* }. D2 {- Z1 z</li>; Q1 C$ {% |7 F: j+ p' ~0 K
<li>
D Q) A" @# ]' f8 e<p>辅助实现 min-slaves 选项：Redis的<code>min-slaves-to-write</code>和<code>min-slaves-max-lag</code>两个选项可以防止主库在不安全的情况下执行写命令。</p>/ w9 N( P [' ]# e
<ul>) @* {- D( O, j8 @; c7 W: F
<li># M3 ]2 L5 T `' c) G; } g
<p>举个例子，如果我们向主库提供以下设置：</p>
0 }6 {$ g" h" A<pre><code class="language-sh">min-slaves-to-write 3
0 Z$ r! P+ g! }; U2 Z O1 smin-slaves-max-lag 10, |- C" N- S! r+ W
</code></pre>4 b' x8 r* U d+ L2 Z2 U9 Y0 ?8 s- P
<p>那么在从库的数量少于3个，或者三个从库的延迟（lag） 值都大于或等于10秒时，主库将拒绝执行写命令，这里的延迟值就是上面提到的INFO replication命令的lag值。</p>
% O2 h+ A% Q& ]</li>* }( E$ A7 b0 ~# S
</ul>0 O2 e% k1 f1 F
</li># }* u* I, i! K8 P
<li>
: V7 Y' b, y, H<p>检测命令丢失: 如果因为网络故障，主库传播给从库的写命令在半路丢 失，那么<strong>当从库向主库发送REPLCONF ACK命令时，主库将发觉从库当前的复制偏移量少于自己的复制偏移量</strong>，然后主库就会根据从库提交的复制偏移量，在复制积压缓冲区（<code>repl_backlog</code>）里面找到从库缺少的数据，并将这些数据重新发送给从库。</p>
?6 s" x8 i3 q7 B" C/ k2 b* C, a</li>
9 }1 D" o# p4 C* R% i+ p; T</ul>
4 h: h6 S- K% l, L8 ?</li>1 N9 ^4 ^8 F* x! }
</ul># p P* }) O, ^- F( Z$ w
<p>总结就是在传播命令阶段，主库通过向从库传播命令来更新从库的状态，保持主从库一致。而从库则通过向主库发送命令来进行心跳检测，以及命令丢失检测。</p>
7 z, u$ V% m) z- [; X# J<h2 id="三主从复制的面试题">三、主从复制的面试题</h2>% w# Z* Q3 S6 |+ A5 {
<h3 id="31-aof-记录的操作命令更全相比-rdb-丢失的数据更少那么为什么主从库间的复制不使用-aof-">3.1 AOF 记录的操作命令更全，相比 RDB 丢失的数据更少，那么为什么主从库间的复制不使用 AOF ?</h3>
( j0 ?$ w. O; I! ~ e5 x0 @1 {<ul>$ `2 p/ s, ?, ~& k& N0 U
<li><strong>RDB 文件是以压缩二进制的方式存储，文件小</strong>，所以在从库加载 RDB 文件时，速度会很快。而 AOF 需要依次重放每个写命令，过程相对 RDB 文件的方式要慢的多。</li>
5 k0 S% [1 [8 I+ `3 E" a- D<li>如果使用AOF 做全量复制，打开 AOF 功能需要选择文件刷盘的方式,选择不当会严重影响 Redis 的性能。而 RDB 持久化方式只需要定时备份和主从全量复制数据时才会触发生成一次快照。在大多数丢失数据不敏感的业务场景，其实是不需要开启 AOF 的。</li>
& t0 |" P1 J2 U' J$ }7 j</ul>
6 m u) x, R; l) _5 H' ?<h3 id="32-如何处理读写分离中的问题">3.2 如何处理读写分离中的问题</h3>
7 B% |; |9 E% Y5 e# i<p>Redis 的读写分离可以实现 Redis 的读负载均衡，能够提高 Redis 服务器的并发量，但是在使用 Redis 读写分离时，也需要注意延迟不一致、数据过期问题。</p>
. X" c) Q4 D/ k1 R% E<h4 id="321-延迟与不一致问题">3.2.1 延迟与不一致问题</h4>/ z( k: J+ Z+ M" {
<p>对于命令传播阶段：因为命令传播阶段是异步操作，所以延迟与数据的不一致无法避免。有以下解决方式：</p>
! g7 @( Q. Y4 j0 ]<ul>
& B/ I Q' l0 R0 X2 O8 D- B/ }<li>若应用对数据不一致的接受程度较低，可以优化中从节点之间的网络环境、使用集群同时扩展写负载和读负载、监控主从节点延迟（offset）判断，若从节点延迟过大，则通知应用不再通过该从节点读取数据</li>
, }# f8 i H s3 a& o+ O8 n/ ^' m& F</ul>
& A" V; |) f" q' q/ B7 W& X" J<p>对于非命令传播的其他阶段，可以对 <code>slave-serve-stale-date</code> 设置为 no 。则从节点只能响应 info、slaveof 等少数命令，可以保证对数据的一致性。</p> z6 D( X4 }0 J1 n2 A# }* D
<h4 id="322-数据过期问题">3.2.2 数据过期问题</h4>0 B( ]$ b. R2 O9 r5 X6 \5 v
<p>数据过期问题已经在<a href="https://www.cnblogs.com/EthanWong/p/15866054.html"><em>Redis 的键管理</em></a> 中提到过，在单机 Redis 中存在惰性删除和定期删除两种删除策略。而在主从复制场景下，从库不会主动删除数据，主要通过主库控制从库中过期数据的删除。而主库的删除策略都不能保证主库及时对过期数据执行删除操作，所以当客户端通过 Redis 从库读取数据时很容易读取到已经过期的数据。</p> a8 Q7 V; C; Q- T0 y$ o/ H
<h4 id="323-故障切换问题">3.2.3 故障切换问题</h4>! O T2 y0 Z. H9 K4 a9 I0 y
<p>在没有使用哨兵的读写分离场景下，建议写监控程序进行切换读写分别连接的 Redis 节点。针对于手动进行切换的方式更复杂但是不容易出错。</p>$ f1 S! j+ w# _! Y+ t
<h4 id="总结">总结</h4>
: G, c" q8 D6 ]/ c3 @! g. P<blockquote>
% O9 y- r7 f% N. p! J' o' Q: w; p<p>在使用读写分离前，可以考虑其他方法增加Redis的读负载能力：如尽量优化主节点（减少慢查询、减少持久化等其他情况带来的阻塞等）提高负载能力；使用Redis集群同时提高读负载能力和写负载能力等。如果使用读写分离，可以使用哨兵，使主从节点的故障切换尽可能自动化，并减少对应用程序的侵入。</p>4 H1 V. n( Z3 O2 _' P* v& \' U
</blockquote>$ P- g% n+ H/ A* s' C6 K: }$ O3 h
<h2 id="参考资料">参考资料</h2>
1 v% |+ e; l2 g! n<p>《Redis 设计与实现》</p>$ u' K/ X5 x7 E _( l: e9 l
<p>《Redis 开发与运维》</p>% V" X; U) `% Z1 J9 J- j
<p><a href="https://pdai.tech/md/db/nosql-redis/db-redis-x-copy.html">https://pdai.tech/md/db/nosql-redis/db-redis-x-copy.html</a></p>1 H% ?2 C3 q$ [; {3 N8 X
<p><a href="https://time.geekbang.org/column/article/272852">https://time.geekbang.org/column/article/272852</a></p>0 j) `# J3 F+ p# `0 g$ E: V2 a
<p><a href="https://kaiwu.lagou.com/course/courseInfo.htm?courseId=59#/detail/pc?id=1782">https://kaiwu.lagou.com/course/courseInfo.htm?courseId=59#/detail/pc?id=1782</a></p>
# N9 k O- ~% w" _# Q3 u
2 M3 ?; N) P( j* V# v, V5 L |
|
发表于 2022-2-12 14:35:43
发表于 2026-1-12 01:04:16