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;
}

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/239023.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

分子生成工具 - ResGen 评测

ResGen 模型是浙江大学药学院侯廷军老师课题组2023年发表在nature machine intelligence期刊上文章Nature Machine Intelligence | Volume 5 | September 2023 | 1020–1030&#xff0c;题目为&#xff1a;《ResGen is a pocket-aware 3D molecular generation model based on …

java: -source 7 中不支持 lambda 表达式 (请使用 -source 8 或更高版本以启用 lambda 表达式)

目录 1、检查项目中 JDK 的设置&#xff1a; 2、检查模块中 JDK 的设置&#xff1a; 3、检查Idea 中的SDK设置 4、检查 IDEA 中 JDK 的设置&#xff08;我出现的问题在这&#xff09;&#xff1a; 今天遇见了一个报错&#xff1a; 问题产生的原因是 JDK 版本太低&#xf…

从程序员到百万富翁,他的技能和智慧是关健

我要跟大家分享一个超级励志的故事&#xff01;&#x1f389;这个故事的主人公是一位普通的程序员&#xff0c;但他通过自己的努力和智慧&#xff0c;成功地实现了从平凡到非凡的飞跃&#xff0c;成为了一位百万富翁&#xff01;你们一定很好奇他是怎么做到的吧&#xff1f;别急…

【JAVA面试题】什么是深拷贝?什么是浅拷贝?

&#x1f34e;个人博客&#xff1a;个人主页 &#x1f3c6;个人专栏&#xff1a; JAVA ⛳️ 功不唐捐&#xff0c;玉汝于成 目录 前言 一、解释 1. 深拷贝&#xff08;Deep Copy&#xff09;&#xff1a; 2. 浅拷贝&#xff08;Shallow Copy&#xff09;&#xff1…

企业级“RAS”的数据平台如何炼成?

从“看报表”到“数据分析结果直接投入运营”&#xff0c;数字化正在深入企业经营&#xff0c;数据系统正在成为核心生产系统。相应的&#xff0c;企业对“作业挂了”、“系统崩了”、“算不出来”的容忍度越来越低——只有足够稳定、可靠、专业的数据系统&#xff0c;才能及时…

原生微信小程序中使用-阿里字体图标-详解

步骤一 1、打开阿里巴巴矢量图标库 网址&#xff1a;iconfont-阿里巴巴矢量图标库 2、搜索字体图标&#xff0c;鼠标悬浮点击添加入库 3、按如下步骤添加到自己的项目 步骤二 进入微信开发者工具 1、创建 fonts文件夹 > iconfont.wxss 文件&#xff0c;将刚才的代码复制…

python脚本传参

sys.argvargparse 第一种&#xff1a;argparse 简单使用&#xff1a; import argparse # 创建一个参数解析实例 parser argparse.ArgumentParser(descriptionParameters) # 添加参数解析 parser.add_argument(--training_epoch, typeint, default3000) parser.add_argument(…

进程间通信---无名管道

无名管道和有名管道的区别&#xff1a; 无名管道只能用于父进程和子进程之间通信&#xff0c;而有名管道可以用于任意两个进程间通信 管道工作的原理&#xff1a; 切记&#xff1a;无名管道一旦创建完成后&#xff0c;操作无名管道等同于操作文件&#xff0c;无名管道的读端/写…

Codeforces Round 862 (Div. 2)

Problem - A - Codeforces AC代码: #include<bits/stdc.h> #define endl \n //#define int long long using namespace std; const int N1e310; int a[N]; int n; void solve() {cin>>n;int ans0;for(int i1;i<n;i) cin>>a[i],ans^a[i];if(n%21){for(in…

LeetCode——2415. 反转二叉树的奇数层

通过万岁&#xff01;&#xff01;&#xff01; 题目&#xff1a;给你一个完全二叉树&#xff0c;然后将其奇数层进行反转。思路&#xff1a;这个题他都说了是奇数层了&#xff0c;那基本就是层序遍历了。但是存在两个问题&#xff0c;一个是如何判断奇数层&#xff0c;另外一…

测试开发体系介绍——测试体系介绍-L2

