00:00
接下来我们就使用spring boot整合一下rabbit MQ来测试一下它里边的交换机队列绑定关系以及收发消息等各种功能。那要整合rabbit MQ spring boot呢,已经抽取了一个场景启动器,叫springt start am qp高级消息队列协议的这个场景启动器,那么只需要在我们的项目里边引入我们这个场景启动器,那就可以快速的使用我们rabbit MQ相关的功能。好那么现在呢,就以我们的订单服务为例,我们之前写完购物车,那现在呢,该写订单了,来到我们这个订单里边,我们直接在他的po文件里边来引入我们的高级消息队列,我们这个场景启动器,好,我们就叫amq paq PA,我们start amqp模块把这个版本号呢来删掉,那引入它以后,我们就可以来测试使用我们的re MQ,那想要测试我们的步骤是这样子的,首先我们来第一步,我们现在呢引入了。
01:00
我们的这个场景启动器好,在这儿来写一下,第一步我们引入了AMQP,咱们这个场景,这是我们要用的,第一引入我们amqp场景,这是我们这个使用rabbit MQ,使用我们这个rabbit MQ,那只要引入了这个场景,那就会有相关的自动配置,来看有没有相关的rabbit rabbit,相关的auto configuration,诶我们发现呢,这就有一个这个自动配置,所以这个自动配置呢,就相当于生效了,来点过来,只要我们引入了这个场景,这个东西就会就会自动生效,那这个一自动生效以后呢,我们再来看一下,它会给容器中放一些什么。这一块呢,会给容器中来放一些连接工厂什么的,这就是来从里边获取连接的哈,那再来往下边翻,我们翻译呢,它还会给容器中来放一些组件,第一个组件叫rabbit templ,然后呢,第二个是am qp me at b都是给容器中放组件,还有我们这个an b rabbit message complete,所以呢,我们接下来就把这几个组件我们拿过来,它会给容器中自动放入一个,哎,给容器中自动配置了,给容器容器中自动自动配置了。
02:22
我们的这些组件,Rabbit tempilet,还有我们的这个rabbit,我们这一块有一个amqpin,那这些组件是干什么的,我们一会儿再用,还有我们的这个连接工厂,那肯定最重要的就是这个连接工厂了,我们要连接re MQ,肯定要从连接工厂里边获取连接好,它还放了这么一个连接工厂。等等,还有它的一个下边的这个rabbit message templ,好,这些的用法我们后来再说,那么现在放到这,那接下来我们要做的就是如果我们引入了re MQ的场景启动器,并且呢,我们给容器中自动配了这些,我们想要使用MQ的功能,我们只需要一个注解,叫enable enable rabbit这个注解,我们enable叉叉叉相关的注解已经非常多了,我们之前呢,都用过非常多的类似注解,所以在spring boot中开启什么功能都是这个注解,比如我们以前整合了spring enable hdb session red的那个注解等等等等我们各种功能,那接下来我们就来测试一下我们rabbit MQ的使用,我们来到单元测试里边,那么整个测试呢,我们还是按照我们之前的逻辑,我们可以先来我们看,我们之前呢,是在我们的web管理界面,我们创建了一些队列以及交换机,并且给交换机绑定。
03:46
定了一些关系,那现在我们来看如果用我们的Java代码该怎么创建,所以呢,我们先要在要测试的功能集中在这几个方面,第一个如何如何创建我们这些交换机exchange以及队列,并且给它们来绑定关系,诶我们绑定关系呢叫帮定,我们看如何创建他们。第二个我们再来测试如何收发消息,我们这样测试通过re MQ就能使用了。好,我们先来看第一个如何创建我们这些交换机队列,绑定关系等等。那这个东西如何创建呢?我们有这么两种方式,第一种方式我们看到容器中呢,之前给我们会放一个组件,这个组件叫am qpdin,一听就是高级消息队列这个管理的组件,所以呢,它既然是能进行管理,所以我们就是使用它,我们可以来使用它来进行创建,进行创建,那么就来测试第一个来创建。
04:46
我们的交换机create X change,那交换机的创建我们现在呢,就来把我们这个amqp admin拿过来,因为它都是自动配置好的,所以我们这个amqp adin组件拿来,拿来以后呢,我们来owa来进行自动注入,那接下来调用它的方法就行了,但是大家现在考虑,那既然要调用它给我们rabbit MQ里边创建一些组件、消息队列等等这些东西,那么必须连接上re MQ,所以跟re MQ的一些连接信息,我们就得在配置文件里边配置,那这些连接信息都在哪呢?那re MQ的自动配置是我们这个类来找到这个类好。
05:31
Rabbit auto configuration就是我们这个类,然后呢,我们来看所有的连接信息,Control hope,我们在这呢配置连接工厂,连接工厂呢,我们看连接工厂呢,会从我们这个properties里边找到所有的连接信息,所以我们这个连接信息就在我们这个properties里边封装着点进来,Properties里边相当于我们要配置MQ的这些连接信息,需要配置以他们开头的所有信息,他们都是在这个类里边进行了属性绑定。
06:03
那接下来我们就在这儿自动生效,给容器中自动配置了,它们还有呢,所有的属性。所有的属性,所有的属性都在这儿来进行绑定,所有的属性都是在这里来绑定的,所以呢,我们只需要配置我们这一块,所有属性呢,我们都是以他们来开头就行了,配置他们相关的信息,所以我们就直接来到配置文件里边,想要用我就来配置,我们将所有rabbit MQ我们就配在这个properties里边,也比较好看,来写第一个点一个host主机地址,那现在呢,Rabbit MQ装在了我们虚机里边,所以我们只需要指定我们虚拟机19216856.10这个地址,然后呢,我们再来指定是不是点一个我们这个re MQ,我们说之前呢,有一个概念叫虚拟主机,还有它的端口号,默认56725672是我们高级消息队列协议工作用的端口,也是客户端要连的端口,我们就来指定它,然后呢它呢,之前有一个概念叫虚拟主机,我们看到我们的这个界面里边。
07:10
我们现在的所有虚拟主机默认呢有一个叫杠,所以呢我们需要在这来指定杠,现在我们连接上我们这个虚拟主机,剩下的呢,我们就不用配置了,因为好多东西呢,它都有一些默认的值,全部在这儿,比如账号密码跟我们之前的账号密码,这都是默认的,所以我们就可以不用配置,那接下来我们就可以继续来使用,所以说re MQ引入了场景启动器啊,然后呢,给容器中它自动配置了,它我们只需要呢给我们配置文件中第三步给配置文件中至文件中我们配置,配置什么呢?配置这些开头的所有信息就行了,配置这些信息,然后呢,最后一个我们来开启re MQ的相关功能,那我们就可以直接来使用rabbit MQ了,Enable,我们叫rabbit,好,来第四步,我们要开启这个功能。
08:08
功能,然后呢,接下来我们就在下边来测试使用,我们测试使用的第一个是来把amqpdin这个组件拿来,我先来看如何创建交换机队列绑定,行,这交换机队列绑定的创建,我们下一节课再做,那现在呢,前提的整合们先把这些配置都写好,我们整合完成。
我来说两句