ZooKeeper 的工作流程

ZooKeeper 集群中的角色简介:

  • Leader: 负责发起投票和决议,更新系统状态
  • Follower:用于接收客户端请求并向客户端返回结果,在选主过程中参与投票
  • Observer: 可以接收客户端连接,将写请求转发给 Leader 节点,但不会参与 Leader 发起的投票,也不会被选举为 Leader,Observer 的目的是为了扩展系统,提高读取速度

一个 ZooKeeper 集群中同一时间只有一个 Leader,其他的都是 Follower 或 Observer

一、Leader 的工作流程

Leader 的主要功能有三个:

  1. 恢复数据
  2. 维持与 Learner(Follower 和 Observer) 的心跳,接收 Learner 的请求并判断 Learner 的请求消息类型

Learner 的消息类型:

  • PING 消息:Leaner 的心跳信息
  • REQUEST 消息:Follower 发送的提议信息,包括读写请求
  • ACK 消息:Follower 对提议的回复,超过半数的 Follower 通过,则 Commit 该提议
  • REVALIDATE 消息:用来延长 SESSION 有效时间
  1. 根据不同的消息类型,进行不同的处理

二、Follower 的工作流程

Follower 的主要功能有四个:

  1. 向 Leader 发送请求(PING 消息、REQUEST 消息、ACK 消息、REVALIDATE 消息)
  2. 接收 Leader 消息并进行处理
  3. 接收 Client 的请求,如果为写请求,则转发给 Leader
  4. 返回 Client 结果

Follower 循环处理如下几种来自 Leader 的消息:

  1. PING 消息:心跳消息
  2. PROPOSAL 消息:Leader 发起的提案,要求 Follower 投票
  3. COMMIT 消息:服务器端最新一次提案的信息
  4. UPTODATE 消息:表明此 Follower 同步已完成
  5. REVALDATA 消息:根据 Leader 的 REVALDATE 结果,确定关闭等待 revalidate 的 session 还是允许其接收消息
  6. SYNC 消息:返回 SYNC 结果到客户端,这个消息最初由客户端发起,用来强制得到最新的更新

三、Observer 的工作流程

Observer 的工作流程和 Follower 的唯一不同就是 Observer 不会参加 Leader 发起的投票,也不会被选举为 Leader,此处不再赘述。

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

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

相关文章

TikTok真题第4天 | 1366. 通过投票对团队排名、1029.两地调度、562.矩阵中最长的连续1线段

1366. 通过投票对团队排名 题目链接:rank-teams-by-votes/ 解法: 这道题就是统计每个队伍在每个排名的投票数,队伍为A、B、C,则排名有1、2、3,按照投票数进行降序排列。如果有队伍在每个排名的投票数都一样&#xf…

idea Maven图标的使用

idea Maven图标的使用

动态规划算法之数塔问题

