1.MQ的基本概念

1.1 MQ概述

M Q 全称 Message Queue 消息队列，是在消息的传输过程中保存消息的容器。多用于分布式系统之间的通信。

1.2 MQ 的优势

1.2.1应用解耦

当订单系统强依赖库存系统，支付系统，物流系统等，若其中一个系统出现问题，整个系统都会收到影响。如下如的系统模式：

系统的耦合性越高，容错性就越低，可维护性就越低。

若订单系统和库存系统、支付系统、物流系统等其他系统之间添加一个MQ消息队列解除它们之间的强依赖，这样可以提升容错性和可维护性。如下图：

使用MQ是的应用之间解耦，提升容错性和可维护性。

1.2.2异步提速

例如：正常的一个下单操作耗时：20+300+300+300+300=1220ms,用户点击下单按钮需要等待1220ms才能等待下单响应。如下图：

如果在订单系统和其他系统中间添加一个MQ，让订单系统和MQ交互，MQ和库存系统，支付系统，物流系统，其他系统交互，这样大大提升系统的速度。如下图：

用户点击完下单按钮，只需等待25ms就能得到下单响应。

提升用户体验和系统吞吐量。

1.2.3 削峰填谷

使用MQ之后，限制消费消息的速度为1000，这样一来，高峰期产生的数据会挤压在MQ中，高峰被“削”掉了，但是因为消息积压，在高峰期过后的一段时间内，消费消息的速度还是会维持在1000，直到消费完挤压的消息，这就做“填谷”。

使用MQ之后，提高系统的稳定性。

1.2.4 MQ 优势总结：

• 应用解耦：提高心痛容错性和可维护性。
• 异步提速：提升用户体验和系统吞吐量。
• 削峰填谷：提高系统稳定性。

1.3 MQ的劣势

• 系统可用性降低：系统引入的外部依赖越多，系统的稳定性越差。一旦MQ宕机，就会对业务造成影响。如何保证MQ的高可用变的很重要！
• 系统复杂度提高：MQ的加入大大增加了系统的复杂度，以前系统间是同步的远程调用，现在是通过MQ进行异步调用。如何保证消息不被丢失等情况变得重要！

1.4 常见MQ产品对比

RabbitMQ安全性比较高，Kafka在金融领域用的比较多。

1.5 RabbitMQ简介

AMQP，即Advanced Message Queuing Protocol(高级消息队列协议)，是一个网络协议，是应用层协议的一个开放标准，为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件不同产品，不同的开发语言等条件的限制。2006年，AMQP 规范发布。类比HTTP。

2007年，Rabbit 技术公司基于 AMQP 标准开发的 RabbitMQ 1.0 发布。RabbitMQ 采用 Erlang 语言开发。 Erlang 语言由 Ericson 设计，专门为开发高并发和分布式系统的一种语言，在电信领域使用广泛。

RabbitMQ基础架构如下：

RabbitMQ 中的相关概念:

• Broker:接收和分发消息的应用，RabbitMQ Server就是 Message Broker
• Virtual host:出于多租户和安全因素设计的，把 AMOP 的基本组件划分到一个虚拟的分组
  中，类似于网络中的 namespace 概念。当多个不同的用户使用同一个 RabbitMQ server 提供的服务时，可以划分出多个vhost，每个用户在自己的 vhost 创建 exchange/queue等 Connection: publisher/consumer 和 broker 之间的 TCP 连接。
• Channel:如果每一次访问 RabbitMQ 都建立一个 Connection，在消息量大的时候建立TCP Connection的开销将是巨大的，效率也较低。Channel 是在 connection 内部建立的逻辑连接，如果应用程序支持多线程，通常每个thread创建单独的 channel 进行通讯，AMQP method 包含了channel id 帮助客户端和message broker 识别 channel，所以channel之间是完全隔离的。Channel 作为轻量级的 Connection 极大减少了操作系统建立 TCP connection 的开销。
• Exchange: message 到达 broker 的第一站，根据分发规则，匹配查询表中的 routing key，分发消息到queue 中去。常用的类型有:direct (point-to-point) ，topic (publish-subscribe) and fanout (multicast)
• Queue:消息最终被送到这里等待 consumer 取走。
• Binding:exchange 和 queue 之间的虚拟连接，binding 中可以包含 routing key。 Binding 信息被保存到 exchange 中的查询表中，用于 message 的分发依据