05_尚硅谷_Flume_Agent内部原理.avi原创

好，接下来呢，我们看一下这个另一个重点，From a't内部原理啊。刚才呢，我们其实是整个浮动框架啊，在一个原理，那现在呢，在。进入到它具体某一个来电的，它又是怎么玩的，那我们来看一看啊。从不同的角度。首先呢，介绍事件啊，比说数据的源头进入到SS里面去，能知道好进来之后它是不是要进入到这个传统啊啊。那进入到拆之前，它是有一个处理事件。什么时间呢？拦截器。也就是说你在我们写的过程当中啊，我先把你这个事情拦下来。这个拦的过程其实有一级燃气，二级燃气，这个可以拦截多少。最主要拿的什么呢？啊，拦下来干啥？有些时候，比如说你这个数据传进来的不是压缩的。

我是不是把它拦下来，我给你压缩完再往下一传呢。同样如果说是前移是压缩的，我想变成非压缩的，我是不是可以解压缩呀。然后原来比如说是UTF杠八的。数据。到时候可以把你改变一个你的相应的这个编码方式啊。啊，都可以啊，但是呢，后来我们在这个项目开发中用的什么呢？哎，拦下来对日志进行分类。你可以想想，京东里面是有大量的这个各种商品的日志，那很多大类啊，你们最擅长的不就是保健品吗？对吧，啊，生活用品还是生理用品。啊等等啊一堆，那是不是得需要一个分类去统计啊，哎，那就在这块的时候。就已经将他拿下来进行一个分别处理。这就是拦截器的作用啊。那是China处理器啊，到这那来完之后回来，接下来呢，是将每个事件给传选择器。

啊，又来一个传统显示器，一般后边呢，它有多个传统的时候，那你说你后面有多级传导。那我把这个数据传到哪一个头上去。这是不需要设置啊。啊。这是一道面试题。啊，原封不动，没人提我就是为了。呃，这道电视题把这个这加上来啊，可以看一下。China有两种类型，一个叫replacing letter。其实这种啊。默认另一个呢，是这个。China这个什么区别啊，这个。这种显示器会加source不来的事件，一般的是吧，啊现在一个集装箱啊，一组数据。发往所有。懂吗？无论你后期有多少个摔倒。

全都介绍到。啊，相当于广播式的是吧，大家都能听到。那而这个market呢，它是可以配置放往哪一个传统，你说你你可以选择性的这里有四个，我就往一里面放啊，或者我就往二里面放。这可指定的这两种发发的方式能理解吗？能啊，OK，是这个意思，这是一道面试题。他问的原原题是问的，问这个选择器当中啊。这种选择器。或者说他的工作形式是什么样的？那其实就是他会向下一级所有的传都发送数据。这一层啊。然后返回写入的这个传梭列表，也就说返回来这个传梭处理器，你最终要往哪个传送器，对吧？啊，如果是你是第一种这个。

那没关系了，那就是都写了啊。那如果你是这个。这个，那你要指定是哪一个通道。大家有没有想过这个哪个通道里都写这个。我跟你说哈，后面我们有一种这个传统。形成这个主，把它组成一个主，它坏了这个数据可以发到这，他带坏了可以把数据发到这，他们是并发网络运行的。那是不是要求你这里面哪个里面都有这个数据啊。想一想啊，如果这三个里面接收到全部都是一样的数据，那最终往后面输出的时候。我允许你一个人往这写。那它坏了，到时候可以下一个写。它可以采用。就是第这你过来一时间你发，再来你发发。啊，类似于故障的一个转移是吧，哎，提高可靠性的，在真正的体开发中配置的这种方式。

包括这个，呃，那是凤凰。他们是前一级39台。快乐结束了舞台。那么他在这个39台呢，啊，就是每一台都会发到这个其中的一台里面。数据一样，这能懂吗？啊，全都全都往里面放啊，全都往里放，那他会配置成什么样呢？就是配置成这种。0009。啊，一组数据，然后最终新的数据。那你说任何一台挂了。是不是还有其他的啊，除非这舞台全挂啊。是为了提高可靠性啊啊。OK，往下。那这个插头哎，最终选出一个啊，或者是多个啊。23个，那就三个网络发呗。比如说这里面就选择了传一啊。那相当于最终往外发，那就往这个think端里面去。

那这呢，其实这它也是任何一个，这都是对应着前一级的一个能。这个都是可配置的啊，都是通过代码配置的。就是比较灵活简单。这处理器选择其中一个，这去获取传统的数据，并将获取的数据写入到。这就没得说了。好，我稍微回顾一下啊。首先接收数据。啊，接收过来数据之后第一个面试题。用没用过？电器。你这个拦截器当中拦截了哪些数据啊？我告诉你们，你们后面会讲啊，前期先你们说日志的分类对吧？啊。这是第一道搞定，那接下来第二道，那么它拦截完之后进入到传选择器。啊，传统检测器当中有两种。

一个是啊，另一个是这个market啊。这种。两种，那第一种这呢，它是将所有数据发往所有的船上，比较简单，默认。那另一个呢，是选择性的发网，你指定的。OK，第二道没问题。降价。往下呢之后呢，就是选择已发的这个通道啊。往那边放，那最终出。根据你的配置搞定。那这里面至少两道面试题啊，这一道这。啊，这是普通真的那。