您当前的位置:首页 > 电脑百科 > 网络技术 > 网络知识

Curator客户端子节点监听机制源码分析

时间:2021-12-15 11:18:17  来源:  作者:程序员阿龙

一、demo

public static void main(String[] args) throws Exception {
        RetryPolicy retryPolicy = new ExponentialBackoffRetry(
                1000, 3);
        CuratorFramework client = CuratorFrameworkFactory.newClient(
                "localhost:2181",
                5000,
                3000,
                retryPolicy);
        client.start();

        PathChildrenCache pathChildrenCache = new PathChildrenCache(
                client, "/cluster", true);
        pathChildrenCache.start();

        // cache就是把zk里的数据缓存到了你的客户端里来
        // 你可以针对这个缓存的数据加监听器,去观察zk里的数据的变化

        pathChildrenCache.getListenable().addListener(new PathChildrenCacheListener() {

            public void childEvent(CuratorFramework curatorFramework, PathChildrenCacheEvent pathChildrenCacheEvent) throws Exception {

            }

        });
    }

我们来看一下这行代码,是如何创建的

PathChildrenCache pathChildrenCache = new PathChildrenCache(
                client, "/cluster", true);
Curator客户端子节点监听机制源码分析

 

/**

*@param client客户端

*@param-path要监视的路径

*@param cacheData如果为true,则除了stat之外还会缓存节点内容

*@param dataIsCompressed如果为true,则压缩路径中的数据

*@param executorService Closeable executorService用于PathChildrenCache的后台线程

*/
Curator客户端子节点监听机制源码分析

 

注释:启动缓存。缓存不会自动启动。您必须调用此方法。

说明调用start方法时默认不会缓存数据

Curator客户端子节点监听机制源码分析

 

默认走NORMAL分支,我们点进去看看

Curator客户端子节点监听机制源码分析

 

这里就启动了一个线程,将传递进来的Operation放入operationsQuantizer,如果放成功则启动一个线程,将Operation从operationsQuantizer删除,调用invoke方法,我们在返过去看一下这个Operation

Curator客户端子节点监听机制源码分析

 

这个里面invoke方法会去调用PathChildrenCache的refresh方法,我们在点击进去看一下

Curator客户端子节点监听机制源码分析

 

方法注释:

/**
*第一次,同步并确保创建路径中的所有节点。后续通话
*在这个例子中,是NOP。
*/

这个方法的是确保监听的目录在zk中已经存在了

Curator客户端子节点监听机制源码分析

 

这里会根据构造器的模式先获取出一个GetChildrenBuilder,在调用GetChildrenBuilder的usingWatcher方法将watcher监听器保存进去,在通过inBackground方法将刚刚创建的BackgroundCallback回调保存

Curator客户端子节点监听机制源码分析

 

实际逻辑则在forPath方法里面,这个因为是后台请求,我们直接看
processBackgroundOperation方法,这里的话会创建一个OperationAndData类,将自己作为operation传递进去

Curator客户端子节点监听机制源码分析

 

这里的话实际就是调用OperationAndData类的
callPerformBackgroundOperation方法,而这个方法其实就是调用刚刚传递进来的GetChildrenBuilderImpl的performBackgroundOperation方法

Curator客户端子节点监听机制源码分析

 


Curator客户端子节点监听机制源码分析

 


Curator客户端子节点监听机制源码分析

 

简要说明就是forPath方法会调用
performBackgroundOperation方法,这个方法会调用zk原生的api给他一个Watcher监听器,zk如果有子节点发生事件会通知原生的Watcher反过来调用我们注册的listener;

Curator客户端子节点监听机制源码分析

 



