00:00
好,那么接下来呢,我们继续啊,嗯,之前呢,我对这个东西是做的手动的测试,对吧?啊,也就是说我们自己去传这个代码测试的,那我们现在呢,把前面的东西给它打开。前面的内容给它打开,然后呢,统一的做一个测试,还是一样的,我们要先写这两个东西。对吧,呃,那这两个东西呢,也比较简单,因为它的数据啊,来源于DWD配置log,所以我只需要将这个谁啊。DWD层叫baselo APP,把前面这个东西拿过来,然后呢,做一些增加新的内容就够好了,对吧?这也能看出来我们多个任务之间是有绝对关联的啊。好,那这个呢,又经过一个APP。啊,这个就比较简单,跟我们之前看的UV是一个道理,对吧?然后呢,呃,弗Li APP到我们的卡夫卡,又写回到我们卡夫卡,这个呢,是我们的DM层啊好,那这块呢,弗APP当然就是我们当前这个APP了,叫U的jump detail APP,对吧,卡不卡呢,还是就是卡。
01:09
啊,就是卡巴尔这个服务,好,那我们就看一下我们要起的东西,ZK卡不卡,Log and,然后呢,More clock对吧,最后起步这是机群上的,呃,然后呢,之后是我们的。B2个对吧,好,那我们来取一下啊。服务得开全了。好,ZK点。ZK起来了对吧,然后卡不卡。好,那我们启动这个logo啊。
02:02
然后接下来呢,当然是我们的NX了,Log也起来了,卡普卡K起来了,对吧,然后呢,我们到这个OG Mo啊。速度。目录下跟这个走,这个呢,我们也查一下,起一个服务呢,之后我们都去查一下啊好,那N这个也起起来了,然后我们CD到G末r ta log里边。对吧,然后呢,我们去启动要启动这个。Mo啊,要启动这个Mo好,那在这个基础上呢,我们去打开一个。消费者啊,我们去开一个消费者,好,消费者呢,我们来到这来啊,拿一下消费者的命令。哎,这个不对,这个没有写那个。主题我得拿一下主题呢,在这儿DWDWM层的一个主题。
03:04
对吧,好,然后消费者给它打开之后呢,我们只需要启动这个APP2个对吧,以及Mo,我们来看数据啊来先是贝lo。把贝打开。好,趁着它开启的时间呢,我们把这个来命令写一下知道吧。这这样,然后积末2020啊,这边已经编译好了,可以运行对吧,告诉我们啊,行,那这边呢,运行起来了,接下来呢,我们把这个user jump也运行起来。但是呢,这个它程序并不像卡普卡程序那样。对吧,啊,不是卡尔,是Spark streaming程序一样,SPA streaming呢,它是VP处理,它每次会打印这个时间戳,而Li程序呢,不会,所以呢,我们只能人为的多等一会儿啊。
04:02
现在呢,应该差不多了啊,由于大家注意一下,由于我们的要求比较严格啊,我们的要求比较严格,而且我把mid呢,呃,其实增加了一些,我把mid呢。增加到2000个,如果说这个mid少于2000就20多个的话,那这个数据就更更少了,因为相同的mid比较多嘛,随机造的数据呢,就就很多对吧。好,那这边呢,我们就开始了,但是这个产生的会比较慢啊,会比较慢,大家要注意一下,因为我们的条件比较苛刻,它并不像我们手动测试,我们手动测试呢,都是奔着目标数据去找的,对吧?而我们随机造的,你想想看,它进入一次之后,它会连续访问很多页面,所以这个产生的会比较慢啊。来,我们把这个打开走。这边呢,已经打印这个success对吧,没有问题,好,那我们看啊这个。
05:07
先看贝log这边,贝log这边呢,也在疯狂的一个打印,对吧,大家应该看得见啊,只不过说看不清啊,可能现在滚屏比较。频率比较快啊,好,那这边等着你看这有三条数据了,哎,又多了几条,这个频率就会低很多了,没问题吧?啊,因为你看我们要求比较严格,第一呢,有一个十秒钟对吧,另外呢,还有这个呃,Mid它连续两次上一条文档,所以跟这边去比,那肯定数据量小太多了,你看半天呢,不产生一条。对吧,啊,可能好久才产生一条,那这个是正常的啊,它就应该是这样,因为要求比较严格嘛,就是过滤条件啊,比较比较比较严格一些,对吧?啊这边呢,又有一条数据啊,又有一条数据出现,对吧,所以呢,他应该是那种很缓慢的去打印。啊,特别缓慢的去打印这个数据的啊,才是这样的一个现象,呃,好,那这个呢,就没有问题了,没有问题了,对吧,我们把这个呢,去联调去测一下啊,去测一下,因为后面的我们会用到这个数据嘛,所以得测试啊,那一样的,我先把这个关掉,一定要先关它,把数据呢消费完啊把这里边的数据呢,统通的消费完,提交赛了,那下一次呢,防止这个数据的一个积压。
06:26
对吧,如果说啊,我先把这个贝斯log APP关掉啊,然后这边呢,跑了很久跑了很久对吧,那我下一次再启动Facebook APP的时候啊,由于我消费者组没有换。他是不是会一下子消费太多的数据,很有可能把我们这个撑爆了呀。对吧,啊,直接任务就挂掉,有这种可能性啊,但其实这也是给我们提供了一个压测的思路。对吧,压测思路你没必要非得说临时产生非常高的生成数据的速率啊,我们可以做什么事呢?我们可以先把这个数据写到写好到卡不卡对吧,积压积压好之后重新消费,那这样也是形成了我们link程序的一个压测,来看你link程序给多少内存对吧,给多少资源,那可以用这种方式来做压测啊。
07:22
啊,在你给定的资源的情况下看O不OK。能理解这个事儿吗?这是我们简单做一个测试啊,它并不难,对吧,刚才我说的那个压测的思路能理解吗?我们说的压测的思路O不OK啊。大家是都没睡醒吗?
我来说两句