00:00
好,那接下来呢,第一步我们先安装一下这个neca工具,其实如果说你装的是这个桌面版的话,应该是自带的新版本好像是自带的,但无所谓,我们都装一下来对吧,它也不大啊,就刚才说的它单向真看,所以说呢,大家那个网速,嗯,大家的镜像是配的阿里云嘛,对吧,那就行啊,那就比较快啊,它其实已经就安装过了啊,都安装过了,现在最新版本了,对吧?嗯,正常你去装一下,那现在呢,我们就可以用NC了,其实刚才我们说了,它是做一个通信框架安人这的,嗯,大家经常看那个什么黑客是什么黑窗口聊天是吧。NC-LK,然后呢,我们往这个,假如说9999啊,选一个这个端口呢,一般也不会被占用,这个相当于就启动了一个服务端,然后这边呢,我们可以用nc local host监听这个端口,还是9999这个端口,对吧?好呃,注意一定要先执行这个命令啊,先连,因为他开的是服务端,服务端跟客户端通信,你客户端先开能连吗?连不了,就类似于你写的HDD,我NDFS没开,你HDAPI能运行吗?不能,因为你写的代码是属于一个客户端代码,对吧?啊,他肯定会报错,那比如说啊,这边我把这个干掉。
01:20
我这个停掉了啊,这边我在启动的时候,他干什么链接拒绝,因为没有开启服务端啊,所以呢,你要先开服务端啊,然后呢,再去看客户端,这个时候呢,他们俩就能通信嘛,对吧,我给你发一个hello,这边立马就能接受的hello啊,或者说咱们这样看啊,啊哈喽啊,这个刚才是从这边发的,对吧,假如说你好啊,立马就收到了,当然他也能给他回信啊,啊你也好是吧?啊就黑窗口类似于这样聊天,它是一个Linux系统当中一个非常轻量级的一个通信工具,通过这个端口来通信的,对吧?是这样东西啊,了解一下它就行了,行,那我们把这个CTRLC干掉啊,这是工具的一个演示啊,那接下来呢,我们去做我们的一个配置信息,当然五个四,端口说这个值是交易这个五个四。
02:20
那么有没有被占用啊,当然正常来说,其实系统不会用这种名字的,没有东西说明五个四端口对于我们现在是可用的,对吧?啊,就是你找一个没有人用的端口就行了,刚才我用的9999是不是也没人用对吧,所以才能啊好,那这个时候呢,我们去创建配置信息了啊,配置信息组就从官网上拿的啊,那我们进到一个啊,一般呢,我们那给大家一个照报目录啊,就放他的一个任务的配置信息的,在这呢,我VM那个或者说它是一个,它是个什么东西呢?我们要从这个端口当中获取数据,对吧?啊从net,然后呢,经过我们的浮中把数据传到我们的什么log,一般的我们的命名都这样。
03:06
就是贱民之意,就是告诉你,其实这当中呢,告诉数据源是一个端口,Net对吧,从端口网络当中获取的数据,数据think我们写的是什么log,一般的我们会把这个source和think写上啊,这名之意,当然这个名字你也随便取啊,你叫aa.com都行,这个无所谓。啊,但是呢,你A点康以后弗是不是可能会有很多任务啊,那你要看到这个东西,你也不知道是什么了,所以尽量的做到见兵之意对吧,做这个事情好,然后呢,我们拿这个来改啊,因为这样我们去看的更清楚一点。进到咱们的康复,诶不是康复是刚才我们所创建叫我对吧,然后进来,进来之后呢,把官方文档当中的原封不动的,我给他拿过来,对就复制就好了,这个对于这个框架呢,就复制粘贴,但是呢,复制过来之后,我们得知道里面有什么东西,对不对,对吧,好第一个。
04:08
看它分为这几部分对不对,对吧,分成好多几部分,第一部分。他说给当前这个A的去命名组件。相当于你在写代码的时候先声明变量对吧,里面呢有source think China分别叫R1 C1,而且大家注意到啊,这个还有一个A1对不对,这个A1呢,是当前A正长的名字。A的名字就是当前进程所需要的那个名字,呃,那这个名字呢,你也可以随便取,但是如果你在同一台的机器上面起多个A点的,注意名字要不一样。对吧,我一个form room,我可以采集Hu的日志,我可以采集哈多日志,我可以上传到IDFS,我可以打印到控制台,我是不是可以放到两个不同的任务里边,那么两个不同的任务呢?这个名字要不一样,一样的话第二个任务就起不来,他会告诉你那个名字已经被占用了啊,就相当于定义的变量要干什么。
05:15
要唯一啊,这个A的的名字啊,是在单台上要唯一,而这个名字呢,假如说我再有一个配置文件,我取名这个名字叫A2了,这个名字就可以干什么一样,因为相当于是两个不同的类,我定义两个属性一样的是不是可以啊对吧,就相当于它是内部变量。能懂意思啊,是这样的关系,同时大家应该还要注意到一个点,这边怎么样啊?有S说明什么问题,可以配多个,就是一个ad里边我们可以配多个,刚才我们是不是介绍了一个A接收某一个系统的采集日志,然后将数据通过两个不同的China发送到两个不同的S里边,对吧?这是一个整体,是一个A,如果能实现这样的话,你是不是要配两个China,两个C,对吧?但其实这边告诉我们了,能不能配多倍。
06:12
可以吧啊,因为他加了S啊,加了S可以配多个对吧,这生品组件,那么接下来这三块内容你看一下啊。它是描述信息的,这是source的配置,这是什么?Think的这个呢,是China的配置,相相当于上面是声明,下面是具体的给它干什么赋值对不对?声明变量,这是赋值变量,三个组件分别赋值,那第一个我们source刚才不说了,我们要兼控端口数据source它要配什么tab类型来看,诶,然后绑定的机器本机五个四探头对吧?啊,当前机器上五个四端口,然后think的类型我们配的是什么log,然后接下来还有一个China China类型,默认的就官方文档先,首先用的是什么memory,好,那么接下来还有其他两个参数,一个呢是什么容量,就当前差照的容量,这个1000你看这啊。
07:16
时间1000,最多放1000个,时间多了就放不下了啊,然后还有一个这个是什么,也是一个容量,Transaction事物,事物的容量对吧,事物的容量,因为他在source跟China通信,China跟通信,它中间启用了事物。啊,它中间会有事物防止数据丢失嘛,因为事物如果说失败,它是不会回滚的,对吧,防止数据丢失,好,那这两个容量你看一下,它为了1000,他为了100,那我这个地方配1万,这个地方配1000,大家想一下行不行?这个事物的容量就是单个事物你最多能发送的数据条数。
08:03
对吧,如果说事物的容量大于你的memory整个的容量。也就是我一次性最多可以传1万条数据,但不好意思,你恰恰告诉我只能接收1000条,那肯定不行,对吧?所以配置的时候,事物的容量一定要比这个什么总容量要小,因为事物的容量呢,指的是。单次发送最大的多少个事件?就是一次性,我从SS里边可以最多给你传什么100个事件过来,它可以批量传输。啊,那如果说我配置的是1万,就是最多我一次一万一万条,那你这边干什么。China最多只能接受1000条,是不是容量,那肯定不行,所以说这两个配置注意一下要受的容量要小于什么总容量啊,China的总容量啊,这里OK吧,好,那最后还有一个。
09:00
这是and south and sing to the China,就是说将south跟S跟China给他干什么?绑定起来啊,就是说那大家想一下,为什么要绑定呢?为什么其实所谓的绑定就是说他们俩关联,因为刚才我们所说的它可能存在这样的例子,那如果说没有绑定,没有绑定,那这个C到底去。接收谁的数据呢?是不是就乱了呀,对吧,所以呢,要绑定,哎这个假如C1,这个是K1CHINA1对吧,这个是K2,这个是C2啊那我们要干什么,把S2跟K2绑定对吧?把S1和K1绑定对吧?做这个事情,要不然数据不就乱了吗?对吧?啊做这实验好,那我们看一下,就是说现在呢,我们三个是不是都只有一个呀。S China这都只有一个呀,那就把这个流给它串起来就好了呗,对吧,是这个意思,所以呢,绑定的时候aa1.s里面的R1,我们绑定了什么C1K1THINK对吧,我们也绑定了C1。
10:07
那是不是相当于south China think就看起来了,对吧,而且注意大家还观察一个这个东西。什么意思?一个source可以绑定多个钱能,就是我一个source可以将数据根据图信息发送到哪啊,不同的China里边,但是这个地方没有S。一个think只能绑定一个才能OK吧,因为官方文档告诉我了,有加S,加S肯定是负数嘛,就可以多个对吧?啊也就是说刚才我们的架构可以这样好,对吧,我一个source发到两个China没有问题,因为这样告诉我们了,但是。假如说我只有一个S,我能这样吗?这个不行啊,对吧,因为告诉你了一个S只能绑定什么一个China啊,这是它的用法,好,那CTRLS做一个保存。
11:02
啊,这里面其实以后的配置信息,无非就是哪块东西在换呢。这三个东西你用不同的类型,得用不同的配置,对吧,你用的是I,那你就遵循I的配置,你用的是fair China,你遵循配置对吧?是这样的一个东西,就是说无非就是照着官光档去改这几个组件就好了,改这几个地方好,那我们保存这个配置信息就已经搞定了。
我来说两句