Tags:Curator   点击:()  评论:()
声明:本站部分内容及图片来自互联网,转载是出于传递更多信息之目的,内容观点仅代表作者本人,如有任何标注错误或版权侵犯请与我们联系(Email:2595517585@qq.com),我们将及时更正、删除,谢谢。
▌相关推荐
一、demopublic static void main(String[] args) throws Exception { RetryPolicy retryPolicy = new ExponentialBackoffRetry( 1000, 3);...【详细内容】
2021-12-15  Tags: Curator  点击:(20)  评论:(0)  加入收藏
▌简易百科推荐
HTTP 报文是在应用程序之间发送的数据块,这些数据块将通过以文本形式的元信息开头,用于 HTTP 协议交互。请求端(客户端)的 HTTP 报文叫做请求报文,响应端(服务器端)的叫做响应...【详细内容】
2021-12-27  程序员蛋蛋    Tags:HTTP 报文   点击:(0)  评论:(0)  加入收藏
一 网络概念:1.带宽: 标识网卡的最大传输速率,单位为 b/s,比如 1Gbps,10Gbps,相当于马路多宽2.吞吐量: 单位时间内传输数据量大小单位为 b/s 或 B/s ,吞吐量/带宽,就是网络的使用率...【详细内容】
2021-12-27  码农世界    Tags:网络   点击:(2)  评论:(0)  加入收藏
1.TCP/IP 网络模型有几层?分别有什么用? TCP/IP网络模型总共有五层 1.应用层:我们能接触到的就是应用层了,手机,电脑这些这些设备都属于应用层。 2.传输层:就是为应用层提供网络...【详细内容】
2021-12-22  憨猪哥08    Tags:TCP/IP   点击:(28)  评论:(0)  加入收藏
TCP握手的时候维护的队列 半连接队列(SYN队列) 全连接队列(accepted队列)半连接队列是什么?服务器收到客户端SYN数据包后,Linux内核会把该连接存储到半连接队列中,并响应SYN+ACK报...【详细内容】
2021-12-21  DifferentJava    Tags:TCP   点击:(9)  评论:(0)  加入收藏
你好,这里是科技前哨。 随着“元宇宙”概念的爆火,下一代互联网即将到来,也成了互联网前沿热议的话题,12月9日美国众议院的听证会上,共和党议员Patrick McHenry甚至宣称,要调整现...【详细内容】
2021-12-17  王煜全    Tags:Web3   点击:(14)  评论:(0)  加入收藏
一、demopublic static void main(String[] args) throws Exception { RetryPolicy retryPolicy = new ExponentialBackoffRetry( 1000, 3);...【详细内容】
2021-12-15  程序员阿龙    Tags:Curator   点击:(20)  评论:(0)  加入收藏
一、计算机网络概述 1.1 计算机网络的分类按照网络的作用范围:广域网(WAN)、城域网(MAN)、局域网(LAN);按照网络使用者:公用网络、专用网络。1.2 计算机网络的层次结构 TCP/IP四层模...【详细内容】
2021-12-14  一口Linux    Tags:网络知识   点击:(30)  评论:(0)  加入收藏
无论是在外面还是在家里,许多人都习惯了用手机连接 WiFi 进行上网。不知道大家有没有遇到过这样一种情况, 明明已经显示成功连接 WiFi,却仍然提示“网络不可用”或“不可上网”...【详细内容】
2021-12-14  UGREEN绿联    Tags:WiFi   点击:(25)  评论:(0)  加入收藏
拉了千兆宽带,买了标称 1300Mbps 的无线路由器,为什么 WiFi 还是跑不满千兆?要回答这个问题,我们先得知道这个 1300Mbps 是怎么来的。开始回答之前先说明一下,这期只讲 802.11ac,...【详细内容】
2021-12-14  Ubiquiti优倍快    Tags:WiFi   点击:(83)  评论:(0)  加入收藏
问题背景IPv6环境下,在浏览器中通过http://[vip:port]访问web业务,提示无法访问此网站,[vip]的响应时间过长。分析过程之前碰到过多次在PC浏览器上无法访问vip的情况,排查方法也...【详细内容】
2021-12-13  云原生知识星球    Tags:网络问题   点击:(27)  评论:(0)  加入收藏
相关文章
    无相关信息
最新更新
栏目热门
栏目头条