00:01
那么接下来我们了解第二个概念,Rpc endpoint。Andpoint翻译起来是什么?端点终端的意思对吧?啊,所以这个代表的就是一个RPC节点,一个RPC的终端。啊,它是一个通信终端,那么它里面主要提供的一些生命周期的管理,比如说这个终端是不是可以启停啊,就像你的手机是不是一个终端啊,你的手机是不是可以开机关机啊,对不对啊,就这么一个东西好了,那它里面呢,都对应的一个ID,还有一个艾系统啊。它的每一个路径都对应了一个。大家对它首先一个端点是不是有一个路径啊,那这个路径是不是有一个对吧?好,那么另外它也实现了一个网关接口啊网关接口。
01:01
那么这边呢,咱们就来看看这个类啊。CTRL加N啊,RPCN的point。呃,之后呢,我们看到它是一个抽象类对吧。它实现了网关的接口,好,那它里面主要有几个成员变量,我们了解了解啊,比较重要的啊,有一个叫service,有一个叫servicer啊,这个咱们呃下一个来介绍,咱们先引出一下这两个东西啊,另外呢,他我们刚才讲的它是不是有一个ID啊,对吧?啊这边有一个ID好了。那还有一个主线程的执行器啊,主线程执行器还有一个标志位,用来标识是否是运行中的,那就没了就没了,那你看它里面所有获取地址啊,获取节点ID啊,获取主机名获取。
02:00
那刚才演出的那两个,一个叫service,一个叫self getaway,其实这个就是server啊,咱们一会再讲啊。还有什么on star等等等等啊好,那咱们看看有哪一些。哎呀,点错了,实现了它啊,你看首先呢,咱们可以看到。是不是有一个task对吧,那我们还关注哪几个组件啊,是不是job manager里面的那三个呀,在哪里呀。在这里。因为他们是不是涉及到一个可能会用到高可用啊,呃,涉及到高可用他就会用这个啊,防止一个脑裂的问题啊。来,你看我点开。你看是不是有一个job master,还有一个resource manager。那有的同学说dispature在哪,在这个里面啊,它又封呃,又封装了一个里面呢,是不是一个dispatch。
03:04
所以总而言之,咱们关注的job master dispart resource manager,还有这四个是不是都继承了终端这个抽象内啊?说白了,这四个是不是就是对应的四个终端对吧,就像四部手机啊,互相之间要通信啊,就这么一回事啊。这个还是比较好理解的endpoint,那他们Spark里面是不是也有一个叫r PC endpoint啊。对吧,同样的道理,呃,因为都类似的,他们很类似啊,很类似。好,那么。呃,这边就讲到提供了一些方法对吧,可以调用RPC的标用啊,那么这边我们强调一点啊,标红的这一块在flink的设计里面,对于同一个终端来讲,它所有的调用怎么样。
04:04
都运行在主线程,为什么要强调这个,因为这样就不会有并发的问题,那比如说我同时被调用了,比如说四个四个方法同时要调用,那它是这四个方法都在主线程依次去调用的,而不是说我有四个同时执行,不会这样,那这样的话会乱套啊,怎么乱套啊,你想想你的手机能够同时同时开机和关机吗?是不可能啊,你要么就是开机,要么就是开完机再关机,对吧,你不可能我开机的同时还在关机吧,对不对,那有的同学说可以啊,我开机的时候把电池抠了,那是异常情况,好吧,那不叫关机啊,那叫出现了故障啊。好了,那这边其实它的构造器里面,咱们,呃,需要关注一个东西,这个是不是它的构造器啊,哎,那么有这么一行代码啊。
05:04
哎,这个这两个东西是不是刚才让大家眼熟的那两个呀,啊没错,这个呢,就是呃,咱们接下来要介绍到的。
我来说两句