32_尚硅谷_Flume高级_自定义拦截器（配置文件）

好，那接下来呢，我们要做它的一个测试啊，做它的一个测试，OK，来project，我们之前说过这个东西呢，你放在idea里面，它用不了了啊，你得打包扔到提裙上去，对吧，拍个点打个包。导包呢，我们把这个路径准备好，Out加pcdd model，然后from Li啊放到这个底下啊，放到这个底下，它默认的这个是它自己的一个pass啊，从这从这里面去加载所有的一个内容，去放到它的一个class pass下。还没打完好，这边打完了，打完之后呢，我们直接给他扔上，他给这个家包叫什么名字无所谓对吧。好，进来。啊下就行了啊，因为我们等会呢，应用的时候要用到全类屏，它通过全类云通过反射的方式去调用它的啊通过反射的方式OK，那我们接下来要写什么呢。

配置文件了，对吧？啊写配置文件了，那还记得当时我们的需求吗。我们的需求是监听一个端口的数据，或者监听一个文件的数据，这个无所谓，对吧，用NECA给它监听过来，监听过来之后呢，要用到。China。选择器对吧，在应用选择器之前，是不是应该有我们啥拦截器，先拦截一下，添加一个类型，你这个拦你这个前的选择器才可以用啊，也就是说这里边。拦截器和选择器对吧，一块用的啊，都一块用的，然后接下来我们将这个数据呢，传到两个阿布罗的，因为我们为了方便传到两个阿罗格里边啊，然后为什么事呢，一个阿布罗森对接103上。Logo性，一个对接104上的logo性，这样我们就能把这个数据给他干什么。分开了啊，或者说你这个都放在102是不是也可以啊。

对吧，那我们就放在103104，这样是不是更能。区分开对吧，而且我们之前也测了是不是跨机器传输也是没问题的，对吧，所以呢，我们就把这个需求变这个样子，OK，我们再说一遍啊，在102上面。我们监听五个四端口发来的数据。好，这是一个ne的一个source，然后这个source呢，经过我们拦截器将数据。同样的给到我们的什么China选择器啊，选择器啊两种嘛，一个呢是带hello的，一个是不带hello的，对吧？啊不带hello的传给我们的这个注意叫China选择器select，这个选择器里边我们是不是要配成market，然后去配handle配对吧，把这个都配上，配上完了之后，接下来这个地方要去干什么。两个China对吧，C1C2C1呢，对接的K1，这个对接的K2，这两个东西呢，都是什么。阿波罗的黑啊，一个发到103，一个发到104，在103104我们多一简单化处理，就是加上。

Log啊，因为我们打印到控制台，这样更方便做测试，对吧，这个流程没问题吧。有问题的，谁说？别到时候写的那个文件的时候有点问题啊好，那我们既然没问题，我们来写一下啊，来写一下，呃，CD到这个job里边，我make d一个什么。In cep。就叫拦截器的一个测试，对吧？啊拦截测试就做了一个这个内容，好CD到这个三里边，我们在这它是一个。因为涉及到三台机器，所以我还是二点嘛。Com可以吧，啊2.com啊CD出来XYC，把这个三给10304发一下，因为103104还没有这个文件夹，我就不单独去创建了，直接用这个内容就OK了。欧model，然后这个。

Job里边有一个给对吧，哎，把这个来复制一份104粘贴，然后我们先把这里边为了不冲动给他干掉吧。RF，这个FORM2看见没有，这里面有一个什么？这里面呢，我们重新touch from3点。对吧。这个地方它是四点。其实你感觉这个三四是不是跟上午那个是一样的。最后那个案例对吧，啊，三四跟倒数应该是倒数第二个案例不是九个案例对吧？啊最后呢，三四两个都去打印。打印到空白，我们直接看结果对吧，所以呢，我们等会可以直接把它打过来啊，把它拿回来，只不过说这个时候不一样的地方在于哪呢。这个案例跟上午我们所做的每个案例像。复制吧，因为就是这里边的选择器的策略不一样嘛，对吧，上午的是现在呢。

