《Zookeeper》源码分析（十四）之 投票是如何发送与接收的

目录

  • Messenger
    • WorkerSender
    • WorkerReceiver
      • 第5步：检验选票的epoch和version
      • 第6步：处理投票

Messenger

Messenger管理接收到的消息以及待发送的消息，其源码如下：
在这里插入图片描述

它的源码比较简单，接下来着重介绍它维护的两个线程：WorkerSender和WorkerReceiver

WorkerSender

WorkerSender的工作是不断从FastLeaderElection.sendqueue中获取待发送的选票，并将其传递给QuorumCnxManager去等待发送。
在这里插入图片描述

WorkerReceiver

WorkerReceiver的工作相对来说复杂一些，它会不断从QuorumCnxManager获取来自其他服务器发来的信息，并将其转化成一个选票，然后保存到FastLeaderElection.recvqueue中等待FastLeaderElection的选举核心算法处理。
在这里插入图片描述

接下来着重分析第5步和第6步

第5步：检验选票的epoch和version

在这里插入图片描述

第6步：处理投票

在处理外部发送来的选票时，

  1. 如果选票来自不具有投票权的服务器，则忽略该选票，并向对方发送自己的选票
  2. 如果外部选票的选举轮次epoch低于当前服务器，此时外部服务器和当前服务器都处于LOOKING，则向外部服务器发送自己的选票
  3. 如果当前服务器已经选举出leader，而外部服务器仍在选举中，则将自己的选票发送到外部服务器
    在这里插入图片描述

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

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

相关文章

Docker 网络之 ipvlan 和 macvlan

Docker 网络之 ipvlan 和 macvlan

Docker ipvlan 和 macvlan 引言 本文讲解了Docker 网络模式中的 ipvlan 和 macvlan 的区别,目前自己在生产环境中使用的 ipvlan 模式非常问题.也解决了实际业务问题. IPvlan L2 mode example ipvlan 无需网卡混杂模式 , 运行如下命令后可以生成一个 vlan 子接口 , 会和主网卡…
阅读更多...
ElasticSearch的客户端操作

ElasticSearch的客户端操作

ElasticSearch的客户端操作 1、客户端介绍 官方文档地址： https://www.elastic.co/guide/en/elasticsearch/reference/current/index.html 实际开发中，有多种方式操作Elasticsearch： 客户端工具：发送http请求(RESTful风格)操作…
阅读更多...
CF1195E OpenStreetMap 题解

CF1195E OpenStreetMap 题解

很好的单调队列题。 题目传送门 题目意思： 给定一个 n m n\times m nm 的矩阵，求出所有大小为 a b a\times b ab 的子矩形中的最小值的和。 思路： 通过题目给的要求建立二维数组 h h h。通过单调队列一行一行地扫，将扫出来…
阅读更多...
Azure Blob存储使用

Azure Blob存储使用

创建存储账户,性能选择标准即可，冗余选择本地冗余存储即可 容器选择类别选择专用即可 可以上传文件到blob中 打开文件可以看到文件的访问路径 4.编辑中可以修改文件 复制链接，尝试访问，可以看到没有办法访问，因为创建容器的时候选…
阅读更多...
spring(15) SpringBoot启动过程

spring(15) SpringBoot启动过程

目录 一、过程简介二、过程流程图三、源码分析1、运行 SpringApplication.run() 方法2、确定应用程序类型3、加载所有的初始化器4、加载所有的监听器5、设置程序运行的主类6、开启计时器7、将 java.awt.headless 设置为 true8、获取并启用监听器9、设置应用程序参数10、准备环境…
阅读更多...
LeetCode450. 删除二叉搜索树中的节点

LeetCode450. 删除二叉搜索树中的节点

