世界将我包围 誓死都一齐
壮观得有如 悬崖的婚礼概述
消息队列，简称 MQ(Message Queue)，目的是为了提高系统的异步通信、扩展解耦能力
- 如注册为列子，一般注册成功后会发送一条消息给用户，如果当我们将数据保存成功后，继续执行发送消息的逻辑，这时候系统就是在等待发送逻辑运行，会降低系统的速度；其实注册成功后发送消息不是要立即响应成功的，我们可以注册成功后，将要发送的消息放入消息队列，然后发送消息的逻辑代码根据消息队列信息去执行，便提高了系统的运行速度
- 还应用在订单系统的 应用解耦 ，秒杀系统的 流量削峰
两种形式
- 队列（queue）：点对点消息通信
- 主题（topic）：发布（publish）/ 订阅（subscribe）消息通信
点对点式：
- 消息发送者发送消息，消息代码将其放入一个队列中，消息接受者从队列获取消息，消息读取后移出队列
- 消息只有唯一的发送者和接 受者，但不是只有一个接 收者，即 A、B、C 都接收到了这个消息，可是消息被 A 所接受了，B、C 接收到了但是使用不了
订阅式：
- 发送者发送消息到主题，多个接受者监听订阅这个主题，那么消息在到达的同时收到消息
JMS 和 AMQP
- JMS（Java Message Service），JAVA 消息服务，是一个 API；基于 JVM 消息代理的规范，ActiveMQ 是 JMS 实现的
- AMQP（Advanced Message Queuing Protocol），是一个高级消息队列协议，兼容 JMS，RabbitMQ 是 AMQP 的实现
RabbitMQ 简介
RabbitMQ 从整体上来看是一个典型的生产者消费者模型，主要负责接收、存储和转发消息。
架构图如下：
Product，生产者
- 生产者连接到 RabbitMQ Broker，建立一个连接 (Connection) 开启一个信道(Channel)
- 生产者声明一个交换器，并设置相关属性，比如交换机类型、是否持久化等
- 生产者声明一个队列井设置相关属性，比如是否排他、是否持久化、是否自动删除等
- 生产者通过路由键将交换器和队列绑定起来
- 生产者发送消息至 RabbitMQ Broker，其中包含路由键、交换器等信息。
- 相应的交换器根据接收到的路由键查找相匹配的队列。
- 如果找到，则将从生产者发送过来的消息存入相应的队列中。
- 如果没有找到，则根据生产者配置的属性选择丢弃还是回退给生产者
- 关闭信道，关闭连接。
Exchange，交换器
在 RabbitMQ 中，生产者并非直接将消息投递到队列中。真实情况是，生产者将消息发送到 Exchange(交换器)，由交换器根据路由规则将消息路由到一个或多个队列中。如果路由不到，或返回给生产者，或直接丢弃，或做其它处理。
RoutingKey，路由 KEY
指定消息的路由规则，需要与交换器类型和绑定键 (Binding) 联合使用才能最终生效，在绑定的条件下，生产者可以在发送消息给交换器时通过指定 RoutingKey 来决定消息流向哪个消息队列。
Binding
将交换器和队列关联起来，决定交换器的消息发送到哪个队列上
Queue，队列
- RabbitMQ 的内部对象，用于存储消息
- 生产者投递消息到队列，消费者从队列中获取消息并消费
- 多个消费者可以订阅同一个队列，这时队列中的消息会被平均分摊 (轮询) 给多个消费者进行消费，而不是每个消费者都收到所有的消息进行消费
RabbitMQ 四种类型的交换器
direct 交换器，fanout 交换器，topic 交换器，headers 交换器
direct 交换器
把消息路由到 RoutingKey 与 BindingKey 完全匹配的队列中，是完全匹配、单播的形式
- eg：如果路由键为“java”，则只能转发 RoutingKey 为“java”的消息到绑定的队列中去，不会转发如“java.spring”
fanout 交换器
会把发送到该交换器的消息路由到所有与该交换器绑定的队列中，不会匹配路由 Key，转发消息是最快的
topic 交换器
通过模式匹配分配消息，将路由键和某个模式进行匹配，识别两个通配符：“#”和“”。# 匹配 0 个或多个单词，匹配一个单词
- eg：发送一条消息，RoutingKey 为“java.spring”，这时候会匹配到 RoutingKey 为“java.#”和“#.spring”的队列
headers 交换器
不依赖于路由键的匹配规则来路由消息，而是根据发送的消息内容中的 headers 属性进行匹配。该交换器类型性能较差且不实用，因此一般不会用到