22_尚硅谷_Flume高级_Channel选择器副本机制（配置文件）

那需求分析完了，我们应该是具体的要去写什么。配置文件了，对吧？啊配置文件了，那这里面是不是有三个配置文件，For me form2 form3，那这个时候你要注意了，假如说你在这个102都配在102可以，那你这个A店的名字就干什么起不一样的吧，啊不能起一样的了，好，那我们CB。到OB Mo from里边，还是到这个job job底下了啊，因为它这三个东西是不是一个组啊，我直接干什么呢？Make，第一个入口一可以了，因为下面还有GROUP2也是组的案例边还有三组案例，所以呢做一个区分啊，CD到这个group里边啊，Group里边啊在这呢，我直接touch一个啊，因为这个内容比较多啊，我直接要form a点。然后它是一个什么from2.com，然后再touch一个from3.ok吧，啊就这三个内容，然后可以退出来，然后呢，我们去改内容，还是在这个上面去改啊在这上面改OK，我们先把这个几个文件呢给它打开，把这个关掉。

点这个。这个叫底下对吧，一，然后FROM1I这个哎是个空文键吗？没问题啊，然后FROM2。大概三应该大概。啊，A的打开，那这里边呢，我们取名叫什么A1对吧，这个取名呢叫A2，我们先定一下这个叫A3啊A3当然呢，因为你最后启动的时候是不是会用到这个配置文件和这个名字，所以呢，你不要这样，A2里面就是分二里面放A3，结果你很容易自己就付款了，对吧，这样就更方便一点，更方便点好呃，那接下来在写这个配置文件之前，我们是不是要搞定我们所说的三个没见过的东西。阿罗。阿罗以及。对吧，本地文件系统的，那我们应该看一下1.7的一个用户指南，先是AV。

A的一个什么。啊，找到还是同样找到那个什么大标题，诶，它这个东西呢，比较少一点啊来看。阿波罗，我之前说过，它是一个RPC的一个通讯框架，也是，它也是什么呢？通过这个端口来传输数据的。啊，通过端口来说数据的，OK，那你看一下这个东西。对，有同学说了，跟那K差不多对吧？啊，跟那cat差不多，但是呢，他不能说你从那cat里边传一个数据过来不行，他得那边也是一个什么RBC的一个服务能听懂啊，两边要对接上，不是说你用那CA来对接这个阿芙罗，这个不行啊，这个游戏OK，那他要绑定一个什么。绑定一个这个是host name或者IP地址去接听的一个IP地址，对吧？然后还有绑定的端口号，因为它通过网络传输的，你想想看，之前所有网络传输的内容是不是IP加端口号，你不记了很多端口号吗？我们说了那个端口号都是用来什么通信的，对吧？那通信不就传输数据用的嘛，对吧？啊，传输数据用的OK，那主要的核心的不就他吗？

那我们就把它背一下，你看一下官方案例是吧，这个地方。啊，好，我们把它拿过来。拿到这吧，啊把这个拿一下吧。RC。诶，A1对吧，A1S这个前面是不是我们所说的定义啊，然后还差一个是吧，A1.s等于K1。对吧，其实我们知道，按照我们之前的需求，第一层里边读一个数据之后要传给C2和。P2，对吧，啊，你要配两个了，因为这边不是写了S嘛，对吧？啊可以配多个啊中间呢，用空格给它隔开啊，空格给它隔开，OK，那第一个类型China绑定，我们给它扔到什么。

最后面去吧，哎扔到最后面去，OK，绑定地址我写一个啊杜102，我们都放在102了，那4141就4141，因为这个端口呢，也没人用啊啊卡四做一个保存，这个呢，是我们关于这个什么。Source对吧，假如说加一个注释吧，啊井号注释对吧，这个呢是命名name命名这个呢S对吧，那接下来这个东西搞定了。这个搞定了，那接下来写什么？China啊China，那直接用什么。我随便从之前的一个东西拿一下可以吧，啊，随便找一个，因为之前我们用的都是什么。

慢慢China，哎，China给他拿过来。CRC啊，这个呢，放在前面啊，放在这China对吧，那这个L我们要改一下吧，这个呢，做一个注释，这个是。看到看到C有吧，然后再把它干什么，复制一份对吧，啊复制一份这个地方呢，改成C对吧。这个改成A1对吧，啊改成A1，好，这个C2就不用改了吧，对吧，因为我们写了有一个C1有个C2啊，有个C1有个C2好，接下来写什么，这里面single是。是不是阿弗罗格，因为他要对接FROM2跟三的，那我们来搜一下这个什么阿罗的一个S对吧，阿罗S你看一下。

