00:00
好,那我们往后看flink里面怎么用这个演员系统啊,啊,这个act模型啊,啊,那你看这个是刚才那个概念对吧,包含状态和行为对吧,这个都提过了啊,然后顺序处理。啊,怎么样怎么样好。那么这一段呢,大家也不用看啊,就刚才都提过了啊,都提过了,那么我们这边主要怎么体现呢?是不是有三大部分,是不是有一个客户端一个。Job manager,一个task manager,他们三大分布式组件之间呢,是不是得有一个通信呢,对不对啊,那后面这一段话就是说他们通信的一些小细节,其实啊,昨天你还不如照着咱们提交流程,对吧,你看比如说。比如说。我圈起来这些箭头算不算通信呢?算吧,哎,像这种就是一种通信了啊,就这个意思啊,没了啊。
01:03
那么这一块呢,是比较老的一个图了啊啊,我也不是比较老,就是特定呃。啊,咱们看一看就行了啊,这是老大的啊,这是客户端,咱们先看客户端啊,客户端,客户端最终是不是提交到啊,当然这个是其他模式,它明显调用一个方法叫submit,就但是咱们per job模式,你是看不到这个方法的,其他模式都有好吧,哎。那么这边呢,他是提呃提交到一个老大节点,那么在这里其实人家提交给你,你是不是得回应一下就行,我知道了呀,对吧,你不可能你工作之后说跟老板汇报,哎,说老板我做完了,然后老板就看着你一一声不吭,那啥意思嘛,对吧,那老板至少说一句行你我知道了,呃你你呃一会把那个什么资料放这,或者把资料给我,对吧,至少会回一句吧,对吧?啊所以这是你就从一个人的角度来思考就行了,一些动作啊。
02:03
好,那这个老大呃,不管怎么处理怎么处理,最终是不是提交任务给小弟去执行啊是吧,哎,他执行了一个提交。那么小弟敢不回应吗?他敢不回应啊,想不想混了对不对,他是不是得回应他,呃呃收到对吧?呃,大家都喜欢的收到啊收到啊收到,然后是把自身保存的状态改变一下对吧,说开始执行某些任务对吧?啊,所以它叫update是不是更新任务状态啊啊。那么同样的一样的,一样的一样的啊,就这么一个过程。就介绍一下这个只是大概粗略的,呃,怎么来理解link里面怎么应用的这个艾系模型啊,那么还有一个小概念,异步跟同步。其实这个咱们是不是讲过了。什么叫异步啊?
03:04
哎,不需要回复的话,这个可不一定,同学们。相对来讲是不是我告诉你一声啊。比如说你正在,比如说啊,你跟你对象啊。你跟你对象,然后呢,你是不是在打游戏啊,正在打晋级赛对吧,忙得很啊,这个时候呢,你需要干另一件事,比如说那个点外卖。这个时候这是不是两件事啊?那你怎么处理啊?你是不是一边打着游戏一边跟你对象说赶紧点个外卖饿死了对吧?干嘛一天天的想什么玩意儿,不知道我在打晋级赛啊啊,想不想好好处了对不对啊,你是不是跟他说一声就完事了,你是不是接着打你的晋级赛啊?对吧,那之后你对象是不是啊脾气比较好对吧?他忍了对吧?啊,给你不断的织帽子对不对啊啊,他忍了啊,他等了之后,他是不是乖乖的去点呢?对吧?这就是一个异步的过程嘛,你打游戏跟执行点外卖这个动作是不是分开在在跑的,互不影响对吧?哎,只不过你一开始要通知他,那至于有没有回复取决于什么,取决于你女朋友要不要告呃,你对象要不要告诉你说我点好了,是不是我点了什么什么什么,他不告诉你也行,告诉你也行,对不对啊,大家按这么来理解就行了啊,那什么叫同步啊,同步就更好理解了啊,还是同样的例子啊,这个时候你是一个。
04:33
单身的单身的单身的动物对吧啊,单身贵族啊,结果呢,你是不是一个人吭哧吭哧打晋级赛啊?啊,然然后打着打着肚子饿的受不了了,眼睛都黑了对吧,这个时候你想点外卖,你是不是,呃,把游戏放在一边对吧?啊,然后你打开手机开始点外卖啊,这就是一个同步的过程的吧,都是由一个人来完成,有先后顺序,你不能同时执行,没办法,对吧?你可简单这么来理解啊啊那另外呢,咱们flink里面主要是什么异步,前面是不是也讲了阿卡的异步消息啊?
05:09
啊,一步好,那这边怎么体现呢,咱们还记得代码里面大量出现的一个词。Future。不知道大家还记不记得。呃,我随便一搜啊。你看这是不是有一个什么什么future啊,然后呢。你再再找是什么future是吧,你能找到一大坨啊,一大坨future,那这种东西是什么,就是J。JUC里面的内容啊,J UC Java里面的JUC,那么说白了,这个filter是用来干嘛呢。用来获取异步的响应,就像刚才那个例子,你让你对象点外卖的话啊,你跟他说了一声,然后呢,这个future就是你跟他之间联系的纽带,如果这个future可以干嘛呢?可以让他回应你。
06:11
获取它执行结果,就像你future调用的get方法,就相当于什么呢?你让他告诉他点完之后,过了五分钟,你又问他,你点了没有啊,然后他告诉你我点了,我点了,比如说呃,龙江猪脚饭是吧。深圳啊,广东特色对吧,广东快餐啊。是便宜的那种快餐啊,龙江猪脚饭啊,这个就是get对吧,通过这个future来get一下,就是让你回应我,告诉我结果这个就是一个future啊,咱们简单这么来理解。呃,那这边讲的是什么呢?那么大家想想,咱们获取响应是不是她不可能马上回应你啊,可能这个时候你女朋友在上厕所对吧?哎,你这个时她她这个时候不想理你对吧?那你总得有一个时间来限制吧。
07:06
对吧。我让我,我叫你告诉我,结果你过了一个小时还不回应我,那我是不是生气了对吧。那这就我们就有一个超时的时间啊,当然这边说了一大坨,为了防止失败啊,思索呀,或者组件直接挂掉啊等等,就说白了,为了防止一些异常现象,对吧,好。那么这边提到了,可以有一个阿卡的timeout来设置啊。那在后面呢,我们说两个演员进行通信之前呢,他是不是得。首先有一个对方的引用啊,对方的引用这个相信之前也提过,就是加了三个字母reference reference,它是通过这个引用去向他做联系啊,是吧,那他获取这个引用也有一个时间啊,查找的时间,这是另一个参数啊,就简单做一个了解,需要的时候你再翻过来看就行了啊。
08:04
那同样的阿卡可以限制消息的大小啊,消息的大小那么也有一个参数啊fra size,就是简单介绍一下啊这块。
我来说两句