39_尚硅谷_Flume高级_自定义Sink（代码实现）

好，那接下来呢，我们就来写代码了啊，就不用看这个文档，直接到这来了，我先把它呢，全部给它干什么。掉啊，这个代码呢，你也不用重新去导那个什么。依赖还是from ing吧，啊，还是在这啊，所以呢不用，然后呢，我们建一个新的class啊，这个class呢叫single包底下来一个什么卖啊。好，他要继承一个内容，实现一个什么内容，对吧，我们直接从这拿一下吧，啊直接从这拿一下。切成一个抽象的一个接口。然后呢，继承一个实现一个什么。好，Out加回车实现相应的方法两个，一个con对吧，一个是process读取配置文件的，一个是。Process来处理这个事件的，那正常的这个先走吧，我们把它干什么啊，提上来啊，这样好看一点啊，因为我们大家看了是当时我们在自定义这个sources的时候，就发现了，是不是先走里面内容，他先去获取配置文件，然后在这里面去用了，对吧？啊，所以他他先走，我们把它放在前面，呃，那同样的先有前后缀，我先给它定义好可以吧？啊，因为我们知道就这个时候就不像之前那个写代法了，我们就按照这个顺序来写了啊定义。

两个。属性。啊，是我们所说的前后缀对吧。后缀。然后。等于一个那啊或者说不做那个赋值也可以吧，啊，不做它这个初始化好，然后CTRLD复制一份，再来一个什么S对吧？啊，一个前缀一个后缀啊前缀后缀好，同样的在这个里边应该去给这个前后缀读取配置文件，给前后缀赋值的对吧？啊叫读取。

配置文件给前后缀什么？赋值啊，前后这个赋值OK，那prefix。等于我们所说的context.get c啊，同样的前缀呢，我给它设计成呃，不带默认值的。可以吧啊，不带默认值，直接来一个free fix，好CTRLD再来一份，把这个sub fix放在这，放在这，这个呢，我给它来一个默认值，对吧？啊叫爱的硅谷可以吧啊给他来一个默认值，也就是说这个属性呢，就是有没有默认值可以这样来添加的啊，这样来添加的好这两个东西呢，我们就快速的去定义好了啊定义好了那这个里边就是我们所说的。要做事情了。对吧，哎，把这个。这个先返回什么后行，我们先不管，那第一步要干什么事，还记得吗？

是不是获取China？对吧，从China。获取事物以及数据。数和数据吧，啊，然后。第三步就是发送数据了啊，发送数据了啊，这个啊，既然你获取到事物，什么开启关闭和提交我就不写了，对吧，正常，因为你获取到数物，你肯定要做一个事儿啊，那我们把它写一下啊，把它写一下，这个里面呢，我们说了等会呢，我们要用W附近那种方式去统一数据啊，就类似于我们直接跟官方一样，在后面来一个杠。D。然后加一个from，点什么root.logo对吧，等于in for逗号conso，哎，将ino日志输出到控制台啊，就做这个事啊，做这事不是直接用Co啊，不是用C的啊，那无论怎么样，那个是处理是当前那个事件吧，我们先写核心逻辑第一步。

或许山的对吧，这写了。过去是不是直接看到的是get China get China OK，得到这个China。啊，得到这个China对吧，得到这个China，其实在get China之前，我们可以先把这个东西做一个定义，是不是对吧？啊定义这个状态第一步，假如说这个叫第二步。定义。返回值啊是一个。Status status等于个什么？那跟官方文档写的一样的China，然后接下来从China里边去获取事物，是不是从China？获取。Show china.get transaction看加倍啊，得到一个事物，得到一个事，那事物得到了，接下来。

是不是开启十啊，开启15啊。Stop。然后接下来第五步。应该是去获取数据了。是不是从。China获取数据啊，具体的数据啊，那这个东西呢，叫China点。T。对吧，啊，我们看到take返回值哦，Ctrl out加V，得到的是一个一个的even，然后接下来第六步叫。处理事件对吧，处理事件。啊，处理时间OK，处理时间呢，我们说了是打印到控制台，我们先把这个空着啊，因为这个是业务逻辑对吧，我们把架子先搭起来，那第七步应该是提交是不是。提交事务，提交事务应该是这个transaction。点科好，那在这个过程当中，处理事故过程当中，这一块是不是有可能会。

发生异常，发生错误啊，对吧，我们是要对这块进行开的啊，进行圈开，那我们今天说了有怎么样一个。这块呢，可以用一个快捷键ctrl out加T，可以直接try catch。Try catch啊，Try catch最好呢，是这样，Try catch finally吧。在这里啊，里边呢，我们做些事情好，呃，那这一块是不是成功了，成功了我们就要把这个状态改一下吧，这等于什么。Q，点ready对吧啊，你可以接着干什么接收啊，你可以接收接收啊，这个呢，我们改一下叫成功。提交。修改。状态信息对吧？啊，因为之前我们定义的是不是就那嘛啊，定义的是个那啊成功提交了啊修改这个信息，好，这边抓到异常了，这个异常呢，我们正常的这个是等一嘛，无所谓啊，这个就不干掉了，好第九步我们写一下应该是提交。

