24_尚硅谷_Flume高级_Sink组故障转移（需求分析）

呃，那刚才呢，我们是把那个副本机制的这种China选择器这块就搞定了，那还有一个我之前说了，呃，下列选择题当中还有一个策略叫marle，对吧，但是现在呢，咱们还测不了，因为这个拦截器咱们还没讲啊，讲完拦截器之后，我们来测一下这个内容啊，来测一下这个内容，好，那接下来我们看第二个阻案例啊，第二个组案例就是负载均衡和什么。故障转移啊和故障转移，那我们先看这个，呃，故障转移，然后看这个平衡啊，这个都可以随便先看哪个后看哪个都无所谓，就是改一个什么。配置参数对吧？啊，改一个配置参数的一个问题啊，OK，那我们先看这个故障转移吧，啊正好案例就是先是实现了这个故障转移这个功能啊故障转移的功能，OK，然后这样的还是一样的道理，这个时候呢，因为为了测方便一点啊，我们就不往那个SDS还有那个什么本地文件去测，因为还是不方便看嘛，因为刚才我们只是最最后对比一下他们俩是否相同，那现在呢，我们做一个简单的事情，都把它最后第二层改造。

Longer直接看结果啊，比较方便啊，比较方便，OK，那我们看一下整个的一个需求是这样的。呃，还是同样的，用这个一呢，监听一个端口啊，或者说呢，监控一个文件，这个源就无所谓了，因为监控端口或者说监控本地的一个文件。我们可以挨个这种方式给他添加对吧？啊这样呢，我们可以自己看到这个数据怎么样的啊，就是还是监控一个端口啊，监控一个端口，然后接下来。这个时候注意就要是C组了，跟刚才那个点的区别就在于哪呢。只有一个China了，对吧，刚才是不是两个China，你才可以选择什么副本等等这些东西，那现在只有一个China就没得选了，你就不用配什么副本啊这些东西了，对吧？啊不用刻意的指明了，这个时候呢，就是两个。C，而这两个最后绑定的时候都绑定C1。

对吧，啊，K1K2都绑定的是C1，但是这个时候你要配一个什么。组的一个策略了啊，组的一个策略了，是这个意思啊，那第一个我们用的是故障转移，昨天呢，我们说了只是粗略的看一下，那今天呢，故障转移我们再来看一下是不是s group里面的。对吧，在这default中我们就不看了吧，啊，默认的不看了，我们看这个什么。不。好。发这呢，首先你这个。这个一定要配吧啊，就是说关于这个组的什么类行啊，还有一个这个组里边的自定的丝也要加进来。因为我可以有C1C2C3C4，我C1C2是一个组，C3C4是一个主心。对吧，啊，分两个组，也就是说这样的啊，注意假如说我有两个China，两个China呢，对应的四个C，那是不是应该他俩一个组，它俩一个组啊，就是你当前这个组里边放哪几个think，你要给他干什么，指定一下能听懂啊好，那接下来呢，是这个类型。

我们肯定要写这个反故障转移的这种，然后接下来还有一个这个内容，这底下两个。而且它也是黑体的，也就是说你要配的吧，啊，你要配备一个值，那这个是干什么用的呢。叫什么东西，那个值优先级。啊，优先级看一下它是怎么配的，诶这个金工号好像我们在哪见过。之前配那个KDR的时候，是不是里面也出现了监控号，也就监括号这个里边的东西，是不是你在上面配置的某一个value啊，还有引号。当时跳电压里面是不是写了F1F2，然后下面什么点F一点F2还有印象吗？那现在它叫think。你上面配的辛斯配的是K1K2，那现在要写K1K2，它这个什么。

优先级给他一个值。能听懂对吧，因为你第一次两个都是活着，你到底选谁呢？选优先级高的，也就这个值大的对吧？啊，也就选这个值大的一个，假如说一个一，一个二，或者一个五一个十，这个距离数字无所谓，你只要有大小关系就行了，对吧？啊，有大小关系就行了，也就这意思好，然后还有一个这个内容。这个又是一个什么back。对于这种失败的。对，那这个干什么事呢？是这样的，因为他这个里边啊，那有同学可能想这个里边有什么退避的，我都是发给一个人退避是这样的，首先假如说我们两个K1K2K3。OK吧啊，K1K2K3，呃，优先级呢，是这样的，321这个数字，假如说我配置文件里面写的好，首先打开的时候，他们三个人都是活着的。

他们三个都是活着的，那首先数据来了，ABC发给谁啊，K1，这个没问题吧，啊，按照顺序来了，好，此时K1挂掉，挂掉之后注意。他这个K1就进到一个失败的队列当中。接下来有数据来了，不好意思，不会考虑你这个K1了，因为你刚是挂掉的，对吧，我数据没传输过去，是在K2K3里边选选择什么。K2，因为它这个优先级比T3要高一些。啊，要高一些，好，那接下来有个问题，它起来了。就跟这个东西有关系了。啊，这里面呢，也是一个什么最大值，也是那个退避原则在里边啊，如果说你假如说我们直接就用最大值吧，就是30秒，直接配就30秒，如果你是在挂掉30秒内起来了。

不做考虑。能听懂。就是说K1先挂掉了，接下来在K2K3里面找这个没有问题，对不对，但K2挂掉了。而此时，K已经起来了。已经起来了啊，就是K2挂掉之前，K1就已经起来了，因为他刚才挂掉可能网络阻塞呀，等等东西，它已经起来了，对吧，已经起来了啊，那这个时候如果你是30秒之内起来了，不好意思你不做考虑，因为你30秒之内你还在这个什么。失败的队列里边，如果说超过了这个最大值，我就要把你放到待考虑的范围内，能听懂啊，就这意思，做这个事的，做这个事的他其实也是做退避吧啊，就防止在考虑他嘛，因为K2挂掉之后。开过来之后，他是不是去校验一下，K1是不是活着，K3是不是活着呀，对吧，因为他此时也不知道到底谁活的，他得尝试去发送一下吧，但是你K1优先级更高，我是不是先尝试它呀。

对吧，但是由于你刚挂掉，是不是我在一定时间范围内我就不尝试你了，能听懂这个意思吗？对吧？啊，就做这个事用的啊，注意一下啊，关注一下这个点就OK了啊关注一下这个点，好这个呢，30秒和30秒就放在这，那我们要配的就是他们三了啊，他们三个就是这个意思，好，那我们把整个的配置文件来写一下，呃。这个地方刚才呢，我们是需求分析，把这个。