RabbitMQ 自动创建队列/交换器/绑定
#自动创建队列,什么玩意儿?
在没有使用Spring AMQP之前,如果我们使用的是官方的Java客户端,我们需要自己手动调用创建channel,手动调用
channel.queueDeclare()
方法来创建队列。如果使用Spring AMQP来操作RabbitMQ的时候,我们会做些什么呢?在配置文件里配置
Queue
,XXExchange
,Binding
等信息。配置完成之后我们启动Spring容器,容器启动后,我们定义的队列也好,交换器也好,都会自动为我们创建。这就是Spring AMQP封装的自动创建队列。如果我们要自己实现配置化自动创建队列,交换器如何实现呢?下面我们会细细将来。
#什么是RabbitAdmin?
RabbitAdmin是Spring AMQP封装的一个对象。 在使用Spring AMQP的时候我们只是配置一个RabbitAdmin对象交给Spring容器做管理。
#Spring 自动创建队列原理
我们在使用Spring AMQP的时候往往就是声明连接工厂,Queue, Exchange,Binding。
@Bean
public Queue mailQueue() {
Map<String, Object> map = new HashMap<String, Object>();
map.put("x-dead-letter-exchange", "dead_letter_exchange");//设置死信交换机
map.put("x-dead-letter-routing-key", "mail_queue_fail");//设置死信routingKey
Queue queue = new Queue("mailQueue",true, false, false, map);
return queue;
}
@Bean
public DirectExchange mailExchange() {
return new DirectExchange("mailExchange", true, false);
}
@Bean
public Binding mailBinding() {
return BindingBuilder.bind(mailQueue()).to(mailExchange())
.with(mailRoutingKey);
}
我们只是声明了这些东西,它们怎么就创建了呢,要知道我们没有显式调用
channel.queueDeclare()
啊。接下来我们来看下为什么有了RabbitAdmin对象就可以自动创建队列。
####RabbitAdmin的初始化方法initialize()
我们看了RabbitAdmin的
initialize()
方法的源码就知道队列是怎么自动创建的了。
if (this.applicationContext == null) {
if (this.logger.isDebugEnabled()) {
this.logger
.debug("no ApplicationContext has been set, cannot auto-declare Exchanges, Queues, and Bindings");
}
return;
}
this.logger.debug("Initializing declarations");
Collection<Exchange> contextExchanges = new LinkedList<Exchange>(
this.applicationContext.getBeansOfType(Exchange.class).values());
Collection<Queue> contextQueues = new LinkedList<Queue>(
this.applicationContext.getBeansOfType(Queue.class).values());
Collection<Binding> contextBindings = new LinkedList<Binding>(
this.applicationContext.getBeansOfType(Binding.class).values());
通过代码片段,我们可以看到,RabbitAdmin初始化的时候会从spring容器里取出所有的交换器bean, 队列bean, Binding Bean; 取出之后干什么呢,当然是创建了,下面来看下创建代码
this.rabbitTemplate.execute(new ChannelCallback<Object>() {
@Override
public Object doInRabbit(Channel channel) throws Exception {
declareExchanges(channel, exchanges.toArray(new Exchange[exchanges.size()]));
declareQueues(channel, queues.toArray(new Queue[queues.size()]));
declareBindings(channel, bindings.toArray(new Binding[bindings.size()]));
return null;
}
});
到此,我们通过Spring配置的Queue对象也好,XXExchange对象也好,Binding也罢,都会在这里被创建。
####什么时候调用的initialize()
虽然我们知道了是在
initialize()
方法中实现的自动创建队列等信息,但是这个什么时候被调用的? RabbitAdmin实现InitializingBean接口,如果你对Spring非常了解的话,立马可以想到afterPropertiesSet()
,有了它当然可以在bean创建初始化的时候执行某些方法了,initialize()
方法就是在这个时候被调用的。
生产者端需要配置RabbitAdmin
生产者端不像消费端的
SimpleMessageListenerContainer
一样,可以自动初始化RabbitAdmin对象,需要我们手动来创建。
####配置RabbitAdmin
@Bean
public RabbitAdmin rabbitAdmin(ConnectionFactory defaultConnectionFactory){
return new RabbitAdmin(defaultConnectionFactory);
}
消费端会不用配置RabbitAdmin, Why?
####消费端核心配置SimpleMessageListenerContainer类
@Bean
public SimpleMessageListenerContainer messageListenerContainer() {
SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
container.setConnectionFactory(connectionFactory());
...
return container;
}
####SimpleMessageListenerContainer的doStart()方法
我们来看下
SimpleMessageListenerContainer
类的初始化配置,也就是doStart()
方法,因为代码太长,这里就不粘贴全部了,看下面的源码
...
if (this.rabbitAdmin == null && this.getApplicationContext() != null) {
Map<String, RabbitAdmin> admins = this.getApplicationContext().getBeansOfType(RabbitAdmin.class);
if (!admins.isEmpty()) {
this.rabbitAdmin = admins.values().iterator().next();
}
}
if (this.rabbitAdmin == null && this.autoDeclare) {
RabbitAdmin rabbitAdmin = new RabbitAdmin(this.getConnectionFactory());
rabbitAdmin.setApplicationContext(this.getApplicationContext());
this.rabbitAdmin = rabbitAdmin;
}
...
如果没有指定rabbitAdmin但是autoDeclare为true,那么spring就会创建一个RabbitAdmin对象。有了RabbitAdmin对象,Spring就会为我们创建队列了。
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- leetcode每日一题-99. 恢复二叉搜索树
- Java 两个经纬度获取方位
- 使用Python实现基本初等函数可视化
- 递归回溯--复原IP地址
- 通过 generic-webhook-trigger 插件实时获取 Bitbucket Repository Events
- 初识TypeScript:查找指定路径下的文件按类型生成json
- Xamarin Forms WPF 干掉默认的窗口导航条
- WPF 从零手动创建承载 Xamarin Forms 项目
- 帝都房价回调?带你用Python了解北京二手房市场现状
- Zabbix 利用 ncat 监控远端端口状态
- MySQL“被动”性能优化汇总!
- H3C WA2610i-GN 无线AP FAT 配置案例
- java强引用、软引用、弱引用、虚引用以及FinalReference
- 读源码——JDK动态代理
- 图解红黑树