25_尚硅谷_Flume高级_Sink组故障转移（案例测试）

好，刚才呢，我们把整个的需求解决一下，也就是说从前面读过来数据通过新的组的负载均衡的一个策略要发送到两个什么。Form里边发到二三里边FORM2FORM3呢，都打印到控制台，我们之前就学过了，对吧？啊，因为打印到控制台呢，更方便看一点，那接下来呢，我们就写它这个什么。非常念make，给大家一个group。二对吧，啊GROUP2好，然后CD的这个GROUP2里边，同样的在这touchfrom1.touch。二点康复，然后它是一个什么，三点康复啊，三点康复好再推出来。然后呢，我们把这个东西全部给它关掉啊，不做影响啊，不要互相影响，因为刚才也有什么123对吧，这个东西呢，全部关掉，重新打开我们GROUP2里边的123啊，退回来GROUP2里边一。

二。三对吧，啊，把这三个给他开一下。挨的好，然后呢，我们再打开一个，因为我们刚才分析到第一个地方，这个地方S。是不是接收端口号数据啊，用那吧，所以呢，我去拿一下这个东西都行，或者从文档当中拿，或者从那个官方文档拿，或者从这个地方拿，这个都无所谓ID的给他拿过来，我把声明加这个都拿过来，OK吧C。放在这，那follow还叫A1这个东西，来来log host logo或者你写哈102也可以啊，这个无所谓，好接下来应该配置什么了。China对吧，啊，假如说我们China一遍。China还是用。可以吧，啊这个里面呢，还用一下给它拿过来。好呢。是不是两个，然后把两个single放在一个组里边，对吧？好，既然是两个single，这块应该加一个跳对吧，好两个OK，这两个single要用什么single。

是不阿罗，因为他要对接的是二跟三嘛，啊，所以呢，对接的是阿罗的一个性格，阿罗性，那我们拿一下阿罗性之前我们也有是吧，GROUP1里边是一是不是阿罗S。对吧，呃，那我们很简单，直接把他们俩干什么。拿过来就行了，对吧。这个放在前面啊，这三个是我们现在要用的三个，这个呢是。保存K1K2。KK这个东西往那一放啊，一个C1C1，一个4132啊，最后还有一个绑定对吧，把绑定写一下find。啊半这个半呢，我们也是从这给他拿一下。但是要做一个修改，这个地方要改成什么。C。

啊，这个地方呢。没有C2了，因为当前是不是只有一个China，一个China对应两个C对吧。没问题吧？当前我们的需求是监控端口的source。Memory channel，然后对接一个think足是不是这样的一个内容啊，对吧，所以呢，C啊这个东西China只有一个C1，其他的都干掉两个K2K加二呢，都绑定这个内容，好，那接下来就要配置这个组的什么。策略了啊，走的策略了，同样的我们是到这来拿一下，把他拿过来吧。CTRLC啊，拿过来。啊，然后把这个拿过来啊第一组。配置这个S组，然后呢，我们在这写一下啊啊，随便你这个位置放在哪，无所谓，井号叫think。对吧，这RO来看一下这里边它怎么配的。首先呢，配了一个定义的一个什么。

足对吧，既然它是定义，是不是我也给它干什么。放在上面去，诶比之前就多一个定义了，定义了是什么组，因为默认的那种情况下没有组吧，啊没有组这一好接下来看往这一组里边塞了。可两个吧，好，他的一个参数是。还over故障转移的策略，然后给K1K2给了一个优先级，对吧？啊，官方的50，那就是优先往K2发。对吧，啊，优先往开发就这意思，好，那接下来这个值，其实你改不改30秒或者十秒这个无所谓了啊，那就改一下啊，这个做一个保存，这你们从官网上直接拿过来了啊，官网直接拿过来了，好接下来写那个。尔，甚至我可以最简单的操作操作。

把GROUP1里边的F2给他拿过来。然后改一个地方。改谁？是不是这个东西改成。Lava就行。有没有问题，没问题吧，啊，因为这个地方我们说了，我们是要对接的是前一层的什么。传过来的数据是不是阿罗的一个source对吧，然后慢China log，因为我们说了这个东西呢，打印到控制台我们更方便什么看一下吧，最后是绑定，绑定需要动吗？不需要，因为这里面只有re c1K1，所以说呢，就是第一绑定的关系吧，没有什么组啊，China断选择器这些东西的，好把它看成A，看到C，复制一份到这个地方。把这个4141改成C142，把A2改成A3，哎，这块有有没有听错。保存一下是不是就够。没问题吧，啊，这个东西就等于配置文件，我们就给大家看什么。

