当前位置: 首页 > news >正文

Redis设计与实现第16章 -- Sentinel 总结1(初始化、主从服务器获取信息、发送信息、接收信息)

Sentinel是Redis的高可用解决方案:由一个或多个Sentinel实例组成的Sentinel系统可以监视任意多个主服务器,以及这些主服务器属下的所有从服务器,被监视的主服务器进入下线状态时,自动将下线主服务器属下的某个从服务器升级为新的主服务器,然后由新的主服务器替代已下线的主服务器继续处理命令请求。

16.1 启动并初始化Sentinel

当一个Sentinel启动的时候,需要执行5个步骤

16.1.1 初始化服务器

Sentinel本质上只是一个运行在特殊模式下的Redis服务器,所以启动Sentinel的第一步,就是初始化一个普通的Redis服务器。

区别在于部分功能Sentinel并不会使用,比如不会载入RDB和AOF文件,不会使用数据库和键值对方面的命令、不会使用事务/脚本命令;复制命令在Sentinel内部可以使用,发布和订阅里Publish命令只能在Sentinel内部使用;文件事件处理器和时间事件处理器也同理。

16.1.2 使用Sentinel专用代码

将一部分普通Redis服务器使用的代码替换成Sentinel专用代码,比如,普通Redis服务器使用redis.h/REDIS_SERVERPORT常量的值作为服务器端口,而Sentinel则使用REDIS_SENTINEL_PORT常量作为服务器端口。前者的默认值是6379,后者的默认值是26379

其次,普通Redis服务器使用redis.c/redisCommandTable作为命令表,Sentinel使用sentinel.c/sentinelcmds作为命令表。

16.1.3 初始化Sentinel状态

服务器会初始化一个sentinel.c/sentinelState结构,这个结构保存了服务器里所有和Sentinel功能有关的状态

struct sentinelState {uint64_t current_epoch; //当前纪元 用于实现故障转移;//保存了所有被这个sentinel监视的主服务器//字典的键是主服务器的名字//字典的值则是一个指向sentinelRedisInstance结构的指针dict *masters;//是否进入了TILT模式?int tilt;//目前正在执行的脚本的数量int running_scripts;//进入TILT模式的时间mstime_t tilt_start_time;//最后一次执行时间处理器的时间mstime_t previous_time;//一个EIEO队列,包含了所有需要执行的用户脚本list *scripts_queue;
}sentinel;

16.1.4 初始化Sentinel状态的masters属性

masters字段记录了所有被Sentinel监视的主服务器的相关信息,字典的key是被监视主服务器的名字;value是对应的sentinelRedisInstance结构。

每个sentinelRedisInstance结构(实例结构)代表一个被Sentinel监视的Redis服务器实例,可以是主服务器、从服务器或另一个Sentinel

typedef struct sentinelRedisInstance
//标识值,记录了实例的类型,以及该实例的当前状态int flags;
//实例的名字
//主服务器的名字由用户在配置文件中设置
//从服务器以及Sentinel的名字由Sentinel自动设置//格式为ip:port,例如"127.0.0.1:26379"char *name;
// 实例的运行 IDchar *runid;
//配置纪元,用于实现故障转移uint64_t config_epoch;
//实例的地址sentinelAddr *addr;
//SENTINEL down-after-milliseconds选项设定的值
//实例无响应多少毫秒之后才会被判断为主观下线(subjectively down)mstime_t down_after_period;
//SENTINEL monitor<master-name><IP><port><quorum>选项中的quorum参数
//判断这个实例为客观下线(objectively down)所需的支持投票数量int quorum;
//SENTINEL parallel-syncs<master-name><number>选项的值
//在执行故障转移操作时,可以同时对新的主服务器进行同步的从服务器数量int parallel_syncs;
//SENTINEL failover-timeout <master-name><ms>选项的值
//刷新故障迁移状态的最大时限mstime_t failover_timeout;
}sentinelRedisInstance;

addr属性是一个指向sentinelAddr结构的指针,保存着实例的IP地址和端口号。

masters字典的初始化是根据被载入的Sentinel配置文件来进行的

16.1.5 创建连向主服务器的网络连接