失败了对吧？啊，无论是提交失败，还是说中间其他的一个内容，什么失败了，我们都去干什么。回滚啊，提交事务失败啊，提交事务失败，OK，那这块呢，是回滚是拿着这个transaction点。Back对吧？啊roll back回滚，然后同时修改状态为。对吧，修改状态。啊，修改状态。然后这个地方呢，是我们所说的status等于。Status连back off对吧，啊back off把这个来修改一下，最后我们为什么还要写一个finally呢？因为你这个事物开启了之后，要给它代码关闭一下啊，关闭一下我们做个判断啊，这边呢是一步。

最终干什么，关闭当前的事物啊，关闭事物，也就是说if这个transaction，如果说它不等于什么，那啊防止空指针嘛，就都写一下，像那种关闭的时候对吧，Transaction点。对吧，啊，给它关闭一下，给它关闭一下，哎，这个地方。这标黄了，不用不用判断，不不闹什么it always true啊，因为前面已经开始了，已经开始了，已经你获取到了，所以呢，嗯，它不会被闹啊，不会被闹，所以呢，你就不用判断了，这块呢，直接可以去关闭啊，就是关闭那这个最终返回什么。返回。状态信息对吧，状态信息OK，返回的就是status。这。Status啊好，这一块呢，是我们核心的一个。步骤吧，啊，核心的一个步骤是这个意思，也就是说现在我们所写的是不是跟官方文档提供的很样的，对吧，只不过说我们比他多了一个什么在那里啊，把那个事关闭一下，因为它写的是一个室内代码，最好关闭一下，OK，那关闭完了之后我们还少哪一块啊。

业务逻辑对吧？OK，那这块呢，我们要用到之前所说的那个log这个方式来翻译。啊，Logo，首先无论怎么样，我们是不是应该把里边的。给他获取出来。这没问题吧，因为body才是我们要的实际的什么数据，对吧？好，那获取这个body.get body，发现它是一个资金数组，所以我们只能干什么用一个，对对吧。有个。哎，怎么把E干掉了。好。这个东西呢啊，会得到我们什么body。啊，得到我们的一个body就是事件体啊，事件体，然后接下来你才能对这个事件体进行测试，对吧，正常的，如果说我们做测试，其实你。

C座行不行？可以，但是呢，我们这次不用C，我们要用logo的方式啊，Logo方式也就是说不用这个啊，这个可能太简单了，C，那logo的方式要干什么事呢？首先在外面你应该去获取一个love对象。啊，获取了对象。对象，那logo对象，我们获取的是log factor。Like for，我们就用这个，这个应该两个都可以啊，两个都可以颠。啊，这个里边，因为因为在这个里边他不让写代码，那我们这样，我们到这来写，写完了之后拿出去可以吧。刚才他不会提示了，因为它默认的这个类里面定义属性的，你不能掉方法对吧？啊，其实你掉了也无所谓啊，等我们写完了拿出去这块呢，你看。获取一个log对象。

这里面传一个class。把这个把当前类要传进去，当前的类是不是my think对吧？点什么获得了一个log项，OK，那我们把它呢干什么。提出去啊，提出去或者你在外面定义在里边是干什么，赋值也可以吧，啊还是叫private赋值，那这个log呢，就可以帮助我们像之前的框架里边看到的有的数据呢，诶打印到控制台，有的呢，打印到文件里边，对吧，而且呢，那个文件有它不一样，是不是from点那个log。你无论用多少天，他只有一个人转。你到今天看他是不是还是服用明了，但是汉文是什么？按贴滚动的，这个都是log服务器里边配的啊logo件，你可以改它这个配置文件，那这块呢，我们到时候再看一下，打印到控制台，好，那我们打印日志是到控制台也好，到文件也好，都要用到这个对象来看一下你们之前看到的那个什么，第八个info a是怎么回事，是指的什么意思来。

那我买那个箱。来调一个方法你就看到了。这个地方是因付，那将来这个日志级别，它就是音付级别的，那除了音付我们再往下走对吧。看到什么A，那通过你调A方法反应出来是这它前面就会是什么。L，那同样的还有。第八个。那至少应该还有一个warning warm对吧，那我们看一下是不是。Name is ww应该在后面，是不是有对吧？啊，所有的日志级别在这都能看见，它就是通过这种你调具体的是哪个方法，它打印出来的，前面都会加什么东西啊，假如说我们就用ino来打印吧，Body。啊叫ino啊，就要用in来打印啊，这样就OK了。啊，这样就OK了，就这种方式呢，就可以将数据打印到这个logo里边，至于打印到控制台也好，打印到文件也好，就看你配置文件怎么写。

啊，就看你配置文件怎么写啊，这个呢，就不是C，它不一定打印到控制台啊，C是不是一定打印到控制台，这个你可以让他打印到控制台啊，是可以不是一定。好，那这个东西呢，我们就给它搞定了啊，就给它搞定了。