温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

rabbitMQ系列高级整合应用Spring AMQP

发布时间:2020-04-09 17:43:13 来源:网络 阅读:350 作者:凯哥Java 栏目:软件技术

在Rabbit基础的API中,声明一个exchange、声明一个绑定、声明一个队列都是通过channel创建出来的。如下图:

rabbitMQ系列高级整合应用Spring AMQP

那么在spring AMQP中这些对象是怎么声明的?

在使用springAMQP去声明,就需要使用springAMQP的如下模式。即使用@Bean模式:

rabbitMQ系列高级整合应用Spring AMQP

下面我们就进行代码演示:

在上一篇代码中修改RabbitMQConfig类。添加如下:

/**
针对消费者配置
* 1. 设置交换机类型
* 2. 将队列绑定到交换机
FanoutExchange: 将消息分发到所有的绑定队列,无routingkey的概念
HeadersExchange :通过添加属性key-value匹配
DirectExchange:按照routingkey分发到指定队列
TopicExchange:多关键字匹配
*/

说明:

我们需要根据不同的交换机特性进行设置。

topic的:

rabbitMQ系列高级整合应用Spring AMQP

启动测试代码,查看队列:

rabbitMQ系列高级整合应用Spring AMQP

查看交换机:
rabbitMQ系列高级整合应用Spring AMQP

查看绑定关系:

topic001这个交换机为例:

rabbitMQ系列高级整合应用Spring AMQP

绑定了两个队列。队列1和队列3.routingkey分别为:spring.*mq.*.到底对不对呢?

我们查看代码:
rabbitMQ系列高级整合应用Spring AMQP

可以看到代码中确实是这么绑定的。说明,我们声明队列、绑定、交换机成功。

本文由凯哥Java(凯哥Java)发布于51CTO。凯哥公众号:凯哥Java(kaigejava)。个人博客:www.kaigejava.com

本节总结:

通过bean注解获取exchangebindingqueue对象。

本文是《rabbitMq精讲系列》教程中的:rabbitMQ精讲系列第十九篇 高级整合应用第二篇 Spring AMQP声明。系列教程,建议从第一篇看起

下节预告:

下节课,我们将讲解一个重要对象rabbitTemplate对象



向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI