19、消息-AmqpAdmin管理组件的使用.avi原创

好，前面呢，我们测试了一下这两个注解，但是我们说不管怎么测试，我们的前提是我们rabbit MQ中的这些消息队列，包括这些exchanges我们都已经创建好了，那如果没创建好，我们程序中要怎么去来创建这些呢？我们就可以使用一个组件叫am qpin，因为后来我们经常要使用程序临时的创建一些啊exchange交换器，绑定规则，或者创建一些消息队列，那么呢，就可以采用它，它帮我们呢创建和删除。是删除我们的这些困啊，我们这些消息队列，包括呢exchange，我们这些交换器，包括呢这些绑定规则，好我们呢，就在这个测试类里边来测试一下。我来注入我们这个amqp，我们只需要一个O，对吧，因为这是我们rabbit的自动配置类里边rabbit。

Auto configuration这个自动配置类里边给我们注入的一个组件，啊，这是一个系统管理组件，我们尝试呢，用它来创建出我们这些消息对列等等，好来create，好，我们先来创建出一个exchange，我们先来看怎么创建exchange，那我们这个am qpin里边它有一些方法，凡是以列开头的都是创建一些组件，那么。相反的就有一些remove remove以及delete，这就是删除一些组件，好我呢先来创建一个exchange，我们在这创建exchange的时候呢，我们要传入一个exchange对象，那么这个exchange我们来搜索一下X exchange，好，这是我们AIQP里边的一个接口，这个接口下边呢，我们有很多的这个实现，有一个抽象的exchange，比如我们要创建哪种类型的exchange，是要direct类型还是final，还是我们topic，还是had，还是我们自定义的这个exchange，好那我们呢，就来以direct为例，我们就可以在这写一个用一个direct exchange好，我们创建这个exchange的时候呢，来点进来，我们可以传入一些规则，比如我们这个exchange的名字，它是否是持久化的，是否是自动删除的，好，我们我们默认就来传一个名字就行了，好。

我们呢，就叫我们这是用amqp的命管理工具创建的一个X change。好名字呢，就叫它这个创建完了，我们在控制台来输出一下，哎，创建完成。我们来到我们的这个exchange里边，我们来先来看，默认呢是没有我们这个的，我们在这儿创建一下运行。

好，我们发现呢，它运行成功，我来在这刷新，刷新以后呢，我们就会看到我们这个am qpdin exchange，我们已经在这儿创建有了，那其他的这些创建呢，都一样，比如我创建了一个exchange，好，我除掉，我再来创建一个am qp butin点我来创建一个队列，哎，这有queen这个创建呢，不传名字的情况下，它是默认随机给一个名字，我们也可以定义一个我们自己要用的队列，这个队列呢，我们是QUEUE，我们这个昆它呢是一个类，不是接口了，那我们就可以直接来拗拗一个昆。好，创建队列的时候，队列的详细信息呢，我们也可以传进去来点进来，哎，可以只传队列的名字，也可以传我们队列的名字和是否持久化等等等等，很多种构造器，那就选用两个的好，我们呢就可以叫AMQP，我的命两困，那么队列的名字呢，就叫它，然后呢，它是否是持久花的好，那写一个处好，这呢是创建一个队列，我来运行一下，看们这个队列能不能创出来。

好，这个运行成功，那队列肯定是创出来，我们在这儿查询一下AAMQP困这个队列呢，有没问题，那队列创创出来以后呢，接下来我们。需要将exchange和队列绑定起来，所以呢，我们可以来创建绑定规则，这么一绑定呢，我们就能使用了，好，那我们可以用amqp me.declare什么呢？这有一个帮顶，好这个帮定呢，我们来搜一下，这叫帮顶，好这个帮顶呢是AMQP中的一个类，那我们就直接来拗拗一个帮顶。

New一个帮顶，而new的时候呢，来看传哪些参数，第一个呢是我们d nation目的地，第二个呢是我们这个目的地类型，这个目的地类型呢有两种，你是要绑定一个消息队列，还是绑定一个啊交换器，然后呢，接下来我们在这里边来写交换器的名字，还有咱们这个路由件，包括呢，我们有没有一些我们这个参数头信息，好我呢就在这直接来写我们的这个绑定，来先写上第一个destination目的地，目的地呢，我们就。发布到这儿，哎，我们来绑上这个AMQP，而这个类型呢，我们就是来绑定的是一个啊队列好来写上一个队列，然后还有一个信息。哎，第三个信息呢，是我们这个exchange的类型，我们给哪个exchange来绑这个队列好exchange exchange的名字呢，就是我们前面刚创建的这个exchange，好我们再来看第四个数据，第四个数据呢，我们这个呢，ROK，我们这个路由件，好我们来写一个路由件，我们是根据路由件来规定发布给谁，这个路由件呢，我们可以叫amq。

P点我们就叫哈哈吧，好随便来叫，然后呢，接下来还可以传入，呃，我们是不是要我们这些啊参数，哎，传一个慢步的这些参数好那呢，如果没有我就直接写一个呢。好，这个呢，我们就声明了一个绑定，那我先不运行，不运行前呢，我们来看这个exchange，它里边呢，默认是没有什么绑定规则的，好我们来运行一下。运行。来我们发现呢，这个绑定也是成功了，我在这呢刷新一下，哎，我们看到呢，这个绑定规则已经显示在这了，哎，我们这个exchange绑定了我们AMQP它的路由K叫他，哎我们可以在这解绑等等，那相当于我们用这个AMQP的命就能操作这些东西，当然这是绑定类似的对应就有相关的删除操作，大家呢在下边就来写这些删除就行了，比如delete只需要写名字啊，包括呢delete这些东西大家来一一尝试。