Sentinel将称为主服务器的客户端,可以向主服务器发送命令,会创建2个异步网络连接:

  • 命令连接:专门向主服务器发送命令,并接收命令回复

  • 订阅连接:订阅主服务器的_sentinel_:hello频道

为了不丢失频道的任何信息,必须要有订阅连接

16.2 获取主服务器信息

Sentinel默认会以每十秒一次的频率,通过命令连接向被监视的主服务器发送INFO命令,并通过分析INFO命令的回复来获取主服务器的当前信息。

根据run_id域和role域记录的信息,Sentinel将对主服务器的实例结构进行更新;主服务器返回的从服务器信息,将会被用于更新主服务器实例结构的salves字典,这个字典记录了主服务器属下从服务器的名单。字典的key是由Sentinel自动设置的从服务器名字,格式为ip:port;字典的value是从服务器对应的实例结构。

主服务器实例结构的flags属性的值是SRI_MASTER,而从服务器实例结构的flags属性的值是SRI_SLAVE。主服务器实例结构的name的值是用户使用Sentinel配置文件设置的,而从服务器实例结构的name属性的值则是Sentinel根据从服务器的IP地址和端口号自动设置的。

16.3 获取从服务器信息

当Sentinel发现主服务器有新的从服务器出现时,会为这个新的从服务器创建相应的实例结构,还会创建连接到从服务器的命令连接和订阅链接。

创建命令连接后,默认10秒一次通过命令连接向从服务器发送INFO命令,得到下面信息:

  • 从服务器的运行 ID run_id

  • 从服务器的角色 role

  • 主服务器的IP地址 master_host,以及主服务器的端口号master_port

  • 主从服务器的连接状态master_link_status

  • 从服务器的优先级slave_priority

  • 从服务器的复制偏移量slave_repl_offset

16.4 向主服务器和从服务器发送信息

会以默认2秒一次的频率,通过命令连接向所有被监视的主服务器和从服务器发送命令

PUBLISH _sentinel_:hello "<s_ip>,<s_port>,<s_runid>,
<s_epoch>,<m_name>,<m_ip>,<m_port>,<m_epoch>"

向服务器的_sentinel_:hello频道发送了一条信息,由多个参数组成,其中s_开头的是Sentinel本身的信息,以m_开头的是主服务器的信息,如果正在监视的是主服务器,这些参数就是该主服务器的信息;如果监视的是从服务器,这些参数就是从服务器正在复制的主服务器的信息。

s_epoch表示Sentinel当前的配置纪元,m_epoch表示主服务器当前的配置纪元。

16.5 接收来自主服务器和从服务器的频道信息

当Sentinel与一个主服务器或从服务器建立起订阅连接之后,Sentinel就会通过订阅连接,向服务器发送以下命令,

SUBSCRIBE _sentinel_:hello

每个与Sentinel连接的服务器,Sentinel既通过命令连接向服务器的_sentinel_:hello 频道发送信息,又通过订阅连接从服务器的_sentinel_:hello 频道接收信息。

对于监视同一个服务器的多个Sentinel来说,一个Sentinel发送的信息会被其他Sentinel接收到,这些信息会被用于更新其他 Sentinel对发送信息 Sentinel 的认知也会被用于更新其他Sentinel对被监视服务器的认知。

当一个Sentinel从该频道收到一条信息时,Sentinel会对这条信息进行分析,提取出信息中的Sentinel IP地址,Sentinel端口号、Sentinel运行ID等8个参数,并进行检查:

  • 如果信息中记录的Sentinel运行ID和接收信息的Sentinel的运行ID相同,这条信息就是本身发送的,丢弃

  • 否则,根据收到的信息,对相应主服务器的实例结构进行更新

16.5.1 更新sentinels字典

Sentinel为主服务器创建的实例结构中的sentinels字典保存的是除了该Sentinel本身,所有同样监视这个主服务器的其他Sentinel的资料:字典的key是其中一个Sentinel的名字,格式是ip:port;字典的value是键对应Sentinel的实例结构。