是multi对吧？啊，也就是选择器的一个策略不一样啊，之前我们是不是将数据打到两个控制台同时打印啊，两个都有啊，两个都有，现在呢，不是了啊，现在不是了，来我们把这个配置文件给它搞定一下啊，给它搞定一下。这个总让人花钱对吧，让你购买。用那个也还行啊呃，102这个job底下有一个intercept这个案例，然后FROM2点开啊，这个呢，里面配的东西比较复杂对吧，因为in the second select都在这里边吧，三四其实很简单啊，三四肯定很简单来。三。然后from，这个叫三。哎，不是这个是那个里边的三对吧，还这个不要不要搞错。

是啊，点开同样的这个，哎，这个我当时保存的东西我再改一下，要不然这个每次从跟目录进要麻烦一点，我一般的配着进来的目录就是。嗯，我叫太色，OK，那这两个东西呢，我们可以去找一下上午的那个东西，我们拿过来配下对吧？呃，上午我们那负载均衡的就是这个内容对吧。二三里边都有，嗯，我现在看啊，二三这个ID的看一下没问题吧，啊，这个东西我们可以直接拿过来啊，我们先把后两个给他配好。这个粘贴一下，这个呢，我也粘贴一下，等会呢，该改的改一下，这个地方我叫A3没问题吧，啊叫A3这个地方应该A3改成A4对吧？好，A3改成A4就可做，诶改过来了，然后接下来注意。这个地方呢，我们之前说过后一个S这边属于。

服务端，服务端它必须要绑定。主机绑定谁？三是不是绑定当前这台机器啊，对吧，我们上次所说的，所以这款应该改成103这块改成104对吧？啊改成104，那既然是103104这两个端口号是一样的K。可以了，对吧，啊可以了，这个是可以的，那我们就还是这样，C141跟414，你要注意一下，诶这两就一样的对吧？啊一样的就一样的好，那接下来我们要配它了。啊，这个地方呢，再给大家写一下第一个还是什么。Name啊，命名命名呢，我们从这个拿过来改一下对吧。他C给他拿过来这个A3，等我们统一改了，这个里面呢，我们把它叫做A2，其实它叫A3也无所谓，Source想一下几个。一个是不是一个对吧，China呢，是不是两个一定两个吧，啊你要选择器了，这个呢，是不是两个好K2好那AS对吧，井号so。

我们把我们先会的都给他定好。来叫那看对吧啊，那看我拿一下吧，或者从这个地方拿下。看到我就不从那个，诶刚才这个就是对吧，把这个拿过来就行了吧。看拿过来看到没好绑定本机五个四还是之前用的完全一样吧，啊直接拿过来了啊，这个A1呢，你也不用管，那接下来China井号China的定义是不是一样的。它会变吗？只不过说我们要加拦截器，加选择器，你加这些东西的时候会影响China怎么定义吗？不会OK吧？啊不会影响China怎么定义OK，那这个地方呢，我们叫China。

啊，两个什么memory China，我从这个地拿一下吧，CRC拿过来啊CR，然后呢，这个来一下，这个改成C2对吧，改成C2。S。最后我们是不是有两个S。应该写。是不是阿波罗think对吧，那我们搜一下AV RO，阿波罗的一个什么S啊，找到一个大标题，我们还去搜一下那个内容，哎，在这在这之后呢，我们从底下这不有案例吗？给他干什么。搂过来对吧，啊搂过来，从这C过来。好，这里边这个是绑定是吧，绑定我们先扔掉OK吧，好，阿波罗这个类型没问题，How'name。这个是哈多103对吧，这个是4142，注意看啊。

