主从复制原理

概念

部分同步的实现

部分同步由三个部分组成

• 主服务器的复制偏移量和从服务器的复制偏移量

• 主服务器的复制缓冲区

• 服务器的运行id（runid）

复制偏移量

执行复制的双方都会维护一个复制偏移量

• 主服务器每次向从服务器发送N个字节的数据时，会将自己的复制偏移量加N

• 从服务器接收到主服务器发送过来的N个字节数据后，也会将自己的复制偏移量加N
  

如下图所示，主从偏移量都是10086

这时，主服务器向三个从服务器发送了33字节的数据，那么主服务器的偏移量会变成10086+33=10119，而从服务器在收到数据后也会将偏移量设置为10119，如下图所示：

考虑下面的场景，在主服务器发送33字节给从服务器时，主从连接突然断开，如下图所示：

那么在从1与主服务器重连之后，数据该如何同步呢？按照我们的猜想，肯定是根据主从的复制偏移量来进行部分同步，没错，你猜对了😘，不过还与复制缓冲区有关（毕竟至少要告诉主服务器从offset开始，发送多少个字节数据给从服务器吧）

复制缓冲区

由主服务器维护的一个固定长度的先进先出（FIFO）队列，默认大小为1MB

当主服务器发送写命令给从服务器时，同时也会将写命令入队到复制缓冲区中，如下图所示：

因此，主服务器的复制缓冲区内保存了最近发送的写命令，并且会记录每个字节对应的偏移量，如下表格所示：

当从服务器重连上主服务器后，从服务器会通过psync命令将自己的offset发送给主服务器，主服务器会根据这个偏移量来决定做何种操作：

• 如果offset之后的数据仍然存在于复制缓冲区，那么执行部分同步操作

• 如果offset之后的数据不存在，那么执行完整同步操作
  

回到上面主从断开连接的图，当主从服务器恢复连接后

1. 从服务器通过psync命令告诉主服务器自己的offset是10086

2. 主服务器收到psync命令和offset之后，检查了一下复制缓冲区10086偏移量后面的数据还在不在，结果发现这些数据还在，就给从服务器返回了一个continue表示要进行部分同步

3. 接着主服务器会将复制缓冲区里10086偏移量后面的数据（10087至10119）都发送给从服务器

4. 从服务器只要接收到这33字节的数据，就可以回到与主服务器一致的状态，如下图所示：

服务器运行id（用来判断部分同步还是完整同步）

每个redis服务器无论主从都有自己的运行id，当从服务器首次同步的时候，主服务器会将运行id传给从服务器，从服务器将其保存，当从服务器断线重连时，从服务器会将之前的主服务器运行id和当前的比较一下：

• 如果相同，说明断开和重连后连接的是同一台主服务器，那么进行部分同步就可以了

• 相反，主服务器已经改变，那么进行完整同步