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

news2025/11/4 2:17:21

目录

  • 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.coloradmin.cn/o/896237.html

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

相关文章

【仿写tomcat】七、项目结构优化以及代码开源

【仿写tomcat】七、项目结构优化以及代码开源

仿写tomcat 项目结构开源地址 项目结构 到目前为止，博主的仿写tomcat就告一段落了，后续有时间了还会继续补充功能，现在的项目结构如下。 在保证功能的前提下作出的改动有： 将各个类中的参数统一成了Config类，通过对…
阅读更多...
Java课题笔记~ Ajax

Java课题笔记~ Ajax

1.1 概述 AJAX (Asynchronous JavaScript And XML)：异步的 JavaScript 和 XML。 我们先来说概念中的 JavaScript 和 XML，JavaScript 表明该技术和前端相关；XML 是指以此进行数据交换。 1.1.1 作用 AJAX 作用有以下两方面： 与服…
阅读更多...
百度又开源一款压测工具，可模拟几十亿的并发场景，太强悍了

百度又开源一款压测工具，可模拟几十亿的并发场景，太强悍了

dperf 是百度开源的一款基于 DPDK 的 100Gbps 网络性能和负载测试软件，能够每秒建立千万级的 HTTP 连接、亿级别的并发请求和数百 Gbps 的吞吐量。 优点 性能强大： 基于 DPDK，使用一台普通 x86 服务器就可以产生巨大的流量：千万…
阅读更多...
[oeasy]python0085_[趣味拓展]字体样式_下划线_中划线_闪动效果_反相_取消效果

[oeasy]python0085_[趣味拓展]字体样式_下划线_中划线_闪动效果_反相_取消效果

字体样式 回忆上次内容 \033 xm 可以改变字体样式 0m - 10m 之间设置的 都是字体效果 0m 复原1m 变亮2m 变暗 从3m到10m 又是什么效果 呢？？ 真的可以 让文字 blink闪烁吗？👁 3m 3m 实现斜体字的效果 4m 4m 对应着下划线 控…
阅读更多...
==和equals方法之间的区别，hashcode的理解，String拼接，Spring拆分

==和equals方法之间的区别，hashcode的理解，String拼接，Spring拆分

==和equals方法之间的区别 字符串有字符串常量池的概念,本身就推荐使用String s="字符串", 这种形式来创建字符串对象， 而不是通过new关键字的方式, 因为可以把字符串缓存在字符串常量池中,方便下次使用,不用遇到new就在堆上开辟一块新的空间 有一对双胞胎姐妹,晓苑…
阅读更多...
LabVIEW开发感应电机自动测试台

LabVIEW开发感应电机自动测试台

LabVIEW开发感应电机自动测试台 设计开发先进的电机测试台，能够测试额定功率为0-15hp的单相和三相感应电动机。系统能够测量感应电动机的不同参数，例如电压，电流，有功功率，无功功率，视在功率，功…
阅读更多...
有限状态机--实现cp的功能

有限状态机--实现cp的功能

有限状态机–实现cp的功能 执行的任务 上图是我们想实现的任务&#xff0c;对于A机来说&#xff0c;从fd1读取内容写到fd2&#xff0c;B机要做的是从fd2读取内容写到fd1中。 画出A机的状态。 代码示例 fsm.c #include <stdio.h> #include <stdlib.h> #include …
阅读更多...
ShowMeBug CEO李亚飞受邀参加深圳青年创新创业系列沙龙电子信息专场

ShowMeBug CEO李亚飞受邀参加深圳青年创新创业系列沙龙电子信息专场

7月13日下午&#xff0c;由深圳市科技交流服务中心&#xff08;深圳市科技专家委员会办公室&#xff09;主办&#xff0c;深圳新一代产业园承办的“2023深圳青年创新创业系列沙龙——电子信息专场”活动举行。ShowMeBug CEO李亚飞受邀参加此次活动。 深圳市科学技术协会党组成员…
阅读更多...
web JS高德地图标点、点聚合、自定义图标、自定义窗体信息、换肤等功能实现和高复用性组件封装教程

web JS高德地图标点、点聚合、自定义图标、自定义窗体信息、换肤等功能实现和高复用性组件封装教程

文章目录 前言一、点聚合是什么&#xff1f;二、开发前准备三、API示例1.引入高德地图2.创建地图实例3.添加标点4.删除标点5.删除所有标点&#xff08;覆盖物&#xff09;6.聚合点7.自定义聚合点样式8.清除聚合9.打开窗体信息 四、实战开发需求要求效果图如下&#xff1a;封装思…
阅读更多...
nginx php-fpm安装配置

nginx php-fpm安装配置

nginx php-fpm安装配置 nginx本身不能处理PHP&#xff0c;它只是个web服务器&#xff0c;当接收到请求后&#xff0c;如果是php请求&#xff0c;则发给php解释器处理&#xff0c;并把结果返回给客户端。 nginx一般是把请求发fastcgi管理进程处理&#xff0c;fascgi管理进程选…
阅读更多...
基于YOLOX的输电线路异物检测算法研究及软件设计_有系统有文献，整体认知蛮好的

