00:00
分钟啊,那么接下来我们要关注整个flink的RPC。也就是说flink它这个RPC具体是怎么实现的呀,对吧?啊,RPC我们说的是一个统称吧,啊,是一种远程调用啊,远程调用叫RPC好吧,所以一般呢,我们呃,说到原理的时候,我们知道基于R卡,接下来我们要就要介绍它的RPC过程是怎么样的啊,就是具体结合flink来讲的,对吧,远程调用那这一块首先给介绍几个flink封装的东西,大家注意这些东西是flink自己封装的一些组件啊,用来RPC通信的一些组件,那么。这中间有,呃,我们一个个看,先看第一个rpc getway。Getaway什么意思啊?网关,网关里面会定义一些通信的行为。呃,什么叫网关呢?其实呃,如果以前呃大家做一些开发,比如说Java也好,前端也好,呃应该对网关概念不陌生啊,我比如说啊,这个是job manager,呃,这个是呃task manager。
01:17
那么他们能够直接通信吗?啊,并不是,他们应该咋通信呢?应该是通过一个叫getway的东西。那比如说老大要向小弟发送命令,他是先发送到一个网关。那么接下来这个网关再去向小弟通知,是不是转了一手啊?对吧,这个是一个叫网关,其实网关这个概念,大家电脑上是不是也有一个网关啊,啊,其实是差不多意思的,你从互联网接收消息也是先进入你的网关的,之后再转发到你本台电脑。啊,就这么一个转发的作用,大家知道啊,转发作用,那所以这里面是不是应该定义一些可以做的事儿啊,比如说我叫小地哭,那这个网关里面是不是有小弟哭的方法呀的调用啊,我让小弟笑,他是不是有一个笑的方法对吧?呃,让小弟吃,他是不是应该有一个吃的方法,然后调用网关里对应的方法,他才去告诉他执行什么是不是。
02:17
啊,来,我们来具体的瞅一眼啊。呃。我们看一个看一个谁啊。Task getway啊啊,比如说你看这个是谁的网冠。是不是task is的网关了,你看啊,CTRL这是一个接口对吧,CTRL加F12。是不是一坨方法呀,你看这些方法是什么,提交任务还有什么请求,Slot还有什么,还有各种请求对吧,还有释放,各种释放,还有心跳,你看网关里面是不是有一些动作。
03:01
一些方法呀,这些方法就是用来告诉对方要做什么事,对吧,所以我刚才讲了,网关里面会定义一些行为啊,定义一些行为。好,再问一个问题。这个网关是要告诉谁呢?这是task的网关,那么这个网关的动作是来告诉谁的?就是他。就是来告诉task可以cut,那就别人要告诉task,可他要通过这个网关去告诉他啊,就这么一个关系,好吧,啊,那么大家理解理解啊,什么叫定义了一些通信的行为。用于远程调用。Rpc and Bo的某些方法可以。是不是调用对方的某些方法呀,对吧,那这个是什么呢?这是一个通信端点啊,通讯端点终端,一个终端吧,对于咱们来讲相当于是什么一个客户端或者一个。
04:04
转发器,一个resource manager或者一个task,就一个组件吧,好吧,一个组件就对应一个端点。嗯。可以理解为对方的代理是不是?就像你要跟他交流,你是不是通过他的代理跟他交流啊,就像一些某些某些人,你要找他,你是不是只能找他的秘书啊。你想直接找到他,人家不鸟你对不对啊,你只能通过他的助理秘书,然后通过这个助理秘书再去跟他做一个,呃,协调沟通对吧,那这个就是一个网关。好。那么我们再了解一下啊,了解一个东西,咱们哪些东西实现的网关呢?来这个是我截的一个图啊,通过咱们ID是可以,呃,可以这么写这么弄的,怎么弄呢?嗯,比如说呃,Rpc getway这个是最底层的这个网关接口,对吧,然后我按住CTRL加H,它是不是一大坨呀。
05:02
好,右键。啊,顺便给大家讲讲怎么用。这个最后一个。最后一个。这里是不是有个塑形图,一个层级结构的图标啊,然后再点受,那下面这个是。弹窗啊,这个上面是不弹窗,不弹窗就是在idea里面,你看在里面,然后呢,它这里是不是到这啊右键你看主要是这两个。这个是不是展示它的实现呢?下面是不是找它的附类啊,对吧,比如说我点一个找实现,你选,呃,比如说我找一个dispature getway,然后就出来了,当然我是可以选中它,再接着展示其他的实现了。啊,比如说叫皇马子的给的,我就是这么点出来的啊好,我就不再继续点了,直接开文档啊。首先这个网关接口,你看看有哪些东西实现了网关接口。这三个是谁呢?是不是job manager里面的三个组件是不是都有网关接口啊,因为他们是可能涉及到跟别人交互通信,对不对啊,所以他们肯定都实现了网关接口,还有task也实现了网关接口,那么这中间多了一种类型呢?这种是,呃。
06:20
高可用的时候要用这种。这这个词翻译起来是围栏,围墙的意思,呃,那么大家就知道他们,呃有有一定的需求吧,高可用需求,我们是不是这几个组件启动的时候都是一个leader选举的服务来起的呀。啊,这个大家知道就行了,反正大家要记住就是是不是这四个东西都实现了网关接口啊,啊,每一个小组件都对应了一个网关,都有各自的网关啊,这个就是咱们要对网关的一个理解啊。
我来说两句