mq消息队列堵塞的原因（浅谈消息中间件）

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

为什么使用MQ？

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

将不需要同步处理的并且耗时长的操作由消息队列通知消息接收方进行异步处理。提高了应用程序的响应时间。

MQ相当于一个中介，通过它让生产者与消费者交互，将应用程序进行解耦合。

如某个系统会往数据库写数据，但是数据库只能支撑每秒1000左右的并发写入，并发量再高就容易宕机。

在系统低峰期的时候并发也就100多个，但在高峰期时候，并发量会突然激增到5000以上，这个时候数据库肯定会卡死。

这时候，可以使用MQ，消息会被MQ保存起来，然后系统就可以按照自己的消费能力来消费，比如每秒1000个数据，慢慢写入数据库，就不会卡死数据库了。

但使用了MQ之后，限制消费消息的速度为1000，但是这样一来，高峰期产生的数据势必会被积压在MQ中，高峰就被“削”掉了。

但是因为消息积压，在高峰期过后的一段时间内，消费消息的速度还是会维持在1000QPS，直到消费完积压的消息,这就叫做**“填谷”**

MQ是消息通信的模型；实现MQ的大致有两种主流方式：AMQP、JMS。

AMQP 是一种协议，更准确地说是一种 binary wire-level protocol（链接协议）。与 JMS 的本质差别 ： AMQP不从API层进行限定，而是直接定义网络交换的数据格式。

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

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

常见的消息队列有如下：

• ActiveMQ：基于 JMS
• ZeroMQ：基于 C 语言开发
• RabbitMQ：基于 AMQP 协议，erlang 语言开发，稳定性好
• RocketMQ：基于 JMS，阿里巴巴产品
• Kafka：类似MQ的产品；分布式消息系统，高吞吐量

RabbitMQ是由erlang语言开发，基于AMQP（Advanced Message Queue 高级消息队列协议）协议实现的消息队列，它是一种应用程序之间的通信方法，消息队列在分布式系统开发中应用非常广泛。

RabbitMQ官方地址：http://www.rabbitmq.com/

RabbitMQ提供了6种模式：

简单模式

work模式

Publish/Subscribe 发布与订阅模式

Routing 路由模式

Topics 主题模式

RPC 远程调用模式；

官网对应模式介绍：https://www.rabbitmq.com/getstarted.html

来源：https://www.cnblogs.com/MoYu-zc/p/15144660.html