基于YOLOX的输电线路异物检测算法研究及软件设计_有系统有文献，整体认知蛮好的

我国自改革开放以来&#xff0c;大力发展工业和经济&#xff0c;对电能同样有着巨大的需求&#xff0c;所需求的电能不仅需要保证其数量&#xff0c;还要保障其质量&#xff0c;因此对整个电力系统安全稳定的运行也提出了更高的要求&#xff0c;电力系统发生故障要实时检测并及…
阅读更多...
从零做软件开发项目系列之一综论软件项目开发

从零做软件开发项目系列之一综论软件项目开发

1 引言 有一个三个泥瓦匠的故事。 三个泥瓦匠在砌墙&#xff0c;一个人走过来&#xff0c;问他们在干什么。 　　第一个泥瓦匠没好气地说&#xff0c;你没看见吗&#xff1f;我在辛苦地砌墙呢。 　　第二个回答&#xff0c;我们正在建一座高楼。 　　第三个则洋溢着喜悦说&…
阅读更多...
Vue2子组件修改父组件的方法

Vue2子组件修改父组件的方法

Vuex Vuex 是状态管理器&#xff0c;集中式存储管理所有组件的状态。 Vuex速成整理_AYBAIWAN的博客-CSDN博客https://blog.csdn.net/aybaiwan/article/details/131442547?spm1001.2014.3001.5501vuex中this.$store.commit和this.$store.dispatch的用法_老电影故事的博客-CSD…
阅读更多...
第八届XCTF联赛首场国际外卡赛——WACON2023即将开启！

第八届XCTF联赛首场国际外卡赛——WACON2023即将开启！

由国际战队SuperGuesser操刀命题 第八届XCTF首场国际外卡赛 WACON2023即将开启 线上资格赛前6名队伍 将晋级WACON2023总决赛 飞往韩国首尔 与全球顶尖白帽黑客一决高下 总决赛冠军队伍将获得&#xff1a; 3千万韩元&#xff08;折合人民币16万&#xff09;高额奖金 &第八…
阅读更多...
Java IO流（一）IO基础

Java IO流（一）IO基础

概述 IO流本质 I/O表示Input/Output,即数据传输过程中的输入/输出,并且输入和输出都是相对于内存来讲Java IO(输入/输出)流是Java用于处理数据读取和写入的关键组件常见的I|O介质包括 文件(输入|输出)网络(输入|输出)键盘(输出)显示器(输出)使用场景 文件拷贝&#xff08;File&…
阅读更多...
基于Java的深圳坂田附近闲置物品交易群管理系统

基于Java的深圳坂田附近闲置物品交易群管理系统

开发技术&#xff1a;java 开发框架&#xff1a;springmvc、spring、mybatis 数据库&#xff1a;mysql 备注&#xff1a;方便大家将手中的二手闲置物品转让给需要的人&#xff0c;例如大家搬家的时候&#xff0c;有不要的&#xff08;冰箱、洗衣机、桌子、椅子&#xff09;等物…
阅读更多...
【3519DV500】AI算法承载硬件平台_2.5T算力+AI ISP图像处理_超感光视频硬件方案开发

【3519DV500】AI算法承载硬件平台_2.5T算力+AI ISP图像处理_超感光视频硬件方案开发

Hi3519DV500 内置双核 A55 &#xff0c;提供高效、丰富和灵活的CPU 资源&#xff0c;以满足客户计算和控制需求。 Hi3519DV500集成了高效的神经网络推理引擎&#xff0c;最高2.5Tops NN算力&#xff0c;支持业界主流的神经 网络框架。神经网络支持完整的 API 和工具链&#xf…
阅读更多...
Qt使用qml（QtLocation）显示地图

Qt使用qml（QtLocation）显示地图

一、qt版本和QtLocation模块版本确认 如果qt版本过低的话是没有QtLocation模块的&#xff0c;我的版本如下 构建工具版本如下 二、qml代码编写 1、工程中添加模块 首先在工程中添加模块quickwidgets positioning location 2、添加资源文件 3、在资源文件中添加qml文件 …
阅读更多...
什么是卷积神经网络

什么是卷积神经网络

目录 什么是卷积神经网络 全链接相对笨重&#xff1a;大胖子​编辑 ​编辑 参数众多&#xff1a;容易造成过拟合 ​编辑 卷积核&#xff1a;进行图像特征提取&#xff0c;源于卷积原理&#xff1a;求相交面积 卷积的作用 卷积的意义 ​编辑 通过卷积核减少参数 深度卷积…
阅读更多...
【001】ts学习笔记-准备工作和【基本类型】

【001】ts学习笔记-准备工作和【基本类型】

typescript安装的包 npm i typescript #安装ts npm i types/node --save-dev # TypeScript 项目中使用类型检查和自动补全。 npm i ts-node -g #可直接在nodejs环境中使用ts, 如&#xff1a;ts-node example.tstsc 常用命令 tsc -init #生成tsc目录下的配置文件:tsconfig.jso…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023