16_尚硅谷_Flume_单数据源多出口案例（Sink组）实现.avi原创

好，接下来呢，我们在这个姆罩里面再创建一个。过嘛。就是GROUP2第二个文件夹，其实这里面最终是有三个文件。哪三个呢？分别是。一。二。啊。我们采用的原则还是一个一个处理，比如说第一个，那就是这边对应的带pad，这边是阿罗，只不过是两个而已。啊，先写它，写完它之后他再。这样呢，就把复杂的问题给简单化啊。呃，来吧，来到这个。在这吧，OKCD照。啊，来到这麦克。吧。CD。进来。进来之后，第一个它的上端是什么呢。

吧，其实就是太阳对吧，啊，然后输出是还是吧。他服装是吧。杠，最终输出点好。那把这个代码过来。看一下先飞机。这块呢，是这个起名字。名字起面这里面加了一个这个group是这个主吧，主跟以前不一样了吧，加了一个，那下面这个，这是K1K2，这个在以前的例子中也有这种场景，所以。那再往下就开始配置这个。上的原第一个案例不就他嘛，对吧，哎，这个通过这个net向这个local host444端口发送数据。

就每个过程OK，不多说，往下走。刚才我配置了一个S组。对吧，这个可入斯可入丝里面有一个基。这个基因你可以配置一下它的类型，那这个类型呢，叫有一个叫load balance。其实就是一个轮询啊。负债均衡叫load balance平衡吗？加载的一个平衡负载均衡，那负载均衡这是back off啊选择to下边有一个。叫Ruby。就是允许。不两个组件吗？哎，这是你下是他啊，这是他完了再再再回来啊。这种交替式的。然后下边呢，这个是max太。这个也很关键，也就是说你这个重新往出发，或者工作过程当中失败了。这就是超值时间。那他挂了，立刻他往出发。这意思啊，好，我们可以看一下啊这个。

Note balance有五个。啊，这吧，你看这个这是对吧，那这里面这个type类型默认的need。To Bed or balance啊？这个呢，其实就是这种高左右，那这个呢，就是负载均衡这两种方式。这块可以配置啊，也说配置它的process。那你再往下这个鲁比。那这里面。这是must这个这什么。不是随机啊，你也可以拍成随机的这种。

11数啊，这个谁那就谁啊后面。这个啊，等等。你说这个和这个其实是比较常用的啊，随机。那你看下面这块配置的就是。干的啊？OK。那回来那这个配置完之后，那下边这个啊。至少是第二遍配置了。这个一。这个二。分别都是阿芙罗、海子堡。呃，四。四。都是往这这两个端口上去写数据就好了。OK，那下面这个开没有任何变化啊，最终这个拓结构那这块要注意一下。那看RC。Re，对应的C。然后格一是对应的think k1K2，先说这个。黑衣出来对应的是。C是吧。

这边对应的。K2吧，是这意思吧，就是R1C1K1K2啊，那下面这个呢，是记忆对应的K1K2啊，就是将这个K1K2形成一个S。拼接起来了，所以说你看这个结构。都是你根据你的配置文件去设置的。呃，像这个服务是这样的，后面你们要学这种流式的房价，像。Stop。像什么STEM啊，像什么卡STEM这种流失的框架全是这种这种特殊结构啊，都是根据你的这个需求。动态组成的。啊，非常灵活啊，灵。还是非常灵活的。好，那我们把这个拿过来。后面会讲啊有一些。这也是。搞的第一集。大家下面再往下看吗？这个完事之后，下面我们来处理这个。

左侧对应的阿波罗，右侧对应的是。对吧。到这个了吧，是吧。那这个是左侧是呃，阿芙罗右侧呢是啊。控台其实写一也行啊，这些。它是一个啊。杠左侧的是。右侧呢，是。那我们再来看一下这个代码。一样，这个前面呢，这块呢是组成没啥说的，SS这块呢，就跟上一级是不是必须一样。一样就可以了，那最终的输出这个类型的是log啊，其实就是打印到控台上啊。

