1 什么是消息中间件？

• MQ，全称是Message Queue，消息队列是应用程序和应用程序之间的通信方法。

2 为什么使用MQ？

• 在项目中，可以将一些无需即时返回且耗时的操作提取出来，进行异步处理，而这种异步处理的方式大大的节省了服务器的请求响应时间，从而提高了系统的吞吐量。

3 MQ的应用场景

• 任务异步处理：将不需要同步处理的并且耗时较长的操作由消息队列通知消息接收方进行异步处理，提高了应用程序的响应时间。
• 应用程序耦合：MQ相当于一个中介，生产方通过MQ和消费方进行交互，MQ将应用程序进行解耦合。
• 削峰填谷：
  • 比如，在订单系统中，在下订单的是时候就会向数据库中写入数据，但是数据库只能支撑每秒1000左右的并发写入，并发量再高就很容易宕机。在低峰期的时候并发也就100多个，在高峰期的时候，并发量就会突然增加了5000以上，这个时候数据库肯定会卡死。

• 如果我们将消息通过MQ保存起来，那么系统就可以按照自己的消费能力来消费，比如每秒消费1000个数据，这样慢慢的将数据写入到数据库中，就不会卡死数据库了。

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

4 AMQP和JMS

4.1 概述

• 实现MQ的主要协议有：AMQP和JMS。

4.2 AMQP

• AMQP（Advanced Message Queue，高级消息队列协议）是一种协议，更准确的说是一种链接协议（binary wire-level protocal），这和JMS的本质差别是，AMQP不从API层进行限定，而是直接定义网络交换的数据格式。

4.3 JMS

• JMS即Java消息服务（Java Message Service）应用程序接口，是一个Java平台中关于面向消息中间件（OOM）的API，用于在两个应用程序之间或分布式系统中发送消息，进行异步通信。

4.4 AMQP和JMS的区别

• JMS定义了统一的接口，来对消息操作进行统一；AMQP是通过规定协议来统一数据交换的格式。
• JMS限定了必须使用Java语言；AMQP只是协议，不规定实现方式，因此是跨语言的。
• JMS规定了两种消息模式；AMQP的消息模式更加丰富。

5 消息中间件产品

• 市面上常见的消息中间件产品如下：
• ActiveMQ：基于JMS。
• ZeroMQ：基于C语言开发。
• RabbitMQ：基于AMQP协议，erlang语言开发，稳定性好。
• RocketMQ：基于JMS，阿里巴巴产品。
• Kafka：类似MQ的产品，分布式消息系统，高吞吐量。

6 RabbitMQ

• RabbitMQ是由erlang语言开发，基于AMQP协议实现的消息队列，它是一种应用程序之间的通信方式，RabbitMQ在分布式系统开发中的应用非常广泛。
• RabbitMQ的官网。
• RabbitMQ提供了6种模式：简单模式、work模式、publish/subscribe发布订阅模式、Routing路由模式、Topics主题模式、RPC远程调用模式（远程调用，不太算MQ，使用不多）。