《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风格)操作…
阅读更多...
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/)一、题目二、题解方法一：递归（一种麻烦的方法）方法二：优化后的递归 一、题目 给定一个二叉搜索树的根…
阅读更多...
论文阅读——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…
阅读更多...
计算机组成与设计 Patterson Hennessy 笔记（一）MIPS 指令集

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

计算机的语言：汇编指令集 也就是指令集。本书主要介绍 MIPS 指令集。 汇编指令 算数运算： add a,b,c # abc sub a,b,c # ab-cMIPS 汇编的注释是 # 号。 由于MIPS中寄存器大小32位，是基本访问单位，因此也被称为一个字 word。M…
阅读更多...
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是加密的 请求头是否加密？ 无…
阅读更多...
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…
阅读更多...
HTTP与HTTPS的区别

HTTP与HTTPS的区别

面试常见问题&#xff0c;HTTPS优化总结易记版&#xff1a; 1、HSTS重定向技术&#xff1a;将http自动转换为https&#xff0c;减少301重定向 2、TLS握手优化&#xff1a;在TLS握手完成前客户端就提前向服务器发送数据 3、会话标识符&#xff1a;服务器记录下与某客户端的会…
阅读更多...
Mac鼠标增强工具Smooze Pro

Mac鼠标增强工具Smooze Pro

Smooze Pro是一款Mac上的鼠标手势增强工具&#xff0c;可以让用户使用鼠标手势来控制应用程序和系统功能。 它支持多种手势操作&#xff0c;包括单指、双指、三指和四指手势&#xff0c;并且可以自定义每种手势的功能。例如&#xff0c;您可以使用单指向下滑动手势来启动Expos视…
阅读更多...
Linux 僵死进程

Linux 僵死进程

fork复制进程之后&#xff0c;会产生一个进程叫做子进程&#xff0c;被复制的进程就是父进程。不管父进程先结束&#xff0c;还是子进程先结束&#xff0c;对另外一个进程完全没有影响&#xff0c;父进程和子进程是两个不同的进程。 一、孤儿进程 现在有以下代码&#xff1a;…
阅读更多...
前端基础（JavaScript语法）

前端基础（JavaScript语法）

前言&#xff1a;今天学习JavaScript的基本语法&#xff0c;包括变量、函数、对象、数组。 目录 JavaScript 变量 函数 对象 数组 JavaScript 变量 定义变量 判断语句 判断等于&#xff1a; 判断不等于&#xff1a;! if else语句 if(vavb){ console.log("…
阅读更多...
springboot 整合swagger 入门 使用

springboot 整合swagger 入门 使用

1.前提 一定要看好版本。 Springboot ✚ Swagger各版本整理_swagger版本_qq_33334411的博客-CSDN博客 我的版本: <dependency><groupId>io.springfox</groupId><artifactId>springfox-boot-starter</artifactId><version>3.0.0</ver…
阅读更多...
前馈神经网络正则化例子

前馈神经网络正则化例子

直接看代码&#xff1a; import torch import numpy as np import random from IPython import display from matplotlib import pyplot as plt import torchvision import torchvision.transforms as transforms mnist_train torchvision.datasets.MNIST(root…
阅读更多...
Docker：Windows container和Linux container

Docker：Windows container和Linux container

点击"Switch to Windows containers"菜单时&#xff1a; 提示 然后 实际上是运行&#xff1a;com.docker.admin.exe start-service
阅读更多...
成集云 | 乐享问题邀请同步企微提醒 | 解决方案

成集云 | 乐享问题邀请同步企微提醒 | 解决方案

源系统成集云目标系统 方案介绍 腾讯乐享是腾讯公司开发的一款企业社区化知识管理平台&#xff0c;它提供了包括知识库、问答、课堂、考试、活动、投票和论坛等核心应用。这个平台凝聚了腾讯10年的管理经验&#xff0c;可以满足政府、企业和学校在知识管理、学习培训、文化建…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023