450. 删除二叉搜索树中的节点 文章目录 [450. 删除二叉搜索树中的节点](https://leetcode.cn/problems/delete-node-in-a-bst/)一、题目二、题解方法一：递归（一种麻烦的方法）方法二：优化后的递归 一、题目 给定一个二叉搜索树的根…
阅读更多...
SpringBoot校验，DTO文件中常用的注解应用案例.

SpringBoot校验，DTO文件中常用的注解应用案例.

在观看本篇文章之前，可以先参考我之前写的一篇文章 “ Spring5，Service层对DTO文件进行数据格式校验. ” ，这篇文章是介绍在 Service层 对DTO文件的校验。 以下方的 CompanyDTO 文件为例，讲解不同的注解使用场景，以及…
阅读更多...
论文阅读——Imperceptible Adversarial Attack via Invertible Neural Networks

论文阅读——Imperceptible Adversarial Attack via Invertible Neural Networks

Imperceptible Adversarial Attack via Invertible Neural Networks 作者：Zihan Chen, Ziyue Wang, Junjie Huang*, Wentao Zhao, Xiao Liu, Dejian Guan 解决的问题：虽然视觉不可感知性是对抗性示例的理想特性，但传统的对抗性攻击仍然会产…
阅读更多...
每天一道leetcode：1129. 颜色交替的最短路径（图论中等广度优先遍历）

每天一道leetcode：1129. 颜色交替的最短路径（图论中等广度优先遍历）

今日份题目： 给定一个整数 n，即有向图中的节点数，其中节点标记为 0 到 n - 1。图中的每条边为红色或者蓝色，并且可能存在自环或平行边。 给定两个数组 redEdges 和 blueEdges，其中： redEdges[i] [ai, bi…
阅读更多...
Dubbo Spring Boot Starter 开发微服务应用

Dubbo Spring Boot Starter 开发微服务应用

环境要求 系统：Windows、Linux、MacOS JDK 8 及以上（推荐使用 JDK17） Git IntelliJ IDEA（可选） Docker （可选） 项目介绍 在本任务中，将分为 3 个子模块进行独立开发&#xff…
阅读更多...
LINUX学习笔记_GIT操作命令

LINUX学习笔记_GIT操作命令

LINUX学习笔记 GIT操作命令 基本命令 git init：初始化仓库git status：查看文件状态git add：添加文件到暂存区（index）git commit -m “注释”：提交文件到仓库（repository）git log&a…
阅读更多...
计算机组成与设计 Patterson Hennessy 笔记（一）MIPS 指令集

计算机组成与设计 Patterson Hennessy 笔记（一）MIPS 指令集

计算机的语言：汇编指令集 也就是指令集。本书主要介绍 MIPS 指令集。 汇编指令 算数运算： add a,b,c # abc sub a,b,c # ab-cMIPS 汇编的注释是 # 号。 由于MIPS中寄存器大小32位，是基本访问单位，因此也被称为一个字 word。M…
阅读更多...
Java Web常见面试题

Java Web常见面试题

1、JSP和Servlet有什么区别 jsp经过编译后变成类Servlet（JSP的本质就是Servelt，JVM只能识别java的类，不能识别jsp的代码，于是web容器将jsp的代码编译成JVM能够识别的java类，也就是servelt）jsp更擅长表现于…
阅读更多...
【2023年11月第四版教材】《第5章-信息系统工程之系统集成（第四部分）》

【2023年11月第四版教材】《第5章-信息系统工程之系统集成（第四部分）》

《第5章-信息系统工程之系统集成（第四部分）》 3 系统集成3.1网络集成3.2 数据集成3.3 软件集成3.4 应用集成3.5 安全工程 3 系统集成 3.1网络集成 安全对策要点传输子系统1.常用的无线传输介质主要包括无线电波、微波、红外线等2.常用的有线传输介质主…
阅读更多...
webpack中常见的Loader

webpack中常见的Loader

目录 1.webpack中的loader是什么？配置方式 2. loader特性3.常见的loader 1.webpack中的loader是什么？ loader 用于对模块的"源代码"进行转换，在 import 或"加载"模块时预处理文件 webpack做的事情，仅仅是分…
阅读更多...
爬虫逆向实战（三）--天某云登录

爬虫逆向实战（三）--天某云登录

一、数据接口分析 主页地址：天某云 1、抓包 通过抓包可以发现登录接口是account/login 2、判断是否有加密参数 请求参数是否加密？ 通过“载荷”模块可以发现password、comParam_signature、comParam_seqCode是加密的 请求头是否加密？ 无…
阅读更多...
ElasticSearch 8.9.0 开发模式安装

ElasticSearch 8.9.0 开发模式安装

ElasticSearch 8.9.0 开发模式安装 MacOS（Apple芯片）：https://artifacts.elastic.co/downloads/elasticsearch/elasticsearch-8.9.0-darwin-aarch64.tar.gz Linux：https://artifacts.elastic.co/downloads/elasticsearch/elasti…
阅读更多...
git仓库新建上传记录

git仓库新建上传记录

新建git仓会出现版本分支问题，解决过程： 其他的前期绑定之类的传送：https://blog.csdn.net/qq_37194189/article/details/130767397 大概思路：新建一个分支，上传，合并，删除分支 git branch …
阅读更多...
4.2 C++ Boost 内存池管理库

4.2 C++ Boost 内存池管理库

Boost 库是一个由C/C语言的开发者创建并更新维护的开源类库，其提供了许多功能强大的程序库和工具，用于开发高质量、可移植、高效的C应用程序。Boost库可以作为标准C库的后备，通常被称为准标准库，是C标准化进程的重要开发引擎之一。…
阅读更多...
cmake扩展(5)——file命令排除部分文件

cmake扩展(5)——file命令排除部分文件

在cmake中可以使用file命令获取需要的文件&#xff0c;并且支持正则/通配符&#xff0c;使用起来还是很方便的。 #语法file({GLOB | GLOB_RECURSE} <out-var> [...] [<globbing-expr>...])#example file(GLOB_RECURSE SOURCES "src/*.h" "src/*.cp…
阅读更多...
最新文章

Copyright @ 2022~2023