rabbitMQ精讲系列第十八篇高级整合应用第一篇

在本章学习中,我们主要是和应用整合的。下面来看看本章我们主要内容:

公司主营业务:网站制作、成都网站建设、移动网站开发等业务。帮助企业客户真正实现互联网宣传,提高企业的竞争能力。创新互联建站是一支青春激扬、勤奋敬业、活力青春激扬、勤奋敬业、活力澎湃、和谐高效的团队。公司秉承以“开放、自由、严谨、自律”为核心的企业文化,感谢他们对我们的高要求,感谢他们从不同领域给我们带来的挑战,让我们激情的团队有机会用头脑与智慧不断的给客户带来惊喜。创新互联建站推出肥西免费做网站回馈大家。

整合spring AMQP和spring boot及spring cloud整合。以及在整合中需要注意及工作中踩过的坑。如同如下图:

rabbitMQ精讲系列第十八篇 高级整合应用第一篇

本文主要内容:

使用代码创建rabbitAdmin,通过rabbitAdmin操作MQ

本文是《RabbitMQ精讲系列》教程中的第十八篇 高级应用整合的第一篇。如果对RabbitMQ感兴趣的朋友,可以从第一章开始。

RabbitMQ整合Spring AMQP实战

在Spring AMQP整合中,重要的组件:

rabbitMQ精讲系列第十八篇 高级整合应用第一篇

RabbitAdmin类可以和好的操作RabbitMQ,在spring中直接进行注入即可:

rabbitMQ精讲系列第十八篇 高级整合应用第一篇

注意:

autoStartup必须设置为ture,否则spring容器不会加载类.

为什么要获取RabbitAdmin?

    RabitAdmin底层实现就是从spring容器中获取Exchange、Bingding、Routingkey以及Queue的@Bean声明。

使用RabbitTemplate的execute方法执行对应的声明、修改、删除等一系列的RabbitMQ基础功能操作。

代码演示:

添加pom文件:



  com.rabbitmq
  amqp-client
  3.6.5



  org.springframework.boot
  spring-boot-starter-amqp

rabbitMQ精讲系列第十八篇 高级整合应用第一篇

需要注意:

如果spring boot 是1.5.6版本的时候,rabbit的版本号可以使用3.6.5以上

如果spring boot的版本是2.1.x的时候,rabbit的版本号可以使用5.7.x

创建rabbitMQConfig:

1:先获取到ConnectionFactory.

注意:是amqp.rabbit下的。如下图:

rabbitMQ精讲系列第十八篇 高级整合应用第一篇

创建ConnectionFactory:

rabbitMQ精讲系列第十八篇 高级整合应用第一篇

2:获取rabbitAdmin的代码:

rabbitMQ精讲系列第十八篇 高级整合应用第一篇

注意:setAutoStartUp必须设置为true

进行测试:

因为在RabbitMQConfig中我们已经将rabbitAdmin由spring容器管理了。所以在这里,我们直接使用autowired就可以。如下图:

rabbitMQ精讲系列第十八篇 高级整合应用第一篇

我们先在页面管控台查看:

rabbitMQ精讲系列第十八篇 高级整合应用第一篇

并没有。启动后,在查看,是否已经创建。

测试类启动成功:

rabbitMQ精讲系列第十八篇 高级整合应用第一篇

在页面管控台查看,exchange交换机是否已经创建:

rabbitMQ精讲系列第十八篇 高级整合应用第一篇

已经创建成功。说明,rabbitAdmin我们成功了。

通过rabbitAdmin创建Queue:

rabbitMQ精讲系列第十八篇 高级整合应用第一篇

创建绑定关系:

rabbitMQ精讲系列第十八篇 高级整合应用第一篇

启动后,查看test_spring_direct_queue是否绑定了test_spring_direct交换机。

rabbitMQ精讲系列第十八篇 高级整合应用第一篇我们发现绑定成功了。

绑定方式二:使用BindingBuilder的链式

rabbitAdmin.declareBinding(
     BindingBuilder.bind(new Queue("test_spring_topic_queue",false))    //创建队列
     .to(new TopicExchange("test_spring_topic",false,false))    //绑定交换机
     .with("user.#")    //设置routingkey
);

rabbitMQ精讲系列第十八篇 高级整合应用第一篇

需要注意的:当时fanout的时候,在bingdingBuilder的时候没有with.因为fanout的不需要routingkey。

本节总结:

    使用spring的@Bean注解怎么创建connection工厂及怎么创建rabbitAdmin以及怎么使用。

下节预告:

    我们知道在rabbitMQ的基础API中得到队列、binding以及路由是通过channel对象获取的,如下图。那么在springAMQP模式下怎么声明呢?在下节课中,我们将要讲解到的。

本文出自凯哥Java(kaigejava) 个人博客(www.kaigejava.com)

rabbitMQ精讲系列第十八篇 高级整合应用第一篇


网站名称:rabbitMQ精讲系列第十八篇高级整合应用第一篇
URL网址:http://pwwzsj.com/article/pcopgo.html