zookeepe - 写数据 - cluster(7)

本文涉及的产品
任务调度 XXL-JOB 版免费试用,400 元额度,开发版规格
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
云原生网关 MSE Higress,422元/月
简介: 概述    本文的主要目的是分析zookeeper的整个数据写入过程,相信大家或多或少都听说过zookeeper是一个集中式的单点写入过程,所有的写入请求都会转发到Leader来完成数据的写入过程,而且在整个写入过程当中会涉及到二次提交(proposal/commit)过程,希望通过这篇文章能够帮助感兴趣的人建立一个整体的流程印象。

概述

    本文的主要目的是分析zookeeper的整个数据写入过程,相信大家或多或少都听说过zookeeper是一个集中式的单点写入过程,所有的写入请求都会转发到Leader来完成数据的写入过程,而且在整个写入过程当中会涉及到二次提交(proposal/commit)过程,希望通过这篇文章能够帮助感兴趣的人建立一个整体的流程印象。

    延伸阅读关于Paxos的协议可以阅读延伸的文章《拜占庭将军问题》,其实zookeeper的二阶段提交就是这个模型的实现,公式证明看不懂但是思路可以看得懂。

    最后整个文章读起来比较费力,如果有兴趣真正搞懂整个写入过程,还是需要抽出一整块时间来阅读的,我本人这篇文章从理清楚过程到画图大概花了一个星期左右,这还是建议阅读别人的文章的基础上的,参考文章中列出的几篇文章还是非常不错的,可以相互补充着来看,因为整个过程涉及的代码太多了,所以就建议大家看参考文献中的文章吧,虽然有一些小出入但是整体来说是非常全面的。

    zookeeper中涉及的事务操作主要包括下面几大类:

        1)写操作(OpCode.create,OpCode.delete,OpCode.setData,OpCode.setACL)

        2)Session的创建和关闭操作(OpCode.createSession和OpCode.closeSession)

        3)OpCode.multi操作。


过程分析

    在正式进入过程分析之前,先得有一个宏观的印象,那就是zookeeper的写入过程当中,当我们连接的是Follower的对象的时候,写入会转发到Leader,最后由Leader完成写入并同步到所有Follower当中,Follower是不具备处理数据写入功能,Follower其实只是对写入的一个转发而已,从下面这个图片就可以看明白了。


img_b45b72900f9cb981de6dd18b753daee1.png
数据写入过程


    另外,在zookeeper的FollowerZookeeperServer和LeaderZookeeperServer当中,都有一个调用链的概念,在接收报文后会通过调用链进行处理后回送报文,其中leader端和Follower端的调用链是有区别的,具体差别就是下图的样子。

img_e4620e28a2c0b2cc36d33745a7d20669.png
Leader调用链
img_3d6595fa6abb3b824c450b5467100302.png
Follower调用链


    在整个交互过程中比较核心的两类报文,Request对象是调用链处理过程中传输的对象,QuoromPacket是follower和leader交互过程涉及的报文。

img_5f9c12ca5faae2a84e551a1fd137c9ca.png
Request报文


img_4ab49ee360b04322263dd2bf6bbae6d5.png
QuorumPacket报文


整个核心的数据写入过程都在下面这个图当中,核心的关注点要关注几个角色之间交互报文以及两阶段提交过程。

img_b56b6aaf8b2b5df5883a7c67e5a90ba1.png
zookeeper写入过程

