00:00
好,接下来呢,我们来看一下第三张卡夫卡和spring BOO一个集成,那这里面呢,Spring boot作为生产者把数据呢发送到卡法集群,诶同时呢,资也作为消费者来消费对应的某一个主题的数据,好,那还是老规矩,我们先做一下资作为生产者把数据呢发送到这个topic里面。那跟以前不太一样的地方是什么呢?这个BOO生产者呀,哎,我们外部的数据呢,是通过接口的方式发送到这个命程序,然后spring BOO接收到这个接口的数据,然后再发送到卡马集群,哎,这样进行一个操作哈,行,那下面呢,我们还是在idea里面安装一个插件啊,那这个插件是帮我们干啥的呢?它主要来快速的帮我们生成一些get set方法的啊,类似这些加快我们的一个开发步骤的哈,那我这里面已经做完了哈,那给大家看一下。打开这个塞ing,塞ing词里面有一个插件,那插件里面呢,哎,你输入对应的像这个lom BOK。
01:05
哎,这里面你看我这呢已经是安装完毕的,那这里面显示呢是灰色的,哎,如果你第三装的话呢,这块需要点击啊install安装,然后之后1OK就可以了哈,行,这是第一个插件啊,加快我们开发的一个速度啊,当然你不安装啊也是可以的哈。那下面呢,我们是创建一个密的程序好。打开之后file另一个project。那这里面呢,点击这个什么,点它点它之后,然后点击next。好,那这个地方呢,哎,输入对应的像com点艾特硅谷,那我们这个程序呢,是spring的程序。啊boot程序,那spring boot程序当中,我这个呢是spring boot杠哎,卡不卡跟卡不卡相关的一个集成操作。那这个11呢,这地方要改一下,哎,我们改成这个加油八啊好N,那下面呢,这块呢,我们要添加啊一些这个需要的一些依赖啊,那这个什么部塔比以前呢要呃方便一些哈,不需要你自己在这个泡沫文件里面去添加了,直接在这页面里面,比如说诶勾选哎这个刚才选的这个插件,那自动的就会在那个泡文键里面帮我们进行一个生成啊这是第一个,那下边呢还有一个是spring。
02:23
这个啊,Spring web点击它,那这样呢,这个呢是帮我们哎集成了内部的一个toca啊,那再往下找到这个MYS啊,那这里面由于我们操作的是卡普卡集群,那所以呢,这个spring啊,需要跟这个卡卡进行一个集成,那好,那这样这三个依赖我们添加下来,一个是工具相关的啊,一个呢是汤姆KD相关的,另一个呢,是跟卡普卡相关的依赖,哎,都倒过来了,然后点击next。好,那这个呢,我放到这个PROJECT2里面。OK finish。放箭。OK。
03:02
啊,这样这个实名布的程序啊,哎,我们就拿到了啊,就非常简单是吧?哎,这个就OK了,那这个OK之后呢,你可以先看一下这个抛沫文件里面,你看在刚才我们那个页面里面选择了对应的像这个呃,Spring卡不卡啊啊还有这个插件啊啊以及相关的一些操作啊这里面呢,自动的帮你进行一个啊导包啊导过来了,那导过来之后呢,下面我们开始写代码,那我们要写一个什么代码呢?哎,这里面都有啊。下面呢,我们要写一个卡不卡的生产者啊生产者。那么生产者里面,我们首先得有一个类吧,哎,创一类,那这类呢,我们就叫这个啊,Producer controller啊,Controller。那这块呢,我们可以先创建一个controller包啊。全抽了。好创建之后呢,在这里面我们创建一个类。那这一类呢,就是producer controller啊。那在这个CTRL里面,哎,我们先导入一个注解啊,Rest。
04:03
全抽了。呃,这里面由于啊,我们不需要跳转到其他页面,哎,只要返回一个正常的金串就可以了啊,那那这里面呢,我们需要哎创建一个方法啊,那什么方法呢?哎,PA。Stay。Date,哎,专门来处理外部发送到这个controller里面的数据,诶我们进行一个接收,那接收呢,是这个啊string。啊,Message,那这里面。接收到这个数据之后,诶,我们呢,通过这个卡夫卡发送出去。通过。卡卡发送出去。那么外部怎么能访问到这个方法呢?那这里面再引入第二个注解,那这个呢,就是这个啊叫request。第二,注解request。麦品啊。接收外部的一个请求,那这里面我给一个对应的地址,那这个地址呢,就是对应的叫,比如说我们给一个叫艾特硅谷,哎,他访问这接口就可以把数据发送过来,那我们就可以接收,接收之后诶,我们通过卡卡往出发,那最后呢,这块有一个return。
05:13
一个OK。那这个卡不卡,我们是不是需要一个卡不卡对象,那这里面我们需要一个卡不卡对应的一个参数配置啊,那比如说呢,是卡不卡模板。模板,那这里面有对应的这个KV类型,比如说你传入进的数据的KB类型,那K呢是实际类型,Y6呢也是对应的实类型,那这呢就是一个卡卡,那这个卡卡对象,要不然你自己用或者呢,你可以通过注解的方式,自动的帮我们进行一个注入啊。凹凸。那。这样就OK了。那自动注入之后,哎,我们需要呢,这块拿过来就可以调用它进行一个散的发送了,那把谁发出去呢?哎,你看一下这里面的参数。这一个呢,是对应的topic主题,那就给他一个for主题,下面呢,就是发送的对应的这个数据,那就把哎外部。
06:08
传过来的数据我直接就发送给对应的卡卡集群啊,比如说通过这个接口接收外部的数据,然后呢,通过这个方法往外进行一个发送,哎,发送到卡普卡,好,那下面呢,我们需要干什么呢?哎,你想我当前这个代码跟我们的卡普卡集群有关系吗?你能找到对应的卡法集群吗?至少得有一个boot slo server吗?目前还没有,还有对应的像key的序列化和Y轴的序列化,是不是也没有配置啊?哎,那好,那这个在哪配置呢?记住它是在这个对应的叫,诶这个里面,Application purpose啊在这里面。那在这里面,那怎么配呢?比如说我们首先配一下对应的这个,呃,连接卡巴机群。啊嗯,你打一个这个boot stop serve哎,你看一打就来了,对吧?哎不t server,那这个boot server你需要给上啊,Hi doop1029092,然后再来一个hi doop1039092,哎这儿呢,就连接上了,那连接上之后,下面我们还需要配置的就是对应的叫。
07:10
K的序列化和Y轴的序列化。哎,T和Y流系数化。那我们打一个什么呢?哎,打一个K杠啊,序列化SE啊啊这就来了啊K的序列化,那K的序的话呢,这里面我们需要导入对应的这个词缀类型。序列画包,那这些拉花包啊,不好找,不找什么,哎,回到这里面啊。给你找一下。子俊序列化啊,进来之后呢,哎,点进去点进去之后copy它对应的这个全列名。哎,Copy背靠背回来之后,然后往这一放。哎,这样就可以了哈,那下面我们再来一个这个Y6的系列化杠。学生化,然后把刚才这个全列名啊,一粘贴这样就可以了,把这个呢给它删掉,你看。
08:02
这样就可以了,那这个呢,整个这个生产者的程序我们就写完了,那我们来测试一下好吧,那我需要把这个数据发送到卡卡集群,那我是不是得创建一个消费者,方便我们进行一个测试啊。好,那我们来一个卡卡的消费者。变卡不卡?很臭。嘿,小尴尬不?Stop。Server。HIOP1029092。杠杠。Topic first消费first主题对应的数据。好,那在主设的哈,那下面呢,我们来启动一下对应的这个程序走。那这个程序启动之后,下边呢,我们需要往对应的这个接口里面发送数据,那怎么发呀,哎,拿过来。
09:02
拿过来之后呢,Local host。8080好。爱的圭吾。Message等于。哈,走。刚才你那边一发送啊,这边呢,就已经能够正常接收到了,那就说明这个STEM boot呀,跟这个卡巴卡集成就已经完成了啊,那这程序呢,非常非常简单啊,但是呢,在企业里面用的呢,是非常非常多的啊,大家呢一定要会啊。
我来说两句