消息队列又可以称为消息中间件，在不同的场景下有不同的用途，一般主要作用有以下几点。
- 解耦，特别是在现在流行的分布式微服务中，除了直接用http调用外，很多可以使用消息队列来解决，比如完成某项功能需要同时发送邮件、短信；订单支持成功要进行后续很多相关操作，都可以使用消息队列来进行友好的解耦。
- 削峰，在某应用访问量剧增的情况下，可以使用消息队列达到削峰的目的，限制入队的速度或消费的处理，避免大量的请求造成崩溃的现象。
- 异步，很多情况下不需要同步处理某个请求，可以使用消息队列达到异步处理的目的，并且可以理论上无限制的增加消费者，可以加快任务处理。
- 补偿重试，当某些处理需要必须处理成功，但其中可能出错，这就必须要进行重试，消息队列可以存储此类信息，并使该功能执行成功才最终确认，从队列中删除，否则队列中都可以一直保留此信息。
RabbitMQ就是现在市面上几种消息队列中很不错的一种。主要关键名词。
Queue
队列，用于消息存储，生产者生产的消息最终都会投递到队列中，供消费者从队列中进行消费。
Exchang
交换机，我们在使用RabbitMQ发送消息的时候，并不是直接把消息发送到Queue中，而是发送到交换机Exchange，再由Exchange路由到各自队列中。交换机主要包含以下几种类型。
- fanout 广播模式，会把所有发送过来的消息全部路由到与此交换机绑定的队列中。一般用于把同一消息给多个对象处理。
- direct，直接把消息路由到绑定了相应路由间RoutingKey的队列中。只能匹配一个路由键。
- topic，跟direct类似，不过可以支持多个路由的绑定，中间以"."隔开，同时支持使用""和"#"做模糊匹配，用""匹配一个单词，用"#"匹配多规则单词，也可以是零个。
- headers模式，此模式不依赖路由键路由消息，是通过消息内容中的headers属性来进行匹配。
在SpringBoot下，消息队列使用配置方式如下：
- 创建队列
/**
* 创建队列
*
* @return 返回创建的队列
*/
@Bean("messageQueue")
public Queue messageQueue() {
// 创建持久队列且不自动确认
// 消息持久化，必须Exchange,Queue，投递模式deliveryModel=2,三者完全匹配，才会进行持久化存储
return new Queue("messageQueue", true, false, false);
}
- 创建交换机
/**
* 创建交换机
*
* @return 返回交换机
*/
@Bean("topicExchange")
public Exchange topicExchange() {
return ExchangeBuilder.topicExchange("topicExchange").durable(true).build();
}
- 绑定队列
/**
* 交换机和路由 队列的绑定
*
* @param queue 需要绑定的队列
* @param exchange 需要绑定的交换机
* @return 返回绑定
*/
@Bean
public Binding buildTopicMessage(@Qualifier("messageQueue") Queue queue, @Qualifier("topicExchange") Exchange exchange) {
return BindingBuilder.bind(queue).to(exchange).with("routingkey").noargs();
}
一个队列可以被多个交换机类型进行绑定，比如绑定fanout类型
创建fanout交换机
/**
* 创建广播创建交换机
*
* @return 返回广播交换机
*/
@Bean("fanoutExchange")
public Exchange messageFanoutExchange() {
return ExchangeBuilder.fanoutExchange("fanoutExchange").durable(true).build();
}
绑定messageQueue到fanout交换机
@Bean
public Binding buildFanoutMessageFanout(@Qualifier("messageQueue") Queue queue, @Qualifier("fanoutExchange") Exchange exchange) {
return BindingBuilder.bind(queue).to((FanoutExchange) exchange);
}
使用此方式即完成使用代码的形式进行消息队列的创建及绑定操作。也可以使用RabbitMQ提高的管理页面进行相关配置。
