前言：

说到哨兵之前，可以思考一个问题。为什么有哨兵机制？这一点其实可以从主从复制的优缺点作为考虑。主从复制其实有一个致命的弱点就是它是非高可用的，比如说当主节点出现故障时，那么此时我的写入就会出现问题，切换需要重新配，就无法做到高可用。此时其实就可以用到哨兵进制，哨兵自动发现故障，并通过选举算法重新选举新主完成转移和通知实现高可用。

参考资料：

https://redis.io/topics/sentinel

一篇看着太长分为两篇：

《集群之哨兵sentinel初识》和《集群之哨兵sentinel故障转移》。

（一）理解哨兵模式

基础结构

1.哨兵本身是监听者身份，没有存储功能。在整体体系当中，一个sentinel或者一个群sentinels与redis主从体系是有监听和被监听者关系。

2.哨兵有如下一些功能：监听、通知、自动故障转移、配置提供程序。

1）监听：哨兵会不断检查主服务和从服务是否正常运行。

2）通知：哨兵可以通过API通知到系统管理员或者其他程序，其中一个受监听redis实例出问题。

3）自动转移故障：如果主服务不正常，则哨兵可以启动故障转移，在该从服务升级为主服务。将其该主服务下其他从服务重新配置主服务，并通知使用Redis服务器的应用要使用新地址。

4) 配置提供程序: Sentinel充当客户端服务发现的授权来源, 客户端连接到Sentinels，以询问负责给定服务的当前Redis主服务器的地址。如果发生故障转移，Sentinels将报告新地址。

3.哨兵存在三种交互模式：哨兵与主服务、哨兵与从服务、哨兵与其他哨兵。

4.哨兵体现中有三个角色：master、slave、sentinel。

（二）配置哨兵模

1.1 sentinel.conf配置说明

# 哨兵sentinel监控的redis主节点的 ip port
# sentinel monitor  
sentinel monitor mymaster 127.0.0.163792

# 当在Redis实例中开启了requirepass foobared 授权密码 这样所有连接Redis实例的客户端都要提供密码  
# 设置哨兵sentinel 连接主从的密码 注意必须为主从设置一样的验证密码  
# sentinel auth-pass  
sentinel auth-pass mymaster MySUPER--secret-0123passw0rd  

# 指定多少毫秒之后 主节点没有应答哨兵sentinel 此时 哨兵主观上认为主节点下线 默认30秒  
# sentinel down-after-milliseconds  
sentinel down-after-milliseconds mymaster 30000


# 这个配置项指定了在发生failover主备切换时最多可以有多少个slave同时对新的master进行 同步，  
# 这个数字越小，完成failover所需的时间就越长，  
# 但是如果这个数字越大，就意味着越 多的slave因为replication而不可用。
# 可以通过将这个值设为 1 来保证每次只有一个slave 处于不能处理命令请求的状态。
# sentinel parallel-syncs  
sentinel parallel-syncs mymaster 1


# 故障转移的超时时间 failover-timeout 可以用在以下这些方面：
# 1. 同一个sentinel对同一个master两次failover之间的间隔时间。
# 2. 当一个slave从一个错误的master那里同步数据开始计算时间。直到slave被纠正为向正确的master那里同步数据时。
# 3.当想要取消一个正在进行的failover所需要的时间。
# 4.当进行failover时，配置所有slaves指向新的master所需的最大时间。不过，即使过了这个超时，slaves依然会被正确配置为指向master，
# 但是就不按parallel-syncs所配置的规则来了  
# 默认三分钟  
# sentinel failover-timeout  
sentinel failover-timeout mymaster 180000  


# 哨兵sentinel实例运行的端口 默认26379  
port 26379  


# SCRIPTS EXECUTION  
 
# 配置当某一事件发生时所需要执行的脚本，可以通过脚本来通知管理员，例如当系统运行不正常时发邮件通知相关人员。
# 对于脚本的运行结果有以下规则：
# 若脚本执行后返回1，那么该脚本稍后将会被再次执行，重复次数目前默认为10  
# 若脚本执行后返回2，或者比2更高的一个返回值，脚本将不会重复执行。
# 如果脚本在执行过程中由于收到系统中断信号被终止了，则同返回值为1时的行为相同。
# 一个脚本的最大执行时间为60s，如果超过这个时间，脚本将会被一个SIGKILL信号终止，之后重新执行。
 
