【redis源码学习】从源码角度看主从复制（1）：前期提要

【redis源码学习】从源码角度看主从复制（1）：前期提要

文章目录

• • 主从复制概述
  • 主从复制使用结构

主从复制概述

关于主从复制的概述半年前写过，篇实践性，有兴趣的小伙伴可以看一下：
【redis】跟我一起动手玩玩redis主从复制和哨兵模式

一般来说，主从、哨兵、集群，三个我都放一起讲的，所以我再放一下关于集群的实践篇吧：
【redis】闲得无聊，来聊聊当下爆火的 redis集群，顺便搭一个玩玩呗

不过源码入手的话实在是庞大，光一块儿就要拆成好几篇来写。

主从复制机制主要有以下作用：

1、数据冗余
2、读写分离，主写从读
3、故障恢复，主机挂了哨兵马上扶持从机上位

主从复制流程概述：

1、握手：主从连接成功之后，从节点需要向主节点“自我介绍”
2、同步：连接之后，需要同步数据，使数据达到一致
3、复制：主节点运行阶段将执行的写命令传播给从节点，使用的是异步复制，主节点默认发出即收到，可以提高性能，但是可能在短期内主从数据不一致

同步机制：

全量同步：简单交涉之后，主节点打包RDB数据发送给从节点，一般用于第一次同步数据。
部分同步：主节点将复制积压区中offset偏移量之后的命令发送给从节点，常用于主从断开重连之后同步数据。

---

主从复制使用结构

struct redisServer {
	
    char replid[CONFIG_RUN_ID_SIZE+1];  // Redis服务器的运行ID，随机字符
    char replid2[CONFIG_RUN_ID_SIZE+1]; // 从主服务器中复制出来的ID
    long long master_repl_offset;   
    long long second_replid_offset; 
    int slaveseldb;                 
    int repl_ping_slave_period;     // 发送心跳包的周期
    char *repl_backlog;             // 复制缓冲区
    long long repl_backlog_size;    // 复制缓冲区中第一个字节的偏移量
    long long repl_backlog_histlen; // 缓冲区中存储的数据真实长度
    long long repl_backlog_idx;     // 复制缓冲区中最后一个字节的位置
    long long repl_backlog_off;     
    time_t repl_backlog_time_limit; 
    time_t repl_no_slaves_since;    
    int repl_min_slaves_to_write;   
    int repl_min_slaves_max_lag;    
    int repl_good_slaves_count;     // 当前有效从服务器数量
    int repl_diskless_sync;         
    int repl_diskless_load;         
    int repl_diskless_sync_delay;   
    
    
    char *masteruser;               
    char *masterauth;               
    char *masterhost;               
    int masterport;                 
    int repl_timeout;               
    client *master;     // 连接成功后，主从服务器互为客户端
    client *cached_master; 
    int repl_syncio_timeout; 
    int repl_state;          
    off_t repl_transfer_size; 
    off_t repl_transfer_read; 
    off_t repl_transfer_last_fsync_off; 
    connection *repl_transfer_s;     
    int repl_transfer_fd;    
    char *repl_transfer_tmpfile; 
    time_t repl_transfer_lastio; 
    int repl_serve_stale_data; // 连接断开之后，是否继续处理数据
    int repl_slave_ro;          // 从机是否被设置为只读
    int repl_slave_ignore_maxmemory;    
    time_t repl_down_since; 
    int repl_disable_tcp_nodelay;   
    int slave_priority;             
    int slave_announce_port;        
    char *slave_announce_ip;        
    
    char master_replid[CONFIG_RUN_ID_SIZE+1];  
    long long master_initial_offset;           
    int repl_slave_lazy_flush;          
   
    
    dict *repl_scriptcache_dict;        
    list *repl_scriptcache_fifo;        
    unsigned int repl_scriptcache_size; 
    
    list *clients_waiting_acks;         
    int get_ack_from_slaves;            
};

---