当目标Sentinel收到源Sentinel发来的信息时,会从信息中分析并提取出源Sentinel的相关参数和源Sentinel正在监视的主服务器的参数,并且在自己的Sentinel状态的masters字典里查找对应的主服务器实例结构,检查主服务器实例结构的sentinels字典里,源Sentinel的实例是否存在

  • 如果源Sentinel的实例结构存在,对源Sentinel的实例结构进行更新

  • 如果不存在,说明源Sentinel是刚刚开始监视主服务器的,目标Sentinel会为源Sentinel创建一个新的实例结构,并且添加到sentinels字典里。

masters字段记录了所有被Sentinel监视的主服务器的相关信息,主服务器的信息包含了其他正在监视该主服务器的Sentinel信息。也就是说监视同一个主服务器的多个Sentinel是可以互相自动发现的。

16.5.2 创建连向其他Sentinel的命令连接

当Sentinel通过频道信息发现一个新的Sentinel时,它不仅会为新Sentinel在sentinels字典中创建相应的实例结构,还会创建一个连向新Sentinel的命令连接,而新Sentinel也同样会创建连向这个Sentinel的命令连接,最终监视同一主服务器的多个Sentinel将形成相互连接的网络:Sentinel A有连向Sentinel B的命令连接,而Sentinel B也有连向Sentinel A的命令连接。

使用命令连接相连的各个Sentinel可以通过向其他Sentinel发送命令请求来进行信息交换。

Sentinel之间不会创建订阅连接:因为Sentinel需要通过接收主服务器或从服务器发送的频道信息来发现未知的新Sentinel,所以才需要建立订阅连接;相互已知的Sentinel只需要通过命令连接来通信就足够了

相关文章:

Redis设计与实现第16章 -- Sentinel 总结1(初始化、主从服务器获取信息、发送信息、接收信息)

Sentinel是Redis的高可用解决方案&#xff1a;由一个或多个Sentinel实例组成的Sentinel系统可以监视任意多个主服务器&#xff0c;以及这些主服务器属下的所有从服务器&#xff0c;被监视的主服务器进入下线状态时&#xff0c;自动将下线主服务器属下的某个从服务器升级为新的主…...

Windows10+VirtualBox+Ubuntu:安装虚拟机VirtualBox,虚拟机中安装Ubuntu

一、需求 在Windows10系统中&#xff0c;安装虚拟机VirtualBox&#xff0c;VirtualBox中安装Ubuntu桌面版。 二、环境准备 系统环境 Windows10 内存&#xff1a;8G 虚拟化 虚拟机的运行&#xff0c;如果需要Windows系统开启虚拟化&#xff0c;可以通过BIOS设置。 “虚拟…...

Torchtune在AMD GPU上的使用指南:利用多GPU能力进行LLM微调与扩展

Torchtune on AMD GPUs How-To Guide: Fine-tuning and Scaling LLMs with Multi-GPU Power — ROCm Blogs 这篇博客提供了一份详细的使用Torchtune在AMD GPU上微调和扩展大型语言模型&#xff08;LLM&#xff09;的指南。Torchtune 是一个PyTorch库&#xff0c;旨在让您轻松地…...

C底层 函数栈帧

文章目录 一&#xff0c;什么是寄存器 二&#xff0c;栈和帧 前言 我们在学习c语言程序的时候&#xff0c;是不是有很多的疑问&#xff0c;如 1&#xff0c;为什么形参不可以改变实参 2&#xff0c;为什么我们编写程序的时候会出现烫烫烫......这个乱码 3&#xff0c;那些局…...

【模块一】kubernetes容器编排进阶业务容器化案例

Kubernetes 实战案例 Kubernetes实战案例-规划(基于nerdctl buildkitdcontainerd构建容器镜像) 业务容器化优势&#xff1a; ① 提高资源利用率、节约部署IT成本。 ② 提高部署效率&#xff0c;基于kubernetes实现微服务的快速部署与交付、容器的批量调度与秒级启动。 ③…...

可视化建模以及UML期末复习篇----相关软件安装

作为一个过来人&#xff0c;我的建议是别过来。 一、可视化建模 <1>定义: 官方&#xff1a;一种使用图形符号来表示系统结构和行为的建模技术。 我&#xff1a;其实说白了就是把工作流程用图形画出来。懂不&#xff1f; <2>作用: 提高理解和分析复杂系统的能力。促…...