一样的，哎，这个地方太饱，好那破的，注意你不要想着一样的直接，有的同学一看兴奋了，把这个拿过来一站，把这个改成什么，这个改成了可对吧，把这个改成。把这个改成K，把这个改成K，注意他其实有一点不一样。这个叫什么？How's the name。上面叫什么半啊，上面叫半是这意思啊，这要注意一下，要么他再来一什么。再来一份，这个呢，我们把它发到什么142端口，这个是K2，哎，我们这个文件里边有个东西写错了对吧，S写错了，S这个东西不能放在这吧。这个东西我们是不是占到位置了。这个银牌放到这儿，放到这儿吧。

对吧，啊，这个地方应该我们聊的当时说的是ECC或者TDR吧。对吧，因为是第一个source呢，读本地文件，然后传到第二层第三层对吧，因为刚才我们看到这个内容，所以呢，我们应该把它给它X给它扔出去了啊，这个地方S放在这，那这个就不叫A1了，叫什么L2吧啊L啊等会整体的呢，我们再回顾一下啊回顾一下好，那这个S是不简单。直接从。这貂。啊，不要这个，我找一个什么太吧。呃，跳文件。If。嗯，我看一下这个点开。哎，这个是EC是吧，嗯，其实E也行，对吧？啊无所谓，然后我们找一下我们之前写的是菲斯对吧，多个文件的啊，多个文件那它吧，那它更好一点。他说C给他拿过来，是不是放在这个地方叫A1没问题吧，R1没问题，Table tell点这个地方，还有group是不是我们只要一个就行了，对吧，你不需要两个了，监控的文件。

我们是不是准备监控have那个have log，对吧？按照我们文档当中的需求来啊，Have底下有个log，底下有个什么have.log。OK吧，他好这个呢，呃，就不要用之前的那个文件了吧，假如说改个名字叫什么1OK吧，啊最好改个名字，就是说不同的一个配置文件呢，用不同的名字啊，用不同名字啊，那我们梳理一下第一部分，第一。这个有问题吗？没问题吧，第二个关于这个有问题吧，OK吧，你就要看一下这里边有没有东西错啊，也帮我再看一下这个东西应该OK吧，监控的是这个数据对吧？啊监控的这个数据好，那接下来。那有个问题啊，就是这个汉点log，我还这块还真不太想用，因为等会最后会给我们最后的测试带来一点困难，因为最后我们现在是不是测复制啊。

复制的话，两个数据要一样吧。对吧，但是你要见过have.log然后这个没有，他把整个have.log全部加载过来了。这个数据量有点大就不好对。能听明白吗？对吧，那我们改一下吧，因为经过哪个数据无所谓，对吧，改一下啊改一下叫data，它里边我们来一个呃，have.log我们自己来建一个那个have.log OK吧，然后自己往那个A数据，这样最后我们好比对两个是否是复制关系吧，OK吧，啊做一个临时调整，因为你这个用T电压的话，它是不是把have.log全部给它加载过来了。因为当前position有数据吗？没有，没有的话它是从哪。他要大家从头读啊，因为没有他得从头读，那数据太多了，不利于我们比对吧，那我们自己来一个这个数据，等会呢，我们自己往里边追加数据，这样方便比对，能听懂OK吧，啊做了这个改变啊，做了一个改变啊，两个memory channel。

没问题吧，好，然后是。阿波罗的什么sing，阿波罗name，一个发到CC，一个发到什么C2K12，好，我们还差一个内容，就最后的什么。办的对吧，啊最后呢，有一个办绑定绑定的还差谁呀，这个地方应该加一个。C对不对。这是谁？说是不要跟两个东西毛利的。对吧，有有问题吗。没问题吧，好，那接下来应该有一个A一点，把这个东西复制一下，对吧，我们自己写A点什么K一点，注意这个地方是什么China有S吗？没有要绑定什么C1啊，尽量加个空格，好把它复制一份吗。

这个地方改成二，这个地方改成啊。没问题吧，啊，那这样一绑定是不是就是我们所说的，哎，这个地方有一个。A点，哦，对，这个是。上面这个地方也错了，对吧。因为这一块是我们刚才直接摘下来，只改了host name对吧。还记得吗？当时我不是说有同学。认为诶跟上面一样，直接给他拿下来了嘛，对吧，当时我不是说这个host name不一样嘛，然后把这个做什么替换，对吧，只做了这个替换，所以这块应该是一个什么think啊think，然后底下绑定的也是这个think吧，啊也是这个OK保存，那也就第一个这个我们就已经干什么。

