#自动创建队列，什么玩意儿？

在没有使用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就会为我们创建队列了。

代码无非增删改查，关注老师给你Coding

林老师带你学编程：https://wolzq.com