那再往下呢，这个这一块一模一样，没有变化。那下面这个拼接组成。都没有变。其实这块呢，你会发现越往后写，你会越来越简单。那再来啊，那这个是第二个，那第三个呢，就是。这是一样的。一样的那一样的也是阿波罗啊，然后最终输出呢，是。这块呢，他是一个。只是这块变成。二好。

那这个拿回来，只是这块要注意哈，上面那个是4141啊，这个是4142啊。其他地方跟上一个是一样的。轻松搞定，也就说智齿的三个配置全部完成了，完成之后下面我们是不是要把这个配置给它开起来啊，也就说你看啊这两图。那你说现在呢，我们要把这个配置文件启动起来，这个配置文件启动起来，这个配置文件也启动起来。然后这边开始T向这个端口里面也是44端口发上网数据，那最终在另一个控制台上能看到相应的数据。那我们开起吧。杠杠。

杠杠内。这个要小心哈，这个要小心。这是A1对吧。这个是A。这个是A3对吧，A3，那我们到了起，从A3开始。那你说这地方是A3A3，然后是杠杠杠杠。照下面的二下面的最终输出到是吧二。对吧，啊是最终这个倒起来的话是这个。这个提供起来了，那下面再来一个。下边杠杠杠杠，然后呢是A级。

AR啊，AR告他减A刚刚跑完啊。干干干饭。在灶下面的格吧。啊，格住下面的flow。不论母一对吧一点。OK起。没人的。干干干。然后是杠杠。然后是A1啊。杠杠杠杠。的号下面的格数法度啊，格数度下面的。还有吗？楼是。对，大的还好。这样是这个火果全部启动起来了。

那改变窗口。人家说这是一个，这是一个，这是一个对吧，三个，那在这地方我要干什么呢。No。这这这这这个，那在这里面，我是不是要向那个太阳带里面发数据啊。啊。C。那发一个。

啊。不着急啊，看啊。把这个干掉。嗯，我们来看一下上一命令，这个命令呢是B杠杠。内幕。N1。啊，卡没打是吧。这完了我就知道了，这个后面这个要要要打着啊，这个你要不这个打印这个参数的话，其实它那个命令。

他就不会在公台上逮出来啊。这两个有什么？A2和A3。我这是A几啊。A1AE文网啊。啊，这个。这是加上吧。这是A3对吧，我先去A3。然后这个再走。那这个呢，这种。啊都起来了，然后呢，这块呢，我开始他腰带。捎带的试试。

来了吧，啊，再来。我呀。是我干的吗？这CTRL1CTRL2啊。好看吗？好看吗？能，能这样吗，我。吃完了完了，没朋友了，来来检查一下一块。它是可以的啊，结果车车过很多面。它就是慢这个因为我们都在你看啊，我们是不是开的所有进程都在这个102上啊，它比较慢啊，所以说这个东西比较多，我们来看吧，看哪个情况了。呃，A2，这是A3，这A3吗？难说了。不开二吗？这是开数一吗？对吧。

没，没问题，你想什么？来再来，他有时候是卡死的啊，这我知道他超时这个是。因为我那个长时间射的有点短。再来。要有耐心。啊，来了吧，再来。太慢。他那其实有时候都达到了他这个超时时限了，所以说你会看到一直在这里面。这个再来一个。

这个好伤心啊。不信她老公在一起。它不是这一个啊，他这个是呃是能，那其实这个它不在不在一起是什么原因呢？你看又上一个吧，它是有个超时时间，咱这个超时时间设的有点短，因为咱这个服务器啊。他都在一个这个102，你看我这开了几个N多个，包括这个102，还有这个呃，海子集群都已经启动了，所以说他会这个占用资源，响应起来比较慢啊，正常情况它就是这个允许保证这个负载均衡啊。就说这个案例啊，在任务开发中你是一定能用到。这个这种配置，至少我现在敢保证呢，就是在这个凤凰网。啊，就是我之前跟你说过吗？他前提是39个。这个，然后第二题呢，是五个，这五个配置的，就是这种这主。能懂吗？性格主啊，就这意思，那同时呢，它是任何一个挂掉，你发现那个他没响应，他是不是切到那其他去了啊，其他的一样能完成这个工作。