Appflyer记录卸载事件

Appflyer官方文档 1.原理 1.AppsFlyer每天向Firebase Cloud Messaging&#xff08;FCM&#xff09;和 Apple Push Notification Services&#xff08;APNS&#xff09;发送一次API请求。 2.然后FCM和APNS会发送一条静默推送消息&#xff0c;用于判断用户设备上是否仍装有相关应…...

JDK17 AbstractQueuedSynchronizer 二 条件队列

条件队列 同步队列中的线程是为了争抢锁&#xff0c;而条件队列中的线程是主动释放锁&#xff0c;挂起自己&#xff0c;等条件满足时被别的线程唤醒&#xff0c;继续工作。 AQS里只有1个同步队列&#xff0c;但可以有多个等待队列&#xff0c;每个等待队列对应一个ConditionO…...

8 设计模式之简单工厂模式

设计模式是软件开发中的一套通用解决方案&#xff0c;而简单工厂模式则是最基础、最常用的一种创建型模式。在这篇博客中&#xff0c;我将为大家详细介绍简单工厂模式的概念、优缺点&#xff0c;以及通过一个饮料制作的案例&#xff0c;帮助大家更好地理解和应用这种模式。 一、…...

计算机的错误计算(一百六十九)

摘要 探讨 MATLAB 中一个不动点的计算精度问题。 不动点是一类特殊的循环迭代。它有形式 例1. 已知迭代[1] 计算 显然&#xff0c;每个 均为 0.5 . 下面看看 MATLAB 的计算结果。不妨不用循环语句&#xff0c;直接用算术表达式表示 这时计算结果在如下图片&#xff1a; …...

Android 图形系统之三:SurfaceControl

在 Android 系统中&#xff0c;SurfaceControl 是一个关键的类&#xff0c;用于管理应用窗口和屏幕上的显示内容。它与 SurfaceFlinger 紧密交互&#xff0c;通过 BufferQueue 提供高效的图形缓冲区管理能力。SurfaceControl 是 Android 的显示架构中不可或缺的部分&#xff0c…...

Laravel8.5+微信小程序实现京东商城秒杀方案

一、商品秒杀涉及的知识点 鉴权策略封装掊口访问频次限制小程序设计页面防抖接口调用订单创建事务使用超卖防御 二、订单库存系统方案&#xff08;3种&#xff09; 下单减库存 优点是库存和订单的强一致性&#xff0c;商品不会卖超&#xff0c;但是可能导致恶意下单&#xff…...

Makefile 入门指南:构建自动化编译流程

个人主页&#xff1a;chian-ocean 文章专栏 前言 make 和 Makefile 是编译和构建软件项目时非常常用的工具和文件&#xff0c;它们通常配合使用来自动化项目的编译过程。 make 定义&#xff1a;make 是一个构建自动化工具&#xff0c;用于根据项目文件的依赖关系自动完成编译…...

C#热更原理与HybridCLR

一、Mono的诞生 在Mono之前,C#虽然很好,但是只在windows家族平台上使用,就这点C#与Java就无法比。于是微软公司向ECMA申请将C#作为一种标准。在2001年12月,ECMA发布了ECMA-334 C#语言规范。C#在2003年成为一个ISO标准(ISO/IEC 23270)。意味着只要你遵守CLI(Common Lang…...

里氏替换原则:Java面向对象设计的基石

在面向对象编程&#xff08;OOP&#xff09;中&#xff0c;继承是一个强大的工具&#xff0c;它允许我们创建新的类&#xff08;子类&#xff09;来复用和扩展现有类&#xff08;父类&#xff09;的功能。然而&#xff0c;继承也带来了复杂性&#xff0c;特别是在确保子类能够正…...

恒创科技:服务器操作系统和客户端操作系统之间的区别

客户端操作系统和服务器操作系统是两种不同的操作系统&#xff0c;旨在满足计算机网络环境中的特定目的。虽然每种类型的操作系统在基本功能方面都有一些相似之处&#xff0c;但它们针对不同的用例进行了优化&#xff0c;并具有针对其特定角色量身定制的特定功能。 什么是服务器…...

