00:00
好,那接下来呢,我们看一下我们整个的综合案例啊,第一个所谓的复制和都复用,刚才我们就提过了,先呢,我们得聊这个什么复制,而多路复用在哪呢?在我们这。啊,多罗夫用multiplaing这种模式啊,我们是给它放到了自定义的拦截器这个地方啊,因为它必须要在头部加一些信息啊,所以没有这个拦截器我们是做不了那个多路用的,没法做的好,那第一个我们看一下这个需求啊,呃,使用一,那这个时候要多多个了,对吧,因为我们说了要将。一个数据接收到之后,传接两个China对吧,两个China对应两个think,那我们呢,两个think呢,分别都是阿lo think对接两个agent啊,对接两个阿S啊,用这样的方式来做的好,那第一个呢,正好我们也测一下之前我们说的简单串联这个事嘛,对吧?啊没有简单串联的例子啊,在这块就有,那么接下来呢,第一个使用FROM1啊,就是第一个其中一个A去监控某一个文件的变化。
01:07
然后数咪呢,将变化的数据传给我们的分数二二是干什么事呢?传上传到SFS。啊,上传到rds,那么接下来同时F1还将变动数据传给FORM3 form3呢,输出到本地啊,它是不是当时我们看到think,除了d think,还有file think,对啊,本地文件系统啊也可以,那这里边呢,我们先来梳理一下里面所用的东西啊,你得想一想,第一个监控文件变动。我们可以用什么,这个是做测试对吧?啊,不用,不用非得考虑它的一个什么断点序这样等等功能,那么监动监监控这个文件的变动,那么我们可以用两个eecc,或者用tell电source对吧,这两种都可以啊,这两种都可以,然后接下来呢,他说将这个变化的数据传给FROM2啊China呢,我们还是统一的用memory China是吧?那这个东西想想看,哎,FROM1传给二,我们当时所聊的这一块,他的一个think得用什么,阿罗的一个对吧,阿罗的一个好,那接下来第二层他应该用阿波罗的S来接。
02:26
对吧,它们俩是一套啊,对接起来的,然后呢,China也用my China think就不用聊了,还是think对吧,写的是S,那同时还有第二层,就是说他还得将这个数据呢,传给F31份,那还是一样的用memory。再加一个传给F3下游还是的,所以还得加一个阿波罗的think对吧,然后F3呢,也是阿罗source my China,加上一个本地文件的一个S对吧?啊,本地文件的一个S,所以呢,我们来看一下它整个的数据流啊来。
03:05
那这里边我们没讲过的,等会呢,我们先去看一下,然后呢再拿过来用对吧。这是本地的数据,对吧?Have开启之后就会去更新这个日志,然后最终呢,我们希望将数据上传到HDFS1份,在本地文件也保存一份。对吧,就相当于互为备份关系嘛,就做这事两个地方都要好啊,完全是副本的好,那么接下来呢,我们就要写这个FORM1 form1,刚才我们聊了,我们可以用ERZS,也可以用S,对吧?然后两个memory China,两个阿罗think。啊,两个阿罗think对吧,好,那么第一个对接的up罗south China加I think,第二个对接的是阿罗s China加fair road think啊,就本地文件系统,它用的是这个think。
04:01
好之后呢,我们就要只要去开启整个的所有的任务就行了,而且大家注意啊,就是说这个所谓的阿夫罗之前我们所提到的,它是一个轻量级的RPC通信框架,对吧?其实我们现在所学的包括你哈多内部的通信啊,呃,或者其他的很多框架的内部通信都用的是RPC的一个通信框架,这种通信框架呢,是基于服务端跟客服端的一种通信模式。啊,就是说他得有服务端,有客户端,那你说这两个东西,就服务端跟客户端而言,先开谁啊,先开服务端对吧,先开服务端,那这个里面呢,所谓的这个up source里边是服务端。啊,就先开source,而且这边还有一个问题啊,就是说既然是服务端跟客户端这个问题,假如说F1F2F3。他不在同一台机器。
05:01
假如说它不在同一台机器,那么你这个阿波罗think阿波罗S啊,我们看到它是阿动框下,它是要一个端口啊,那个端口是写,假如说啊,这个在102,这个在103啊,就说这个,那这个端口说写102的还是写103的。零三的,为什么对,因为刚才我说了阿罗他是服务端。它是服务端,服务端注意啊,你在哪台机器上,你只能用的是这台机器上的端口。不可能说我在102上开一个那么no的这个服务,我用的是103那么一个端口,你觉得可能吗?不可能,但是可能情况是什么?我在102上开一个服务,但是用103来访问这个服务是不是可以远程访问对吧?所以这块注意配的应该是103的端口对吧?如果说这个机器不在同一台的话,那是这样子的,因为sources是服务端啊,这个要搞清楚的对吧?就是下去还是要总结的一个问题啊,就是说大家对于这个端口号的一个内容,对吧,到底哪个是服务端服务的一个端口号,还有我们通过网页看到的,网页看到的,假如说那个9870对吧,后续你还会学到很多很多内容框架,他都可以在网页上访问他的信息,这个呢是属于叫外端口,他就是给用户,给使用者来查看信息用的。
06:34
啊,你不要说在写API的时候写什么写类似于这样的东西了啊,只要是基基于这个RPC通讯框架的啊,外部服务端口呢,是你不需要去写什么东西的,对吧,它给你提供一个查询接口的参,而我们一般配的就是说你要访问的端口,那个端口呢,我们把它称为叫服务端,就类似于大家配的8020对吧,那弄的,那你想想看,你写SDF代码的时候。
07:03
首先是不是构建一个file system文件系统,对吧,这个文件系统里面传的一个URL。那就是要8010啊,服务端口就相当于在远程开了一个HD服务,对吧,在102上,103104开了一个集群,对吧?它这上面呢,有HD的服务,那我们可以从Windows或者说从其他机器,只要我能访问到机器,我就能够连到你的服务里面啊,所以说这个要搞清楚啊,因为最后一个案例呢,我们开始啊,这三个东西呢,都放在同一台机器啊,最后一个案例呢,我们会给它分开啊,会它分开,到时候你再去看一下啊,或者说你自己再测一下,哎,我把这个端口号写在另外一个地方,你看行不行。对吧,是这样的一个情况,行,这是我们所说的整个的一个流程啊,最后呢去开,然后呢,这块我们用的是relicating的一个拆的选择器啊,副本机制,其实副本机制的话,其实你可以不用配,就这句话可以不用写,因为默认的就是等会我们可以找一下官方配置啊,好,这是需求分析啊,然后接下来呢,我们去实现。
我来说两句