浪浪山下那个村 👋🏼

简介 HDFS的NameNode、Yarn的ResourceManager都是依靠ZK实现主备倒换的。核心的类为：ZKFailoverController.java, 选举的核心类为ActiveStandbyElector.java 主备选举 主备选举的核心类是ActiveStandbyElector。在初始化的时候需要创建zk连接并且尝试在zk上面创建文件。在创建连接或者创建文件的时候都会有回调事件。 回调处理的函数主要包含： 创建node节点回调 入口函数如下： public synchronized void processResult(int rc, String path, Object ctx, String name) { // ..... } 处理流程图如下： 监控回调 入口函数如下： public synchronized void processResult(int rc, String path, Object ctx, Stat stat) { // ... } 处理流程如下： 事件回调 入口函数如下： synchronized void process....

客户端认证 客户端的入口函数为 KerberosAuthenticator.authenticate函数 连接HTTP服务端 HttpURLConnection conn = token.openConnection(url, connConfigurator); conn.setRequestMethod(AUTH_HTTP_METHOD); conn.connect(); SPNEGO认证 对于普通的HTTP的kerberos认证(SPNEGO)，需要现在客户端登录KDC服务。核心代码在函数doSpnegoSequence里面。 首先需要登录KDC服务端： subject = new Subject(); LoginContext login = new LoginContext("", subject, null, new KerberosConfiguration()); // 登录KDC服务 login.login(); 下面主要是开始认证的时候的逻辑。核心处理逻辑流程图如下： 主要代码逻辑如下。 GSSManager gssManager = GSSManager.g....