Redis哨兵源码分析

在Redis server启动过程中，实现了实例化和初始化

1、哨兵实例化过程，采用redis sentinel指令实例化还是redis server下的参数实例化--sentinel。

// 检查服务器是否以 Sentinel 模式启动
server.sentinel_mode = checkForSentinelMode(argc,argv);/* Returns 1 if there is --sentinel among the arguments or if* argv[0] is exactly "redis-sentinel". */
int checkForSentinelMode(int argc, char **argv) {int j;if (strstr(argv[0],"redis-sentinel") != NULL) return 1;for (j = 1; j < argc; j++)if (!strcmp(argv[j],"--sentinel")) return 1;return 0;
}

 2、如果Redis实例以哨兵模式启动，执行初始化，此时又两个函数需要注意

// 如果服务器以 Sentinel 模式启动。需要执行以下两个初始化操作。if (server.sentinel_mode) {initSentinelConfig();initSentinel();}

initSentinelConfig函数负责初始化哨兵的配置端口号，供全局使用。

// 这个函数会用 Sentinel 所属的属性覆盖服务器默认的属性
void initSentinelConfig(void) {server.port = REDIS_SENTINEL_PORT;
}

2、initSentinel函数操作比较多，基本就是预分配一些配置需要的空间并且初始化默认值。

1、初始化server哨兵命令列表。

2、初始化主服务器信息字典。

3、初始化 TILT 模式的相关选项。

4、初始化脚本相关选项。

/* Perform the Sentinel mode initialization. */
// 以 Sentinel 模式初始化服务器
void initSentinel(void) {int j;/* Remove usual Redis commands from the command table, then just add* the SENTINEL command. */// 清空 Redis 服务器的命令表（该表用于普通模式）dictEmpty(server.commands,NULL);// 将 SENTINEL 模式所用的命令添加进命令表for (j = 0; j < sizeof(sentinelcmds)/sizeof(sentinelcmds[0]); j++) {int retval;struct redisCommand *cmd = sentinelcmds+j;retval = dictAdd(server.commands, sdsnew(cmd->name), cmd);redisAssert(retval == DICT_OK);}/* Initialize various data structures. *//* 初始化 Sentinel 的状态 */// 初始化纪元sentinel.current_epoch = 0;// 初始化保存主服务器信息的字典sentinel.masters = dictCreate(&instancesDictType,NULL);// 初始化 TILT 模式的相关选项sentinel.tilt = 0;sentinel.tilt_start_time = 0;sentinel.previous_time = mstime();// 初始化脚本相关选项sentinel.running_scripts = 0;sentinel.scripts_queue = listCreate();
}

3、启动哨兵实例。

sentinelIsRunning函数-->

sentinelGenerateInitialMonitorEvents函数-->

sentinelEvent函数-->

pubsubPublishMessage函数

发布订阅模式解决哨兵与master、slave节点、或者哨兵实例之间的通讯问题。实际就是通过

pubsubPublishMessage函数完成发布消息给redis客户端列表和订阅了该频道（channel）的实例（哨兵或者主节点）。

/* Publish a message ** 将 message 发送到所有订阅频道 channel 的客户端，* 以及所有订阅了和 channel 频道匹配的模式的客户端。*/
int pubsubPublishMessage(robj *channel, robj *message) {int receivers = 0;dictEntry *de;listNode *ln;listIter li;/* Send to clients listening for that channel */// 取出包含所有订阅频道 channel 的客户端的链表// 并将消息发送给它们de = dictFind(server.pubsub_channels,channel);if (de) {list *list = dictGetVal(de);listNode *ln;listIter li;// 遍历客户端链表，将 message 发送给它们listRewind(list,&li);while ((ln = listNext(&li)) != NULL) {redisClient *c = ln->value;// 回复客户端。// 示例：// 1) "message"// 2) "xxx"// 3) "hello"addReply(c,shared.mbulkhdr[3]);// "message" 字符串addReply(c,shared.messagebulk);// 消息的来源频道addReplyBulk(c,channel);// 消息内容addReplyBulk(c,message);// 接收客户端计数receivers++;}}/* Send to clients listening to matching channels */// 将消息也发送给那些和频道匹配的模式if (listLength(server.pubsub_patterns)) {// 遍历模式链表listRewind(server.pubsub_patterns,&li);channel = getDecodedObject(channel);while ((ln = listNext(&li)) != NULL) {// 取出 pubsubPatternpubsubPattern *pat = ln->value;// 如果 channel 和 pattern 匹配// 就给所有订阅该 pattern 的客户端发送消息if (stringmatchlen((char*)pat->pattern->ptr,sdslen(pat->pattern->ptr),(char*)channel->ptr,sdslen(channel->ptr),0)) {// 回复客户端// 示例：// 1) "pmessage"// 2) "*"// 3) "xxx"// 4) "hello"addReply(pat->client,shared.mbulkhdr[4]);addReply(pat->client,shared.pmessagebulk);addReplyBulk(pat->client,pat->pattern);addReplyBulk(pat->client,channel);addReplyBulk(pat->client,message);// 对接收消息的客户端进行计数receivers++;}}decrRefCount(channel);}// 返回计数return receivers;
}