# 通知型脚本:当sentinel有任何警告级别的事件发生时（比如说redis实例的主观失效和客观失效等等），将会去调用这个脚本，  
# 这时这个脚本应该通过邮件，SMS等方式去通知系统管理员关于系统不正常运行的信息。调用该脚本时，将传给脚本两个参数，  
# 一个是事件的类型,一个是事件的描述。如果sentinel.conf配置文件中配置了这个脚本路径，那么必须保证这个脚本存在于这个
# 路径，并且是可执行的，否则sentinel无法正常启动成功。
# 通知脚本  
# sentinel notification-script  
sentinel notification-script mymaster /var/redis/notify.sh  
 
# 客户端重新配置主节点参数脚本  
# 当一个master由于failover而发生改变时，这个脚本将会被调用，通知相关的客户端关于master地址已经发生改变的信息。
# 以下参数将会在调用脚本时传给脚本:  
#        
# 目前总是“failover”,  
# 是“leader”或者“observer”中的一个。
# 参数 from-ip, from-port, to-ip, to-port是用来和旧的master和新的master(即旧的slave)通信的  
# 这个脚本应该是通用的，能被多次调用，不是针对性的。
# sentinel client-reconfig-script  
sentinel client-reconfig-script mymaster /var/redis/reconfig.sh


master-name 节点名称，名称只能是[A-z 0-9]以及.-_内的字符。

quorum 当这些quorum个数sentinel哨兵认为master主节点失联,那么这时客观上认为主节点失联了 。

1.2 启动哨兵模式

如果使用的是redis-sentinel可执行文件（或者您具有指向该redis-server可执行文件的名称的符号链接），则可以使用以下命令行运行Sentinel：

redis-sentinel /path/to/sentinel.conf


否则，您可以直接使用redis-server在Sentinel模式下启动的可执行文件：

redis-server /path/to/sentinel.conf --sentinel


server.c源码中可以体现两种加载模式：

intcheckForSentinelMode(int argc, char **argv) {
   int j;

   if (strstr(argv[0],"redis-sentinel") != NULL) return1;
   for (j = 1; j < argc; j++)
       if (!strcmp(argv[j],"--sentinel")) return1;
   return0;
}


（三）哨兵源码解析

2.1 初始化哨兵

1） server.c 哨兵初始化

intmain(int argc, char **argv) {
   //...省略
   server.sentinel_mode = checkForSentinelMode(argc,argv);  //判断是否为哨兵模式
   
   //...省略
   
   if (server.sentinel_mode) {
       initSentinelConfig(); //加载端口
       initSentinel();       //初始化哨兵模式，包括命令调用和各种数据结构。
   }
   //...省略
   if (!server.sentinel_mode) { //普通模式
      //...省略
   } else {
       /*
       检测哨兵模式是否正常配置
       */
       sentinelIsRunning();  
   }
}


initSentinelConfig函数中为加载哨兵端口，默认端口为26379。initSentinel函数中初始化哨兵模式，包括命令调用和各种数据结构。

initSentinel函数如下：

structredisCommandsentinelcmds[] = {
   {"ping",pingCommand,1,"",0,NULL,0,0,0,0,0},
   {"sentinel",sentinelCommand,-2,"",0,NULL,0,0,0,0,0},
   {"subscribe",subscribeCommand,-2,"",0,NULL,0,0,0,0,0},
   {"unsubscribe",unsubscribeCommand,-1,"",0,NULL,0,0,0,0,0},
   {"psubscribe",psubscribeCommand,-2,"",0,NULL,0,0,0,0,0},
   {"punsubscribe",punsubscribeCommand,-1,"",0,NULL,0,0,0,0,0},
   {"publish",sentinelPublishCommand,3,"",0,NULL,0,0,0,0,0},
   {"info",sentinelInfoCommand,-1,"",0,NULL,0,0,0,0,0},
   {"role",sentinelRoleCommand,1,"l",0,NULL,0,0,0,0,0},
   {"client",clientCommand,-2,"rs",0,NULL,0,0,0,0,0},
   {"shutdown",shutdownCommand,-1,"",0,NULL,0,0,0,0,0}
};