搞定了。这已经搞定了，好，接下来来配置第二个。被了同样的加一个什么。那命名。啊，命名命名，我直接把这个拿过来对吧，改一改啊。这个地方全部改成L。对吧，L好，R是不是要。注意，那有同学说你A2这个东西不能一样，但是我这个R1，你这里面不有R1了吗？我这能不能用R1可以，这个A2相当于内容我们所定义的全局变量，但是这个是不是当前A的里面定义的变量。对吧，它就相当于是局部变量，局部变量两个方法里边，我用同一个命名，可不可以可以吧，能听懂这个意思啊这个。这个里面有多个吗？没有就I1C1吧，好，那这块第一个。

你所说的叫？S应该是阿波罗的S。对吧，是半没问题吧，好C1C1好二呢，我们对接CC1端口，呃，接下来是我们所要的。China。真的直接从这个地方拿一个吧，啊，就把这个A1的这个东西拿过来，然后把这个ae改成什么。L。所也要改成对吧。这个改一下啊，其实我们刚才应该粘这个是吧，啊粘这个更好一点，就改的少一点，好China也搞定了，接下来是我们要的。Single这个第一个single，我们按照文档当中传到哪啊。还是所以呢，我们去拿一下。HDFS的一个C，直接把它干什么，拿过来OK吧，好，直接把它拿过来，在二里边拿过来好，嗯，这个目录呢，我们加一个这个呢，我们加一个这个。

是不是组一里边的，那我放在组一里面做一个区分，OK吧，啊这个名字呢，随便改一下，其他的呢，什么滚动嘛，这些东西我就不改了，没问题吧？A2看一下没问题吧，这个地方是不是要改一下。对吧。还不能做全局替换还可以，CTRLH我直接替换的是什么K2给他替换成K1对吧？啊，可一做一个替换好，那这个就都改过来了啊，这个就方便一点好哎，没问题吧，检查一下你时刻要关注这种名字，好好，那这个S搞定了，接下来写什么。办的这个办的就简单了吧，我直接可以干什么，从这个地方拿来。全部改成什么一是不是就够了。没问题吧，啊，最后这个笨就简单了，因为它是一一对应的关系，大家对吧？啊，一一对应的关系，好这个东西检查一下有没有问题，应该OK吧，啊south China single single肯定没问题，我们直接从那个里面拿到了，好我直接control a control c给他干什么。

复制到这里边，是不是他们俩很多东西都一样，然后我们要把什么A2要改成A3了，是不是啊，改成A3，这是第一个点。然后接下来注意这个地方要改一个4142。啊，注意跟上啊，因为这个地方第一层是不是我们采集数据的这个地方，将数据发到了CC端口和CC端口。两个吧，那这块我们绑定的是C141，那这个第三个我们就应该绑定C142，都是102，这个不用改了，好think这是不是要动一下了，对吧，这个东西就是给它干掉。我们要用到本地文件对吧，肉我还没看吗。肉。

那看一下，其实它这个配置啊，也是极其简单的。类型绑定和我们当时想了，他肯定要提供一个目录，像点一样的，你要提供一个目录是这个意思啊，提供一个目录，然后这里边呢，它也是啊30秒什么刷新一个文件啊，刷一个文件，这个呢我们也就不改了，那刷新就刷新，那我们就直接干什么把它。拿过来吧，没问题吧，啊，他RC给他拿过来改一改对吧？啊，因为这些东西呢，你在公司当中用的时候，也是从官网当中去粘的过来改一下吧，这个绑定是不是可以给它去掉，因为写在后面了对吧？类型这个地方改成三也不用改肉这个不用改吧，这个地址我们得改一下。呃，我还是放在那个贝塔四里面可以吧。OBT。MODEL4啊，Group。

一组1OK吧，没问题吧，好看S，那这块要注意一下，我们当时SDF上的那个目录啊，是没有建，他自己来了之后自己建的，而且我们还用了百分号Y100分M这个房建的。有印象吗？对吧，没有自己建，但是本地文件系统，不好意思，这个目录要存在。他不会给你自己创建能听懂啊，所以呢，我们这个东西要去干什么，创建一下啊，创建一下我直接在这。那个家。好，我们去看一下CD没问题吧，啊，这个就建立好了啊，这个就建立好了，好就放在这，那接下来我们再来看一下整个的一个配置啊，按照我们整个的一个需求，我们整个的一个需求应该是怎么样子的？读取本地文件对吧，传给通过。副本的一个机制传给两个China，两个China呢，传给两个C，然后这个C好，这是第一层的吧，第二层，第二层这个C传给了一个。

阿波罗的这中间用阿波罗对接的对吧，阿波罗这个底下也一样啊，底下好他传给了一个China，传给China，然后呢，他到I这DF，他到本地对吧？啊这样的一个配置文件啊，配置文件那之后里边的一个东西，你自己去看一下，应该问题不大啊，应该问题不大，如果说他报错了，我们再回来看一下啊，我们来看一下，OK，这是我们整个的一个配置内容啊配置。