目录

一、MQ简介

二、MQ主要用途

1.限流削峰

2.异步解耦

3.数据收集

三、MQ主要产品

ActiveMQ

RabbitMQ

Kafka

RocketMQ

---

一、MQ简介

MQ，Message Queue，是一种提供消息队列服务的中间件，是一套提供了消息生产、存储和消费全过程的API的软件系统。消息即数据。一般消息的量不会很大。

二、MQ主要用途

1.限流削峰

MQ可以将系统的超量请求暂存其中，以便系统后期可以慢慢进行处理，从而避免了请求的丢失或系统被压垮。

2.异步解耦

上游系统对下游系统若为同步调用，则会大大降低系统的吞吐量与并发度，且系统耦合度太高。而异步调用则会解决这些问题，所以两层之间若要实现由同步到异步的转化，一般做法是在这两层中加一个MQ层。

3.数据收集

分布式系统会产生海量级数据流，如：业务日志、监控数据、用户行为等。针对这些数据流进行实时或批量采集汇总，然后对这些数据流进行大数据分析，这是当前互联网平台的必备技术。通过MQ完成此类数据收集是最好的选择。

三、MQ主要产品

ActiveMQ

ActiveMQ是使用Java语言开发的一款MQ产品，早已很多公司与项目中都在使用，但现在的社区活跃度已经很低，目前下项目中较少使用

RabbitMQ

RabbitMQ是使用ErLang语言开发的一款MQ产品，其吞吐量较Kafka与RocketMQ要低，但由于其不是java语言开发，所以公司内部对其实现定制化开发难度较大。

Kafka

Kafka是使用Scala/Java语言开发的一款MQ产品，最大的特点是高吞吐量，常用于大数据领域的实时计算、日志采集等场景。其没有遵循任何常见的MQ协议，而是使用自研协议。

RocketMQ

RocketMQ是使用Java语言开发的一款MQ产品，经过数年的考验，性能与稳定性非常高。其没有遵循任何常见的MQ协议，而是使用自研协议。对于Spring Cloud Alibaba，其支持RabbitMQ、Kafka，但提倡使用RabbitMQ。