voidinitSentinel(void) {
   unsignedint j;

   /* 初始化哨兵命令 */
   dictEmpty(server.commands,NULL);
   for (j = 0; j < sizeof(sentinelcmds)/sizeof(sentinelcmds[0]); j++) {
       int retval;
       structredisCommand *cmd = sentinelcmds+j;

       retval = dictAdd(server.commands, sdsnew(cmd->name), cmd);
       serverAssert(retval == DICT_OK);
   }

   /* 初始化各种数据结构. */
   sentinel.current_epoch = 0;
   sentinel.masters = dictCreate(&instancesDictType,NULL);
   sentinel.tilt = 0;
   sentinel.tilt_start_time = 0;
   sentinel.previous_time = mstime();
   sentinel.running_scripts = 0;
   sentinel.scripts_queue = listCreate();
   sentinel.announce_ip = NULL;
   sentinel.announce_port = 0;
   sentinel.simfailure_flags = SENTINEL_SIMFAILURE_NONE;
   memset(sentinel.myid,0,sizeof(sentinel.myid));
}


redisCommand结构体数组为哨兵模式支持命令集。哨兵有单独的命令集，只支持ping、sentinel、subscribe、unsubscribe、psubscribe、publish、info、role、client、shutdown命令。

2） server.c 哨兵任务

int serverCron(struct aeEventLoop *eventLoop, long long id, void *clientData) {
     //...省略
     run_with_period(100) {
        if (server.sentinel_mode) sentinelTimer();  //哨兵相关模式下运行任务
    }
    //...省略
}

serverCron为initServer函数中的注册时间回调。serverCron中调用sentinelTimer方法中执行哨兵模式中的任务。

包括执行定期操作比如PING、分析主服务和从服务的INFO命令、故障转移等等。

2.2 定期操作

周期执行命令函数sentinelSendPeriodicCommands

voidsentinelSendPeriodicCommands(sentinelRedisInstance *ri) {
   mstime_t now = mstime();
   mstime_t info_period, ping_period;
   int retval;
   //。。。省略

   /* 如果这是一个处于O_DOWN状态的主服务器的从服务器，我们开始发送
       它每秒钟都有信息，而不是通常的哨兵信息期周期 */
   if ((ri->flags & SRI_SLAVE) &&
       ((ri->master->flags & (SRI_O_DOWN|SRI_FAILOVER_IN_PROGRESS)) ||
        (ri->master_link_down_time != 0)))
   {
       info_period = 1000;   //1s
   } else {
       info_period = SENTINEL_INFO_PERIOD; //10s
   }

   /* ping通过 down-after-milliseconds 参数可以配置，默认1秒*/
   ping_period = ri->down_after_period;
   if (ping_period > SENTINEL_PING_PERIOD) ping_period = SENTINEL_PING_PERIOD;

   /* Send INFO to masters and slaves, not sentinels. */
   if ((ri->flags & SRI_SENTINEL) == 0 &&
       (ri->info_refresh == 0 ||
       (now - ri->info_refresh) > info_period))
   {
       retval = redisAsyncCommand(ri->link->cc,
           sentinelInfoReplyCallback, ri, "%s",
           sentinelInstanceMapCommand(ri,"INFO"));
       if (retval == C_OK) ri->link->pending_commands++;
   }

   /* 发送ping */
   if ((now - ri->link->last_pong_time) > ping_period &&
              (now - ri->link->last_ping_time) > ping_period/2) {
       sentinelSendPing(ri);
   }

   /* PUBLISH 发送hello，SENTINEL_PUBLISH_PERIOD为2000则为2s */
   if ((now - ri->last_pub_time) > SENTINEL_PUBLISH_PERIOD) {
       sentinelSendHello(ri);
   }
}


正常情况下每10秒会获取一次info主和从到。每1秒发送ping命令，ping命令down-after-milliseconds可以配置，每2秒广播一次hello msg。

总结：

（1）哨兵没有存储功能。

（2）哨兵服务支持命令：ping、sentinel、subscribe、unsubscribe、psubscribe、publish、info、role、client、shutdown

（3）哨兵提供功能：监听、通知、自动故障转移、配置提供程序。

（4）哨兵有两种启动模式：配置或者命令行参数。

（5）哨兵体现中有三个角色：master、slave、sentinel。

（6）周期函数主从非O_DOWN状态下每10s发送一次info命令到主从。

（7）ping命令默认是1s发送一次，可以通过down-after-milliseconds配置。

（8）每2秒广播一次hello msg。