搞定了啊，就给他搞定了，OK com s做一个保存啊做个保存，那也就是说三个配置文件，我们就已经给他干什么。搞定了啊搞定了，OK，那这块呢，我们来做测试。做测试。同样的道理，先起。二三吧，啊，先讲三好并。From nga。着呢，杠C-f job底下有一个GROUP2里边吗。二注意后两个是231最后起了，我们也说了，一最后起OK，什么杠NA2好，这个时候既然是log，所以呢，我们应该去找一个什么。杠D那个参数啊啊杠D，因为你要是不写杠D的话，你就打印到哪来。打印到日志文件里面了，打印到日志文件倒也能看，但是有一个问题，就是你两个人都打印到这个日志文件，到底是谁打印到了？

对吧，所以呢，我们在这个地方加一个这个内容，OK吧，啊加一个这个内容啊走一下。走了，阿波罗的一个已经启动了，好，接下来把这个谁也起下吧，B fromg a的杠，C杠。Job底下GROUP2里边有一个三，然后杠N是。A3对吧，A3A3，然后同样的我们应该加上一个这个内容吧，啊给大家拿一下C，因为它也是log走。啊，这个呢，也启动了，启动完成之后应该把这个谁。A1也启动了啊，A1也启动b from-C-F底下有个GROUP2里面的FROM1对吧？啊，然后杠N是A1，这后面要杠D吗？不用，他是阿波罗性对吧，阿波罗性他不需要走。

这个东西有了。啊，它显示已经监控到了，放的已经绑定了，刚才是不是只是到这啊日志对吧，一启动之后呢，哎，你起来之后，他们俩已经连接上了啊，通道已经打开了，好然后呢，我们要去干什么。NC。好色五四的。14141，谁说411，你监控的这个你4141是发到幺。不要混了，你监控的是这个端口吧，这个是你读数据的来源，这个是这两个端口是你发数据的，对吧，你说NC是不是要连这个呀，没问题吧，好，那我们这样把这个呢，窗口呢，我们给它。这种模式好，那现在这个一对吧，我之前说的一是芙蓉一吧，对吧，二是芙蓉二，三是三，那按照我们的优先级谁高啊。

K2高K2对应的是。三没问题吧，K2嘛，K2对应的你看端口号是4132，谁坚定的4132。FROM3也就这个吧，那优先级他高，应该理论上说先你先接收吧，那我们试一下是不是啊哈。走这个因为中间传输的比较多，它稍微会慢一点。咱们有咱们机器问题吗？咱们虚拟机问题，OK，过来了吧，爱的硅谷。还在微博对吧，啊，然后随便随便这个就随便。因为虚拟机没办法，虚拟机没其实没这么慢，没慢，生产当中没这么慢，挺快的，能过来吧，对吧，而且你发现无论我怎么说。

就这个吧，这个有据没有吧，没有过来了，过来了吧，好，那把他干什么，看TRC干掉了，哎停掉了，它挂掉了，也就是说此时我们刚时说了，它是不是服务端了，后一层是服务端嘛，也就是对于弗一来说。是不是这个。哎，你看在这这个C挂掉了，因为你服务端关掉，我客户端能连吗？连不了又报错了，说那个4142端口连接不上，连接不上它不能就算了，因为你是一个组，是不是就连接他呀，对吧，来我再来好。在这等着对吧，啊，看这的窗口就行了。第一次通信有点慢。OK，过来了吧，啊过来了啊，也就是说他是不是备份的一个关系啊，备份那个关系，OK，然后是爱的硅谷OK了啊再来，你看现在就你一个人活着了，只能你工作对吧？啊，就做这个事啊做这个事。

OK，这就是我们所说的那个叫什么故障转移对吧？哎，故障转移给他拿回来134对吧，因为这样给大家缩一下比较好看一点啊，直接能看到结果，好，那我们这个是我们整个的一个测试。