做异端中的异端 -- Emacs裸奔之路4: 你不需要IDE

确切地说&#xff0c;你不需要在IDE里面编写或者阅读代码。 IDE用于Render资源文件比较合适&#xff0c;但处理文本&#xff0c;并不划算。 这的文本文件&#xff0c;包括源代码&#xff0c;配置文件&#xff0c;文档等非二进制文件。 先说说IDE带的便利: 函数或者变量的自动…...

Unity3d C# 摄像头检测敌方单位(目标层级)并在画面中标注(含源码)

前言 需要实现的功能是通过一个专门的检测摄像头将出现在摄像头画面内的敌方单位检测出来&#xff0c;并通过框选的UI框在画面中标记出来。检测摄像头支持自动检测和手动控制检测&#xff0c;同时需要实现锁定模式&#xff0c;检测到一个敌方单位直接锁定到对象上等功能。 效…...

js 16进制加密

function hexEncode(str) { let hexEncodedStr ‘’; for (let i 0; i < str.length; i) { let charCode str.charCodeAt(i); let hexCode charCode.toString(16).padStart(2, ‘0’); hexEncodedStr ‘\x’ hexCode; } return hexEncodedStr; } // 示例用法 let ori…...

性能测试之压测

1、首先需要提前准备好需要压测的接口地址及对应的接口参数 写好对应的压测接口及对应参数脚本 2、添加线程组&#xff08;根据对应的需求提供的QPS及需要压测的数量如有&#xff09; 如&#xff1a;40个线程&#xff0c;循环次数为永远&#xff08;或者根据自身情况设置循…...

CentOS修改yum.repos.d源,避免“Could not resolve host: mirrorlist.centos.org”错误

1、问题现象 由于CentOS停止维护&#xff0c;mirrorlist.centos.org网站也关闭不可访问。导致CentOS默认配置的yum.repos.d源也不可用&#xff0c;所以执行yum命令会报“Could not resolve host: mirrorlist.centos.org”错误。具体如下&#xff1a; Could not retrieve mirror…...

Python 三目运算实战详解

Python 的三目运算符&#xff08;也称为条件表达式&#xff09;是一种简洁的方式来执行基于条件的赋值或返回值。它的语法类似于其他编程语言中的三元运算符&#xff0c;但有一些细微的不同。在 Python 中&#xff0c;三目运算符的语法如下&#xff1a; value_if_true if cond…...

JVM 性能调优 -- CMS 垃圾回收器 GC 日志分析【Full GC】

前言&#xff1a; 上一篇我们分析了 Minor GC 的发生过程&#xff0c;因为 GC 日志没有按我们预估的思路进行打印&#xff0c;其中打印了 CMS 垃圾回收器的部分日志&#xff0c;本篇我们就来分析一下 CMS 垃圾收集日志。 JVM 系列文章传送门 初识 JVM&#xff08;Java 虚拟机…...

PS的学习

背景差色较大&#xff0c;就魔棒 魔棒的连续就是倒水点的跨越问题 魔棒的容差的选择就有点看经验了&#xff0c;看颜色的统一程度选择 Ctrl D 取消当前所有的选区 至于快速选择工具&#xff0c;和对象选择工具也差不多&#xff0c;只不过控制范围变成了一块一块的&#x…...

数据集搜集器(百科)008

对数据集搜集器&#xff08;百科&#xff09;007进行一下改进&#xff1a; 错误处理&#xff1a;增加更多的错误处理&#xff0c;比如网络请求超时、解析错误等。 用户界面&#xff1a;增加一些提示信息&#xff0c;让用户更清楚当前的操作状态。 多线程处理&#xff1a;确保多…...

Java学习,反射

Java反射是Java编程语言的一个重要特性&#xff0c;它允许程序在运行时查看任意对象所属的类&#xff0c;获取类的内部信息&#xff08;包括构造器、字段和方法等&#xff09;&#xff0c;并能动态地调用对象的方法或构造器。 反射概念 反射&#xff08;Reflection&#xff09…...

数据结构 (18)数的定义与基本术语

