Java面试之ZooKeeper篇

本文涉及的产品
云原生网关 MSE Higress,422元/月
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
注册配置 MSE Nacos/ZooKeeper,118元/月
简介: 针对Zk的面试题而言,很多面试官喜欢问的就是注册和watcher这两大模块,这两块也是zk的核心,所以必须要掌握。

一.题目介绍


1.题目来源


实际面试中遇到,形式的话有书面解答也有口述,一般侧重点有ZAB协议,Zookeeper的Watcher机制,其数据同步的流程,如何保证事务的顺序一致性


2.题目


1)ZAB协议


2)说一说Zookeeper的Watcher机制


3)数据同步


4)Zookeeper是如何保证事务的顺序一致性的


二.具体解答


1.ZAB协议


ZAB协议是为分布式协调服务Zookeeper专门设计的一种支持崩溃恢复的原子广播协议。 ZAB协议包括两种基本的模式:崩溃恢复和消息广播。当整个zookeeper 集群刚刚启动或者Leader服务器宕机、重启或者网络故障导 致不存在过半的服务器与Leader服务器保持正常通信时,所有进程(服务器)进入崩溃恢复模式,首先选举产生新的Leader服务器,然后集群中Follower服务 器开始与新的Leade 服务器进行数据同步,当集群中超过半数机器与该Leader服务器完成数据同步之后,退出恢复模式进入消息广播模式,Leader服务器开始 接收客户端的事务请求生成事物提案来进行事务请求处理。


2.Zookeeper的Watcher机制


1).发生点:Zookeeper允许客户端向服务端的某个Znode注册一个Watcher监听,当服务端的一些指定事件触发了这个 Watcher,服务端会向指定客户端发送一个事件通知来实现分布式的通知功能,然后客户端根据Watcher通知状态和事件类型做出业务上的改变。


2)大致流程:

客户端注册watcher,发起了通知(消息生产者)

服务端处理watcher,接收并处理通知(消息接收和消费者)

客户端回调watche,为了确保消息已被接收并且消费,使用回调确认


3.数据同步


1)发生点:整个集群完成Leader选举之后,Learner回向Leader服务器进行注册。当Learner服务器向Leader服务器完成注册后,进入数据同步环节。

数据同步流程:(均以消息传递的方式进行)


1)Learner向Learder注册


2)数据同步


3)同步确认(类似AK机制)


4.Zookeeper是如何保证事务的顺序一致性的


1)考察对ZK在分布式系统中事务层面的理解,如果理解两阶段(2PC)的提交过程,这个就不难理解


2)解答:

ZK采用了全局递增的事务Id来标识,所有的proposal(提议都在被提出的时候加上了zxid,zxid实际上是一个64位的数字,高32位是epoch(时 期; 纪元; 世; 新时代)用来标识leader周期,如果有新的leader产生出来,epoch 会自增,低32位用来递增计数。当新产生 proposal 的时候,会依据数据库的两 阶段过程,首先会向其他的server 发出事务执行请求,如果超过半数的机器都能执行并且能够成功,那么就会开始执行。


三.题后思考


针对Zk的面试题而言,很多面试官喜欢问的就是注册和watcher这两大模块,这两块也是zk的核心,所以必须要掌握。

相关实践学习
基于MSE实现微服务的全链路灰度
通过本场景的实验操作,您将了解并实现在线业务的微服务全链路灰度能力。
目录
相关文章
|
6天前
|
监控 Java 应用服务中间件
高级java面试---spring.factories文件的解析源码API机制
【11月更文挑战第20天】Spring Boot是一个用于快速构建基于Spring框架的应用程序的开源框架。它通过自动配置、起步依赖和内嵌服务器等特性,极大地简化了Spring应用的开发和部署过程。本文将深入探讨Spring Boot的背景历史、业务场景、功能点以及底层原理,并通过Java代码手写模拟Spring Boot的启动过程,特别是spring.factories文件的解析源码API机制。
20 2
|
11天前
|
存储 算法 Java
大厂面试高频:什么是自旋锁?Java 实现自旋锁的原理?
本文详解自旋锁的概念、优缺点、使用场景及Java实现。关注【mikechen的互联网架构】,10年+BAT架构经验倾囊相授。
大厂面试高频:什么是自旋锁?Java 实现自旋锁的原理?
|
16天前
|
存储 缓存 Oracle
Java I/O流面试之道
NIO的出现在于提高IO的速度,它相比传统的输入/输出流速度更快。NIO通过管道Channel和缓冲器Buffer来处理数据,可以把管道当成一个矿藏,缓冲器就是矿藏里的卡车。程序通过管道里的缓冲器进行数据交互,而不直接处理数据。程序要么从缓冲器获取数据,要么输入数据到缓冲器。
Java I/O流面试之道
|
12天前
|
存储 缓存 Java
大厂面试必看!Java基本数据类型和包装类的那些坑
本文介绍了Java中的基本数据类型和包装类,包括整数类型、浮点数类型、字符类型和布尔类型。详细讲解了每种类型的特性和应用场景,并探讨了包装类的引入原因、装箱与拆箱机制以及缓存机制。最后总结了面试中常见的相关考点,帮助读者更好地理解和应对面试中的问题。
38 4
|
13天前
|
存储 Java 程序员
Java基础的灵魂——Object类方法详解(社招面试不踩坑)
本文介绍了Java中`Object`类的几个重要方法,包括`toString`、`equals`、`hashCode`、`finalize`、`clone`、`getClass`、`notify`和`wait`。这些方法是面试中的常考点,掌握它们有助于理解Java对象的行为和实现多线程编程。作者通过具体示例和应用场景,详细解析了每个方法的作用和重写技巧,帮助读者更好地应对面试和技术开发。
53 4
|
1月前
|
存储 安全 算法
Java面试题之Java集合面试题 50道(带答案)
这篇文章提供了50道Java集合框架的面试题及其答案,涵盖了集合的基础知识、底层数据结构、不同集合类的特点和用法,以及一些高级主题如并发集合的使用。
86 1
Java面试题之Java集合面试题 50道(带答案)
|
25天前
|
存储 Java 程序员
Java面试加分点!一文读懂HashMap底层实现与扩容机制
本文详细解析了Java中经典的HashMap数据结构,包括其底层实现、扩容机制、put和查找过程、哈希函数以及JDK 1.7与1.8的差异。通过数组、链表和红黑树的组合,HashMap实现了高效的键值对存储与检索。文章还介绍了HashMap在不同版本中的优化,帮助读者更好地理解和应用这一重要工具。
53 5
|
24天前
|
存储 Java
[Java]面试官:你对异常处理了解多少,例如,finally中可以有return吗?
本文介绍了Java中`try...catch...finally`语句的使用细节及返回值问题,并探讨了JDK1.7引入的`try...with...resources`新特性,强调了异常处理机制及资源自动关闭的优势。
19 1
|
1月前
|
Java 程序员
Java 面试高频考点:static 和 final 深度剖析
本文介绍了 Java 中的 `static` 和 `final` 关键字。`static` 修饰的属性和方法属于类而非对象,所有实例共享;`final` 用于变量、方法和类,确保其不可修改或继承。两者结合可用于定义常量。文章通过具体示例详细解析了它们的用法和应用场景。
28 3
|
1月前
|
Java
Java面试题之cpu占用率100%,进行定位和解决
这篇文章介绍了如何定位和解决Java服务中CPU占用率过高的问题,包括使用top命令找到高CPU占用的进程和线程,以及使用jstack工具获取堆栈信息来确定问题代码位置的步骤。
97 0
Java面试题之cpu占用率100%,进行定位和解决