前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >hadoop 主备倒换控制器:ZKFailoverController详解

hadoop 主备倒换控制器:ZKFailoverController详解

原创
作者头像
zeekling
发布2024-09-22 23:50:34
790
发布2024-09-22 23:50:34
举报
文章被收录于专栏:浪浪山下那个村

简介

HDFS的NameNode、Yarn的ResourceManager都是依靠ZK实现主备倒换的。核心的类为:ZKFailoverController.java,

选举的核心类为ActiveStandbyElector.java

主备选举

主备选举的核心类是ActiveStandbyElector。在初始化的时候需要创建zk连接并且尝试在zk上面创建文件。在创建连接或者创建文件的时候都会有回调事件。

回调处理的函数主要包含:

创建node节点回调

入口函数如下:

代码语言:java
复制
public synchronized void processResult(int rc, String path, Object ctx,
      String name) {
// .....
}

处理流程图如下:

zk_failver_001
zk_failver_001

监控回调

入口函数如下:

代码语言:java
复制
public synchronized void processResult(int rc, String path, Object ctx,
      Stat stat) {
// ...
}

处理流程如下:

zk_failver_003
zk_failver_003

事件回调

入口函数如下:

代码语言:java
复制
synchronized void processWatchEvent(ZooKeeper zk, WatchedEvent event) {
 // ..
}
zk_failver_002
zk_failver_002

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 简介
    • 主备选举
      • 创建node节点回调
      • 监控回调
      • 事件回调
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档