跟这个端口一样吧，他的尾1034142，我是不是应该把这个再干什么，复制一份，把这个K1改成K2，然后把这个三改成四，对吧，C就搞定了，最后还有一个什么。绑定对吧，绑定绑定呢，我们也从这个地方拿一下CTRLC给他拿过来。往这一放好，那接下来我们应该想一想，这个地方怎么绑定了，R1这个地方要绑定什么。是不是C1跟C2啊，是不是绑定两个，因为CC2是不是都从R1里边来获取数据的，没问题吧，所以呢，他要绑定两个，但是这个地方K1。怎么绑定绑定C1K2呢？绑定C2，他们俩是直接这样没关系吧，好，那这里边还有A3没改，是不是把A3改一下，A3改成什么A1，哎A2啊，我们这个是负二啊，就叫A2OK吧。哎，这个ae也要改一下吧。

好，A1呢，也改成a replace。哎，这没改呢。A3。好，现在好了吧，这个是基本的一个配置，如果说我现在就让他跑起来，它会是什么样子。是不是以副本的形式默认的一个策略，对不对，对吧，默认的策略好，那现在我们要去配China选择器，对吧，那这块加一个井号叫China。Select select，对吧，China选择器，那我们把它搜一下对吧，China选择器还是同样的，从官网当中我们拿一下叫China China选择器，OK，在这。来把这个东西给他干什么？这是不是要对的，我们不要吧。是不是把它复制过来。

给他拿过来吧，这个前面的定义，我们是不是定义了两个就不用这个前面定义了，好把它往这一放，那我们要改一改了，马要改吗？不要这个要改吗？要改成什么？是不是table，注意是跟哪，是不是跟这个地方对应的啊，要跟这个地方对应，我们说的就是这个事，好接下来麦这要改吗？是不是要改啊，那我把它改成什么？I硅谷这个地方呢，Big data塔对吧？哎，Big data啊，硅谷大数据好，一个是C1，一个是C2，我们并没有定义什么C3。没问题吧，好，那这块呢，是我们定义的什么。China选择器，这个等会我们一块改啊，因为还有一个拦截器对吧，好，那我们再把拦截器配井号，拦截器叫intercept对吧？Intercept找到这个intercept一个什么配置文件。

点。嗯，应该还是不要点加S在这对。是那种在这吧，啊，它这个配法，那它这个配方我们是不是直接给他看什么。拿过来对吧，好，我们拿这个，嗯，其实随便啊，我们要的是这些东西，我们只有一个吧，一个呢，就拦一下它就行。因为下面有两个是吧，有两个，我们有一个。看到没？这个一行我缩小一点，这个就简单的一行对吧，那我们是不是只有一个L2就不可以给它干掉啊，蓝截系列就刚才你写了一个L2，就会是形成拦截训练，而且它这个调用顺序就是A1L这种顺式啊好，那这个是不是要改一下。我们选类名是不是给他拿过来。然后呢，给他。

看到没啊，替换掉全列名后面build这个东西是不是跟我们进单内部类是一样的。没问题吧，啊叫的你要注意我说了，如果你这个地方随便取个名字，假如说你取了班长，对吧，你取了班长。好吧。啊，反差可以取是吧？行，那build如果说你取的名字是班长对吧？啊，这块就要写什么。你选了班长，你就属于班长了是吧，你就得写班长在这对吧，是这意思啊，然后呢，A1要改一下吧，啊不要忘了把这个A1改成L没错，OK，那所有的一个配置信息就已经干什么。搞定了啊，就一定搞定了，那我们捋一下，其实我们跟之前相比增加的就是。这个东西吧，一个拦截器一个什么。选择器啊，其实选择器我们之前也用过一种叫Y配KT对吧，只不过说它是默认的，你写不写呢，无所谓，因为它是副本，它是副本机制呢，你只要配一个副本机制，那我大家都发，需要像这样，我某一种日志发到这，某一种日志发到这嘛，不用因为副本大家都一样的，对吧？啊所以呢，他马PL这种呢，它会比较麻烦一点啊，会比较麻烦一点，这个意思好TRL做一个保存。