前言 数据结构是计算机科学中的一个核心概念&#xff0c;它描述了数据元素之间的关系以及这些元素在计算机中的存储方式。 一、数的定义 在计算机科学中&#xff0c;“数”通常指的是树形数据结构&#xff0c;它是一种非线性的数据结构&#xff0c;由节点&#xff08;或称为元素…...

Flink的双流join理解

如何保证Flink双流Join准确性和及时性、除了窗口join还存在哪些实现方式、究竟如何回答才能完全打动面试官呢。。你将在文中找到答案。 1 引子 1.1 数据库SQL中的JOIN 我们先来看看数据库SQL中的JOIN操作。如下所示的订单查询SQL&#xff0c;通过将订单表的id和订单详情表ord…...

《使用Python进行数据挖掘:理论、应用与案例研究》

嘿&#xff0c;今天我要给你们介绍一本使用Python进行数据挖掘的好书。这本书是由吴迪博士撰写的&#xff0c;他是雷曼学院商学院的助理教授&#xff0c;也是数据科学的实战派。 在这个时代&#xff0c;数据多得让人眼花缭乱&#xff0c;要从中找出有用的信息&#xff0c;那可不…...

Go语言技巧:快速统一字符串中的换行符,解决跨平台问题

统一字符串中的 Windows \r\n 换行符 — Go语言实现 在编程中&#xff0c;尤其是处理跨平台的文本数据时&#xff0c;换行符的处理是一个常见的问题。Windows 系统使用 \r\n 作为换行符&#xff0c;而 Unix-like 系统&#xff08;如 Linux 和 macOS&#xff09;使用 \n。在 Go…...

网站建设免费域名/会计培训班要多少钱

以下是关闭输出编写器的3种不同方式。第一个在try子句中放置close()方法&#xff0c;第二个在try子句中放置close&#xff0c;第三个使用try-with-resources语句。哪个是最合适的&#xff1f;//close() is in try clausetry {PrintWriter out new PrintWriter(new BufferedWri…...

校园网站建设意义/网络营销的盈利模式

作者&#xff1a;朱金灿来源&#xff1a;http://blog.csdn.net/clever101 我们这边把Software翻译为软件&#xff0c;台湾同胞把它翻译为软体。最近生发一点思考&#xff0c;觉得把Software翻译为软体&#xff0c;比翻译为软件更接近Software的本质&#xff0c;也更符合Softwar…...

网站建设的电话客服/佛山网站营销推广

前言 今年3月份阿里面试题其中之一就是防抖与节流&#xff0c;可解决用户体验及改善高频发事件导致浏览器或服务器带来的性能问题。 场景 浏览器条滚动onscroll事件&#xff0c;input输入框input事件&#xff0c;窗口大小改变onresize事件&#xff0c;鼠标移动onmousemove事件等…...

现在给别人做网站还赚钱吗/怎样做网络推广挣钱

迁移时间&#xff1a;2017年5月20日11:16:05CreateTime--2016年9月18日18:20:15Author:Marydon在windows下安装SVN软件 说明&#xff1a;64位的系统只能安装64Bit的tortoise,32位的系统只能安装32Bit的tortoise 中文包--LanguagePack_1.9.4.27285-x64-zh_CN.msi 客户端--Tortoi…...

深圳网站开发建设培训机构/百度推广培训机构

以下内容主要参考 - 带你了解ABAQUS中如何定义各种阻尼&#xff0c;但对部分内容进行了增加和删减。 目录 1. 阻尼的含义 2. 阻尼对响应结构的动态响应的影响 3. Abaqus阻尼设置方式 4. Abaqus阻尼设置 - 具体操作 4.1 直接模态阻尼&#xff1a; 4.2 瑞利阻尼 - 常用&am…...

天眼查网站建设公司/河南网站公司

ASP.NET移动框架&#xff08;AMF&#xff09;是一种最常用的平板电脑和智能手机上Web应用程序的框架&#xff0c;基于jQuery Mobile&#xff08;http://jquerymobile.com&#xff09;的asp.net 开源项目&#xff0c;项目地址是http://amf.codeplex.com/&#xff0c;最新发布的版…...