package cn.gldwolf.bigdata;/* 3 12 56 23 4 78 34 69 34 19 12 3 54 12 34 *//* 思路:从最底层往上走,判断下层两个节点中的最大值, 并将最大值与上层节点中的值相加得到这一步的最大值, 将最大值保存到新的数塔中 …

Log4j 配置详解

1. Log4j 简介 Log4j 有三个主要的组件: Loggers(记录器):日志类别和级别 Appenders(输出源):日志要输出的地方 Layouts(布局):日志以何种形式输出 1.1 Log…

Iterator主要有三个方法:hasNext()、next()、remove()详解

Iterator主要有三个方法:hasNext()、next()、remove()详解 一、Iterator的API 关于Iterator主要有三个方法:hasNext()、next()、remove()hasNext:没有指针下移操作,只是判断是否存在下一个元素next:指针下移,返回该指…

Java获取登录用户IP地址

Java获取登录用户IP地址 /*** param * return * throws * description * author wqd* date 2021/9/21 13:45*/public static String getIpAddr(HttpServletRequest request) {String ip request.getHeader("x-forwarded-for");if (ip null || ip.length() 0 || &q…

Kafka Shell 基本操作

1. 启动集群每个节点的进程 nohup kafka-server-start.sh \ /home/hadoop/apps/kafka_2.11-1.1.0/config/server.properties \ 1>~/logs/kafka_std.log \ 2>~/logs/kafka_err.log &2. 创建 Topic 解释说明: –create --> 创建 Topic 的选项 –zookee…

Spark 简介

1. 什么是 Spark 官网:http://spark.apache.org Spark 是一个快速、通用、可扩展的大数据分析引擎。 Spark 是基于内存计算的大数据并行计算框架 1.1 Spark 的特点 快:与 Hadoop 的 MapReduce 相比,Spark 基于内存的运算要快 100 倍以上&a…

Linux环境下安装Mysql5.7

本文记录下我近期在Linux环境下安装Mysql5.7的实践经历。 服务器版本Mysql版本Centos 7.65.7.32 1. 下载Mysql 下载地址:https://downloads.mysql.com/archives/community/ 进入页面后选择你需要的版本进行下载,这里提供了2种格式:tar.gz和…

Redis 入门及实战

目录 1. Redis 基本概念 2. Redis 的优势 3. Redis 适用场景 4. Redis-3.2.6 安装(未整理)与测试 5. 使用 Redis 的 Java API 客户端——Jedis 6. 数据结构 6.1 String -- 字符串 6.1.1 String 使用概述 6.1.2 String 常用操作 6.1.3 String 使用案例 6.2 List -- 列…

HBase 简介

HBase 是一个通过大量廉价机器解决海量数据的调整存储和读取的分布式数据库解决方案 HBase 的特点: 高并发,易扩展,解决海量数据集的随机实时增删改查HBase 本质依然是 Key-Value 数据库,不支持 join 等复杂操作不支持复杂的事务…

Flink官网自学笔记

1. What is Apache Flink? Apache Flink 是一款用来进行分布式流数据和批数据处理的开源平台。Apache Flink 是一个对有界数据流和无界数据流进行有状态计算的框架和分布式处理引擎。Flink 被设计用于在所有常见的集群环境中运行,以内存中的速度和任意规模进行计算…

HBase Java API 代码开发

1. API 介绍 几个主要 HBase API 类和数据模型之间的对应关系: Java 类 HBase 数据模型 Admin 数据库(Database) HBaseConfiguration Table 表(Table) HTableDescriptor 列簇(Column Family&#…

HBase 原理

1. HBase 底层原理 1.1 系统架构 1.1.1 Client 职责 1. HBase 有两张特殊的表: .META.: 记录了用户所有表拆分出来的 Region 映射信息,.META. 可以有多个 Region -ROOT-(新版中已去掉这一层): 记录了 .META. 表的 Region 信息,-ROOT- 只有…

用IDEA debug按键功能

用IDEA debug按键功能 一、断点 断点键,是用户在所选行代码处标记的功能点,表示在debug时代码执行到此处暂停。 注:断点可设置多个 二、启动debug 在设置好断点后单击此功能键,启动debug功能。 三、中止任务 点击该功能键&a…

HBase 的表设计

1 ColumnFamily 设计 追求的原则是:在合理的范围内能尽量少的减少列簇就尽量减少列簇。 最优设计是:将所有相关性很强的 Key-Value 都放在同一个列簇下,这样既能做到查询效率最高,也能保持尽可能少的访问不同的磁盘文件。 以用…

shiro原理及其运行流程介绍

什么是shiro shiro是apache的一个开源框架,是一个权限管理的框架,实现 用户认证、用户授权。 spring中有spring security (原名Acegi),是一个权限框架,它和spring依赖过于紧密,没有shiro使用简单。 shiro不依赖于sp…

shiro中文api_Shiro

1 shiro Apache shiro 是一个 Java 安全框架。 功能:认证、授权、加密和会话管理功能 应用环境:JavaEE、JavaSE Subject 可看做成一个用户 SecurityManager 框架的核心API Reaim 域对象,用于取数据库中的数据,进行权限比对。…

Java Lambda 表达式讲解

Lambda 表达式 Lambda 表达式的基础语法 Java8 中引入了一个新的操作符:-> 该操作符称为箭头操作符或者 Lambda 操作符 Lambda 操作符将表达式拆分成两部分: 左侧:Lambda 表达式的参数列表右侧: Lambda 表达式的"函数体" --&…

方法引用、构造器引用和数组引用

方法引用 若 Lambda 体中的内有方法已经实现了,我们可以使用“方法引用”(可以理解为方法引用是 Lambda 表达式的另外一种表现形式) 语法格式 主要有以下三种语法格式: 对象::实例方法名 注意&#xff1…