目录&#xff1a; 被测系统架构与数据流分析 开源项目 LiteMall 系统架构&#xff1a;开源项目 Mall 的系统架构&#xff1a;如何快速了解一家公司的架构统一建模语言 UML推荐工具梳理业务流程&#xff1a;使用思维导图分析功能点:使用时序图分析数据流:使用活动图分析测试用例…

20-二分-值域二分-分割数组的最大值

这是二分法的第20篇算法&#xff0c;力扣链接。 给定一个非负整数数组 nums 和一个整数 k &#xff0c;你需要将这个数组分成 k 个非空的连续子数组。 设计一个算法使得这 k 个子数组各自和的最大值最小。 示例 1&#xff1a; 输入&#xff1a;nums [7,2,5,10,8], k 2 输出&a…

oracle数据库sqlplus登录卡顿

问题描述 新安装了一套oracle 11.2.0.1 版本的数据库服务器&#xff0c;出现了在服务器本地通过sqlplus / as sysdba登录的时候很快&#xff0c;但是通过监听登录的时候就非常的慢&#xff0c;卡顿&#xff0c;大概需要1分钟多的时间才能登进数据库。 之前安装了好几套oracle …

快手×东方卫视《超省钱大会》荣获“TV地标”2023年度优秀融媒体节目

12月19日&#xff0c;“TV地标”&#xff08;2023&#xff09;电视媒体和网络视听暨“时代之声”&#xff08;2023&#xff09;广播业综合实力大型调研成果发布会在京举办&#xff0c;国家广播电视总局主管的《中国广播影视》杂志公布了此次调研榜单。快手凭借与东方卫视、京东…

2024年你的年度目标OKR制定好了吗?

标题2023年余额见底&#xff0c;2024年的FLAG都制定好了吗&#xff1f; 目标很明确&#xff0c;计划很丰满&#xff0c;执行起来又处处透着一点点乏力&#xff0c;怎么办&#xff1f; 2024年可以尝试用OKR制定目标。 OKR目标管理方法&#xff0c;既适用于企业&#xff0c;也…

一种带缓存DSP28335 CAN程序

一、概述 在嵌入式系统中&#xff0c;CAN&#xff08;控制器局域网络&#xff09;是一种常用的通信协议。然而&#xff0c;为了保证数据的稳定传输和处理效率&#xff0c;我们需要设计一种高效的CAN驱动程序。本文将介绍一种基于DSP28335的带缓存CAN驱动程序设计&#xff0c;该…

flutter + firebase 云消息通知教程 (android-安卓、ios-苹果)

如果能看到这篇文章的 一定已经对手机端的 消息推送通知 有了一定了解。 国内安卓厂商这里不提都有自己的FCM 可自行查找。&#xff08;国内因无法科学原因 &#xff0c;不能使用谷歌服务&#xff09;只说海外的。 目前 adnroid 和 ios 推送消息分别叫 FCM 和 APNs。这里通过…

UG阵列面、阵列集合特征和阵列特征的区别

阵列面 对面进行阵列&#xff0c;当实体中被切除特征的时候可以使用阵列面&#xff0c;当这个命令去阵列一个实体的时候&#xff0c;阵列的是一个片体&#xff0c;优点是速度快&#xff0c;缺点是功能较简单&#xff1b; 阵列几何特征 对实体进行阵列&#xff0c;可以一次性选…

在el-tabs中echarts图表宽高设置style=“width: 100%; height: 100%“不起效变成100px的问题

bug场景 两种情况 一就是如标题一样&#xff0c;给div设置的100%高度&#xff0c;但是最后在elements里检查元素发现高度只有100px。二是&#xff0c;设置了高度为100%&#xff0c;但是检查元素里发现元素高宽为0。 问题解决方案 在使用 ECharts时&#xff0c;将图表嵌套在 …

【稳定检索|投稿优惠】2024年绿色能源与电网电力系统国际会议(ICGEGPS 2024)

2024年绿色能源与电网电力系统国际会议(ICGEGPS 2024) 2024 International Conference on Green Energy and Grid Power Systems(ICGEGPS) 一、【会议简介】 2024年绿色能源与电网电力系统国际会议(ICGEGPS 2024)将在宜宾盛大召开。本次会议将聚焦绿色能源与电网电力系统的最新…