下面过程分析的数字编号不是对应上图当中的编号,而是宏观上按顺序把整个过程进行分解,当然每个过程都是可以在上图中找到对应的连接线的(源码层面可以看ZooKeeper源码分析:Quorum请求的整个流程)。

    1、client向follower发送packet报文,然后进入follower的消息处理链当中,也就是FollowerRequestProcessor当中。


    2、Follower的处理过程:FollowerRequestProcessor做两个事情:负责沿着调用链处理也就是执行CommitProcessor当中,在这个时候follower的处理就暂时停留在了CommitProcessor当中;负责将报文通过follower.request()发送到leader当中,此时报文的type为Leader.REQUEST


    3、Leader的处理过程:Leader端由LearnerHandler(负责和follower建立的连接)进行处理,核心处理逻辑其实就两个:逻辑一依次通过调用链PrepRequestProcessor -> ProposalRequestProcessor->SyncRequestProcessor(CommitProcessor),其中CommitProcessor其实处理到一半没有继续往下执行;逻辑二是PrepRequestProcessor -> ProposalRequestProcessor->发送Leader.PROPOSAL报文给Follower。


    4、Follower的处理过程:Follower在接收到Leader的Proposal报文以后,通过调用链SyncRequestsProcessor->SendAckRequestProcessor发送Leader.ACK报文给Leader。


    5、Leader的处理过程:Leader在收到Follower的ack报文以后,会判断是否超过半数已经回复了相应报文,也就是对应的tryToCommit的处理逻辑,里面其实就是判断是否超过半数的follower回复了,如果超过半数回复了那么就进入了第二个阶段(Commit/Inform)阶段发送给Follower,当然leader本身会在之前的CommitProcessor当中继续操作(也就是在步骤3当中执行到一半的过程),沿着调用调用CommitProcessor->ToBeAppliedRequestProcessor->FinalRequestProcessor完成数据的写入。


    6、Follower收到Leader.COMMIT/INFORM报文之后开始进行数据的持久化,并将响应报文发送给client,整个过程就结束了。


参考文章

    ZooKeeper学习之server端实现的基本骨架

    ZooKeeper源码分析:Quorum请求的整个流程

    ZooKeeper 核心模块代码浅析

相关实践学习
基于MSE实现微服务的全链路灰度
通过本场景的实验操作,您将了解并实现在线业务的微服务全链路灰度能力。
目录
相关文章
|
6月前
|
存储 NoSQL 算法
深入理解Redis分片Cluster原理
本文深入探讨了Redis Cluster的分片原理,作为Redis官方提供的高可用性和高性能解决方案,Redis Cluster通过数据分片和横向扩展能力,有效降低单个主节点的压力。
深入理解Redis分片Cluster原理
|
9月前
|
存储 NoSQL Redis
redis集群cluster
redis集群cluster
69 0
|
SQL 前端开发 数据库
解决读写分离主从数据库之间数据不同步的问题 Slave_SQL_Running: No slave_io_running:no
解决读写分离主从数据库之间数据不同步的问题 Slave_SQL_Running: No slave_io_running:no
202 0
|
存储 移动开发 数据库
无主复制系统(2)-读写quorum
图-10中,三副本若有两个以上完成处理,写即可认为成功了。若三副本中只有一个完成写入,会怎样?到底几个副本完成才能认为写成功?
165 0
|
存储 NoSQL 分布式数据库
Kudu 架构(master\tablet server) | 学习笔记
快速学习 Kudu 架构(master\tablet server)
545 0
Kudu 架构(master\tablet server) | 学习笔记
|
NoSQL 算法 分布式数据库
Redis Cluster 数据分片
Redis 集群是 Redis 提供的分布式数据库方案, 集群通过分片(sharding) 来进行数据共享, 并提供复制和故障转移功能。
250 0
Redis Cluster 数据分片
解决elasticsearch集群分片lock锁无法分配
elasticsearch分片lock锁无法分配 报错内容如下所示 出现这个问题的原因是原有分片未正常关闭或者清理,所以当分片要重新分配回出问题节点时就会没办法获取分片锁,这不会导致数据丢失,只需要重新出发一下分配分片的操作即可
220 0
解决elasticsearch集群分片lock锁无法分配
解决elasticsearch集群分片lock锁无法分配问题
elasticsearch分片lock锁无法分配 报错内容如下所示 出现这个问题的原因是原有分片未正常关闭或者清理,所以当分片要重新分配回出问题节点时就会没办法获取分片锁,这不会导致数据丢失,只需要重新出发一下分配分片的操作即可
407 0
解决elasticsearch集群分片lock锁无法分配问题
ZooKeeper写数据流程
只有Leader才能处理写数据请求,Follower接受写数据请求要转发给Leader;半数以上的节点写数据完成,即写入数据成功。
241 0
ZooKeeper写数据流程

热门文章

最新文章