温馨提示:文本由机器自动转译,部分词句存在误差,以视频为准
00:00
好,上节课啊,我们把这个数据leader和follow之间的数据同步已经做完了,那leader和follow之间的数据同步做完了,那大家思考的问题哈,那如果说这个节点它成为了leader,那他成为leader之后,那他到底要初始化干什么事呢?是不是这也是我们要思考的一个问题啊?啊好,那么来看一下啊,比如说这个他成为leader之后,他干了哪些事儿。那我们首先呢,就是进入到这个leader.java对吧?哎,然后下面呢,调的是这个力的方法,不陌生吧,啊,因为他当老大之后,它就会掉它掉它在这个方法里面,你会看到这个start JK server,比如说启动服务。然后在这里面进行各种set up启动。启动之后,然后你会调用一个setup这个。Request process。然后这个线程进行启动,启动之后就可以接收外来的对应的请求,然后对外来的各种请求进行相关的一个应答。
01:04
哎,你说你是下面哪一个请求,那我就有哪一样的对应的处理办法。相当于是啊,初始化完毕之后,就等待对方的一个请求处理。那我们看一看它是不是这样的呢。把这个截出来。那保存之后呢,下面我们来看一下代码啊,首先找到这个找谁呀?哎,找到这个leader对吧。Leader是不是在这儿呢?其他的关掉找到力之后,是不是找里面的力的方法。对吧,来找他。找到了吧,哎,力的方法往下找,之前我们找leader里面是不是找到哪了呢。找到的位置是往下看啊。大家看一下啊,回忆一下我们之前是不是找到这啊,创建了一个learner啊,然后cns accept啊放在这,那你从这往下找啊,往下找你说前面呢,准备好之后数据同步完了。
02:06
往下看。Start JK server,哎,这个是启动对应的服务,那看一下他干了什么事,启动,启动之后继续往下找,看这块JK start啊,继续启动。对吧,那找到这,然后再启动。OK吧,啊,到这到这这里面来到一个setup request。爱人说接收请求相关的一个处理初始化。进来进来之后这里面有一个啊,啊准备request process,哎,对请求相关的一个预处理,然后呢,它是一个什么,是一个线程是不是启动啊,那我们进来看一下。它是不是就是对它调用它对应的run方法就可以了,那它的run方法是不是在这呢。哎,在这在这这行,你看外务处一直等待接收。
03:01
接收别人对他的相关的请求,然后在这一块是不是来处理这个请求,你看。这个哎,处理请求,那看他处理什么请求呢,你打开一看啊,你这里的请求类型。有这么多。是吧?哎,不管你是哪种请求类型,我都有对应的处理办法。哎,这就是这个leader它启动之后要做的一些事情。了解一下。
我来说两句