ZooKeeper源码解析(3)-Cluster启动过程解析

ZooKeeper启动时,有两种模式,第一种是单例模式,这也是默认模式,第二种是cluster模式.今天我们就来探究Cluster模式下,ZooKeeper模式是如何启动的.

启动过程

Cluster模式下的入口为org.apache.zookeeper.server.quorum

那么,Cluster模式下,节点是如何一步步启动起来的呢?

从上面的这幅图片中,我们可以看到,就是调用的QuorumPeerMaininitializeAndRun方法.

我们看一下这个方法的实现.

这里也很容易理解,就是做了这么几件事:

  • 解析配置文件
  • 启动一个定时器来清理旧数据并且生成快照
  • 如果配置文件中并没有指定server,那么就以单例模式启动

如果配置文件没有错误,就调用runFromConfig()方法.

在这个方法中,会创建一个ServerCnxnFactory类的子类的实例,默认是NIOServerCnxnFactory,用于创建NIOServerCnxnNIOServerCnxnServerCnxn的一个子类,ServerCnxn代表客户端和服务器端之间的一个连接.

在创建完NIOServerCnxnFactory并配置完之后,会实例化一个QuorumPeer实例.QuorumPeer内部封装了Leader选举等Zab一致性算法中的内容.

QuorumPeerstart()方法中,主要做了这么几件事:

  • 通过快照以及事务日志恢复这个节点在宕机之前的状态(loadDataBase()方法)
  • 启动上面创建的NIOServerCnxnFactory
  • 进行Leader选举

那么,通过快照以及事务日志恢复这个节点宕机之前的状态,是如何做的呢?

具体是这么几步:

  • 加载SnapShot并且构建DataTree
  • 加载Transaction Log
  • 将Transaction Log应用到Data Tree
  • 提交Transaction Log并且把它们添加到commited log
  • 更新latest zxid

当加载SnapShot以及Transaction Log时,就涉及到了SnapShot以及Transaction Log的格式.

关于它们的格式,请参考本系列中的另外两篇文章:

ZooKeeper源码解析(4)-TxnLog文件格式

ZooKeeper源码解析(5)-Snapshot文件的格式

这部分的代码本身也是比较简单的,这里就不深入介绍了.

由于QuorumPeer本身也是一个线程,我们从其run()方法中可以看到,它就是启动了一个死循环,不断检测这个节点的状态,然后根据不同的状态来做不同的事情,这个在后面的文章ZooKeeper源码解析(6)-Zab实现解析中有介绍,这里就不详细说了.

需要注意的是,我们可以看到,如果当前节点处于LOOKING状态,那么会检测一下是否当前节点已经宕机,如果已经宕机了,那么就可以启动一个ReadOnlyZooKeeperServer.这个对于CAP的权衡.

如果当前节点处于LEADING状态,那么会在完成了确定了自己Leader的地位后,就启动一个ZooKeeperServerZooKeeperServer中就是一个节点,其中维护了各种数据,比如,和客户端之间连接的Session.

如果你是刚开始读源码,那么可能会对ServerCnxnFactory,ZooKeeperServer,QuorumPeer之间的关系不清楚.

它们之间的关系如下:

调用的时序图如下:

其中ServerCnxnFactory的继承关系如下:

ServerCnxn的继承关系如下:

ZooKeeperServer的继承关系如下:

每个类图中,我都只是列出了少量属性和方法.

总结

总的来说,在启动时,主要是做这么几件事:

  • 解析配置文件
  • 根据Snapshot和transaction log在内存中构建出数据和元数据
  • 创建ServerCnxnFactory
  • 启动Leader选举过程
  • 根据选举结果切换到相应的状态并进行相应的操作
  • 启动一个ZooKeeperServer来接收客户端操作
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 202,980评论 5 476
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,178评论 2 380
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 149,868评论 0 336
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,498评论 1 273
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,492评论 5 364
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,521评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,910评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,569评论 0 256
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,793评论 1 296
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,559评论 2 319
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,639评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,342评论 4 318
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,931评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,904评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,144评论 1 259
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 42,833评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,350评论 2 342

推荐阅读更多精彩内容