00:00
好,呃,那么接下来呢,我们看一下所谓的内部原理,其实就是它详细的架构,因为它的过程当中,我们刚才看到之前好像我们以为是只有source China跟S对吧,现在是不是又多了两个事物传过程当中两个事物,其实在这个过程当中呢,它还有其他的组件,那我们来看一下啊呃,后期的案例当中,我们对这些组件呢,都有涉及,每一个组件我们都要去用的,首先呢,最原始的source接入数据封装,Event。按照这来说是不刚才说了要把数据传给这个China。对吧,然后中间是不是有事物到这,其实不是的,中间还有其他的东西,那你想吧,假如说我一个so把数据传给两两个拆了,他应该怎么传呢。是不是要配置策略啊,到底是副本还是一人一条呢?因为我假如有四条出去,到底四条我两个人都传,还是说一人两条呢,还是说一边一条,一边三条呢,这个都是可以配的。
01:09
那我们之前都没有配过,对吧?是因为我们现在还没有涉及到一个组件,那我们看一下除了source在China之外,他在S到China的过程当中还做了什么事来,第一个他首先呢把数,把这个数据呢,传给了叫China process叫处理。处理器对吧,China处理器还没有到China啊,注意,然后呢,China处理器呢,它会调用in the分子。那大家说打断打断那是不行,拦截器打断没问题对吧,就是说把你这个数据呢,先拦截一下,我可以对数据呢做一些调整,或者说我发现有一些脏数据,我能干啥过滤掉,我不传了,对吧,我不往下传了。啊,或者说呢,我在你的数据当中,我加一些内容。
02:03
你比如说IDF think那边,我们是不是看到是要使用当前的什么local time,还记得那个属性吗?用本地的时间戳,如果不加,你可以测一下啊,它会报错写不了,当然你前提是你路径里边用到的时间。它会报错,那如果说我没加,我可以干什么事呢?我可以在拦截器里边给它的图信息添加个时电桩,这样也可以,那那个属性呢,我们就可以设为false。啊,而且这边拦截器呢,还可以写什么。123可以写多个啊,其实呢,他先将数据呢,传给我们所谓的叫拦截器量啊,叫拦截器链这个东西啊好,那接下来经过拦截器之后,它是不是有的数据都丢弃,或者有的数据呢,添加了一些信息啊对吧,然后又传给我们China process,然后接下来由我们的China process干什么事呢?交把数据交给我们叫China select。
03:10
这个翻译过来叫什么叫China选择器?就是决定我们这个数据应该如何去发送的问题了,刚才我们说了exce对应多个China,那应该怎么发,就是由这个什么China选择器来决定的,它的选择China啊好,那China选择器当中呢,就有策略了,它有两大策略,第一个默认的。默认就是你不配的时候,就是它它的选择器策略对吧,你不配那就是它叫什么叫reliccating什么意思,副本,那什么叫副本机制呢?对我一个哨子对接两个差呢,两个人完全一样。那这个就叫副本机制,默认的它是副本机制,就是说假如说你给一个sources绑定了两个China,你没有配任何China选择器的内容,它就会把同样的一份数据发给两个China,这是它默认的策略,但往往有时候我们不希望这样。
04:16
对吧,我不需要这个发送到两部分,那接下来还有一个叫。叫multiplaing对吧?Multi什么意思?多啊,这个指的是多路复用,就是说呢,这个时候就可以人为的来控制这一条数据到底发给一产导还是发给二产,还是说有的数据两个产能都发,都可以配置。啊,都会配得非常灵活,当然这个时候呢,要就是说如果要用marketing的时候,一定要结合着拦截器来用,它是根据我们数据当中同信息里边的一个内容去做的处理,就同信息里边你得配一些东西,然后其实它是根据同信息里边你所配的东西来决定将这个数据发送到哪个产是这样东西,也就是说China选择器这块呢,有两个对吧,还有一个multi,一个呢副本机制,一个叫多轮复用。
05:14
可以决定这个数据到底发往哪个产品,当然这个数据啊,如果说两个产的都要,你也可以配置,两个都发也可以啊,但是后面我们要具体的案例去操作的,好,这是我们的拆断选择器,经过拆断选择器之后,这个数据是不是就知道该发送到哪个拆断了。对吧,它其实就是选择去选择干什么,发送到哪个掺到的所谓的拆的选择器,然后接下来呢,它会把数据又返回给我们什么。China处理器,好,那拦截器也经过了,China选择器也经过了。那么接下来就是开启对应的事物啊,数据写到我们的什么China啊,有可能就选择是CHINA1对吧,啊标红的,当然我们可能source配一个,这两个配三个都可以啊对吧,那假如说这个数据写的最后呢,根据这个选择器选择发现用的MARING1选择发现用的是什么看到一将数据发送给看一但在这个发送的过程当中,就会有我们刚才所说的。
06:22
铺的事故了啊,在这个过程当中,它会开启的事物啊,是这个过程当中,在这这个才真正的传输啊,这一块呢,只是说在传输之前相当于做一些准备工作啊,做一些准备工作啊好,那数据到我们China了之后,接下来是不是应该到我们的。Think,好,之前我们是不是说过一个S只能绑定一个产,对吧?我们配置文件当中看S一个source里面是不是加了s think里边没加S,但是从来没有说过一句话,一个China只能配一个think,没有说过这个吧。
07:03
对吧,就是说一个S,假如这是一个think,我们不能说从两个参当中去干什么,拉取数据,这个不行,但是我是一个China,我将数据选择发送给两个C,这个就是可以不冲突呀,对吧,这个是可以的,也就是说我用两个性同时绑定一个才能。这个是可以的啊,所以呢,那接下来这个China里的数据要发送给哪一个think是不是又要类似于做这种选择了呀,对吧,它类似于做选择了,它呢叫think process,其实这里面呢,就会有一个S组。它里面会有C组的问题,C组呢,默认的有三种啊,就是说它有三种,但是你可以自定义S组,但是其实很少自定义啊,S组也很少自定义三种,那我看一下第一个只有第一个可能大家不太清楚,叫默认的这个,第二个呢balance,第三个呢叫三欧。
08:17
Over是什么意思?故障转移吗?你们当时学那个高可用的时候,不是看的那个吗。它存在这个单点故障问题,我们用think往外写的时候,假如说你单独的一个think出问题了,那不就写不出去了吗?那整个出问题了吗?那我们可以配两个对吧,相当于这个呢,其实高补充这个呢,是叫负载均衡好,那还有个default。Default呢,其实有时候你在面试的时候啊,跟人家去聊的时候,人家说新组只有两种呢,怎么就三点呢,因为default这个S组啊,他只接收一个S。就如果你用的是default的话,那么你一个China也就只能保定一个字,能懂我的意思吗?啊,是这样的一个关系,好,那这个default呢,所以说有的时候面试官说认为这个default不算一个组,只有一个C嘛,对吧,他认为不算一个组,这个也很正常,所以说面试官说的时候,人家说三种,它是两种,你要知道它指的是什么意思,OK吗?啊,是这样的东西。接下来呢,我们聊一聊load balance和这个犯over它是什么意思啊,Not balance呢,负载这么好,这个假如说这个China呢,绑定了三个。
09:33
绑定了三个,我们说了数据不是由think主动去挖取吗?对吧,他这样的先呢,你去看看里边有没有数据,对吧?如果有数据你拿走,接下来由你看,接下来由你看三个人以轮询的这种策略挨个去看有没有数据做负载均衡吗?不是说所有的数据交给一个人处理数据,如果说这边数据是源源不断过来的,一直不停的,那么最后这个数据是不是分散到了三个性格当中?
10:08
对吧?啊,所谓的负载均衡就是做这个事的,那下面一个我们叫故障转移对吧?故障转移是什么意思呢?假如说它可以配置优先级啊,在里边C个组里边,在故障转移当中,对于多个C个可以配置优先级,假如说我优先级是20 15,就是用一个数字20最高,它是它怎么样的呢?先。你一个人去了,就交给你了这个任务,但有可能你这个性格怎么样啊,挂掉了对不对啊,挂掉之后好就交给你了。就是你挂掉了我才交给你,他跟刚才的load balance是不是不一样啊,Load balance是大家都活着的时候,怎么样啊,就类似于那种轮巡的不停的先你去拉取一下,我去拉取一下,然后另外一个人去拉取一下,而现在所谓的故障转移呢?
11:05
就优先你一个人去拉取,当你坏的时候,我相当于替代你工作,对吧?当你坏了干什么?由我替代你工作,这就故障转移,那之前大家所学习的内node单点故障不也是这样的吗?里边提到了一个,因为它存在单点故障问题,对吧?那我要配多个内node先呢?你一个人工作,当你挂掉的时候,是不是我另外一个人起来替代你工作,对吧?这就是所谓的叫故障转移。啊,故障转移当然啊,如果说你挂掉了,一会儿已经切到它了,对吧,你起来了,你又重新启动了,又好了,对吧,接下来如果你挂掉了,它优先级高,还是选择它啊,不会选择它。对,还是看优先级啊,还是看优先级是这样的内容啊,如果说你前面两个都挂掉了,那就到那到谁呀,到第三个了,优先级最低的那个啊,就里边可以配置优先级啊,配优先级是这样的东西啊,所以呢,这里边看上去就之前我们认为的只有south China think对吧,实际仔细一看它详细的架构图当中呢,又多了几个东西,想想一个拦截器,一个China选择器,还有一个think process,或者说我们把这玩意叫single组啊,叫single组。
12:23
啊,叫三个组就好了啊,又多了这三个东西,同时我们知道在这块是不是有一个不的是我在真正的数据传输的时候,这边有一个take对吧?如果说在面试过程当中,人家问到你from架构是什么样子,那你要聊的是它,而不是简单的说source China sing这三个东西OK吗?要把这里边详细的要说出来,当然现在呢,你强行记可能有点难,但没关系,因为我们后面呢,像自定义拦截器啊,China断选择器啊,C格组啊,我们都要去用的。啊,我们后面的案例都会涉及啊,然后呢,我们一个一个去看这些东西啊,现在呢,相当于还是跟那个所谓的事物一样的,对吧,先呢去记一记把里面东西啊,回家可以去画一画这里面的东西,对吧。
我来说两句