00:00
好,接下来呢,我们来写一下客户端,在这个主题本集群上进行一个监听操作。对吧,来进行监听,那这个他是干什么事呢。那这个监听它是不是就监控这个serve下边节点的一个动态变化是不就OK了。哎,就干这件事情好,我们下面来看一下代码啊。呃,收完之后你去表的客户端拿回来。又一个累。那这个呢是没方法OK吧,那我这个客户端我要做哪几件事呢?对吧,啊思考一下。首先第一件事情是不是还是获取JK连接啊,也是得连上对应的主题本。那就是过去。这个链接。产生连接之后。下一步要干嘛?你俩之间已经可以进行通讯了。
01:00
对吧,那是不是我就要监听你这个节点路径上的变化,比如说这个serves下面,诶子节点的一个是否增加和删除。监听。服务器VS下面。节点。嗯,下面对指节点。的增加。和删除。对吧,按节点变化就OK了,然后下面最后一步呢,其实就是。对应的业务逻辑了。准确来说就是睡觉。OK吧,行,那下面我们一步一步来看,第一步啊是获取链接,那我们还是采用这种方式啊,创建自己的这个类。有。OK,拿到它之后我们起个名字。然后呢,获取连接client点。
02:01
那这里面get。OK吧?那需要啥你就创建啥。拿过来,拿过来之后这里面啊,那就又一个paper。仍然是三个对应的参数,对吧,Connect。使劲,然后下一个sessln啊CN。Time out。然后另一个毛球。这都是,呃,熟练操作啊。那这个给它起个名吧,仍然叫JK可以吧,好,第一个out加回车。在这儿首先你要想到的是它有什么注意事项啊,这要知道啊,这四项,然后就是hi豆1022181,逗号不要有后格对吧,拍DO1032181。再来嗨杜1042181,好吧,嗯,下面呢是三胎猫奥加回收。
03:06
2000搞定,然后呢,这个异常给他抛出去。然后这个JK啊。Out shift加F。啊,CTRL2C呃,Ctrl alt加F啊,就变成全局变量了。抛出异常对吧?哎,现在呢,就是建立好连接,那下一步呢,就是这个监听器的一个连接。那写呗,客户端点。Get。VE。Serve就是获取这个serve下面啊,那serve啊找一下。啊是这个对吧,哎,下面所有的节点的上限和下限,比如说增加或者减少。最后一杀就行了。放心。
04:00
好吧,那创建拿到这个JK客户端仓。第二,所谓的监听是不是就get children爱监控某一个路径,那我监控哪一个路径呢,我就监控。这个路径。三四。可以吧,哎监听啊,那这里面只要有节点变化,我是不是就得启动这个监听啊,那你有两种方式,一个是市政处处的话会走谁啊,会走你这个,哎,Get connect比说这块这个监听对吧?那如果说你这块要是new一个包车呢,是不是走的是你自己拗的这个包圈,那这里面我们用这个还是初始化的。能懂我意思吧,啊,你一打触的话,他走的是这个。角Y啊,就是那就获取到整个这个serve下面所有的节点,就是相当于这样。他就把这个节点下的。这些信息拿到了啊。他把这个异常啊抛一下。
05:00
二加货车对吧,哎,跑出去。这个呢也有。抛出去之后呢,下面我就得那得把这里面的值是不是得取出来呀,因为我要取什么呀,大家看一下啊。我现在呢,是拿到了这里面对应的节点。比如说children对吧,但是我需要取出的是这个每一个节点里面对应的值啊。因为在节点里面存储着对应的主题名称嘛,对吧,还有10110213。是这意思吧,那我说在循环便利这里面每一个节点,然后取出里面定的值。这一个啊。啊,怎么来操作。那就循环便利他呗。点啊这样去写啊就比较快对不对,哎,同学们拿到它之后,那下面我要怎么办呢。CK点。Get。来获取对应的数据,获取哪一个数据呢?这样写,S1VS斯下面。
06:06
然后我拼接上对应的这个。大家看一下我现在拼接的路径,是不是就相当于获取的是。这个节点或者是这个节点,或者是这个节点。对吧,哎,获取这个节点路径上的值。然后后面看看里面的值CTRL加t watch是否要监听,那这块就没有必要监听了吧,对吧,我不监听这里面值变化啊,因为上面这个呢是监听这个根目录下它的变化就可以了,那这个呢就没有必要,没有必要呢,就来一个false。那后面还有一个状态,那这个状态其实我们也不用看啊。不用看里面详细的这个信息,我们就想拿到对应的里面的值就可以了。OK吧,哎,返回的是这个date。那你现在在啊,每一个节点。是不是都会返回对应的一个一个的值啊,那我是不是希望把这些主机名称封装到一个集合里面,然后后续统一的往出打印呢?说哎,这个节点上,这个service下面一共有多少个节点上线。
07:10
到时候把这些值我需要封装到一个集合里。知道吧,那封装到一个集合,那你就需要一个集合呗,那需要啥你就来啥,又一个。On a release。对吧。行,那现在就来一个集合,那这个集合呢,就叫S1SERVE4。可以吧,哎,所有的服务器节点都在这里面,那在这里面我记得往里面添加呀。添加的话就是爱的呗。那我将这个值按了进去。那你这里面是字节啊,字节数组我需要的是一个。那给它放进去呗,啊,这就OK了。那你这里面未来存储的都是整个service下面对应的所有的主机名称知道吗?
08:02
那我是不是给他打印出来。那打印的话怎么打呀,So,然后serve。是不是这样就OK了,哎,就把整个里面所有的节点都打印出来了。啊,那这个打印完之后,那下面来看,那后面是不是该下一步操作了,哎,下一步操作呢,就是睡觉就睡觉啊客户端点。In。Al加回车创建方法。就一件事。right.sleep然后。浪点。好一场。对吧,哎,现在呢,整个代码呢,就已经写完了,难收啊。再捋一下逻辑,首先呢,你要连接上对应的主Q集群,连接上之后我要监听这个serve下面节点的增加或者删除啊get例子,那在这里面要干什么事儿呢?哎,就干这么一件事。
09:02
哎,你首先获取这里面啊监听啊,监听得到,那监听得到它是不是要走这里面啊,走这个,然后呢,这里面获取到对应的节点,那我就便利一下啊,这里面到底有多少个节点,然后取出对应节点里面的主机名称。对吧,哎,把这个主机名称取出来,取出来之后封装到一个集合里面,是为了方便打印。让大家思考的问题啊。我现在呢,是是不是只注册了一次监听,注册一次的话,是只生效一次。那我想让它一直生效,还记得我们之前写的案例,怎么样能一直生效?是不是就是你这边处罚完这个监注,注射监听之后,是不是你再处罚。是不是再来一次是不就OK了?哎,在调用啊在调用,然后二加灰色。这样才能保证他你。这个时刻监控一下啊,这个节点上的这个数据的变化,否则的话,他就监控一次就完事了。哎,就不会有第二次了。啊,这个地方要注意一下。
我来说两句