一文看懂什么是MQ消息队列

概念

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

用途

流量削峰

MQ可以将系统的超量请求暂存其中&＃xff0c;以便系统后期可以慢慢进行处理&＃xff0c;从而避免了请求的丢失或系统被压垮。防止因为短时请求超负荷导致服务器宕机。

异步解耦

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

数据收集

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

常见MQ

RocketMQ

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

RabbitMQ

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

ActiveMQ

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

Kafka

Kafka是使用Scala/Java语言开发的一款MQ产品。其最大的特点就是高吞吐率&＃xff0c;常用于大数据领域的实时计算、日志采集等场景。其没有遵循任何常见的MQ协议&＃xff0c;而是使用自研协议。对于Spring Cloud Netflix&＃xff0c;其仅支持RabbitMQ与Kafka。

MQ 常见协议

JMS

JMS&＃xff0c;Java Messaging Service&＃xff08;Java消息服务&＃xff09;。是Java平台上有关MOM&＃xff08;Message Oriented Middleware&＃xff0c;面向消息的中间件 PO/OO/AO&＃xff09;的技术规范&＃xff0c;它便于消息系统中的Java应用程序进行消息交换&＃xff0c;并且通过提供标准的产生、发送、接收消息的接口&＃xff0c;简化企业应用的开发。ActiveMQ是该协议的典型实现。

STOMP

STOMP&＃xff0c;Streaming Text Orientated Message Protocol&＃xff08;面向流文本的消息协议&＃xff09;&＃xff0c;是一种MOM设计的简单文本协议。STOMP提供一个可互操作的连接格式&＃xff0c;允许客户端与任意STOMP消息代理&＃xff08;Broker&＃xff09;进行交互。ActiveMQ是该协议的典型实现&＃xff0c;RabbitMQ通过插件可以支持该协议。

AMQP

AMQP&＃xff0c;Advanced Message Queuing Protocol&＃xff08;高级消息队列协议&＃xff09;&＃xff0c;一个提供统一消息服务的应用层标准&＃xff0c;是应用层协议的一个开放标准&＃xff0c;是一种MOM设计。基于此协议的客户端与消息中间件可传递消息&＃xff0c;并不受客户端/中间件不同产品&＃xff0c;不同开发语言等条件的限制。 RabbitMQ是该协议的典型实现

MQTT

MQTT&＃xff0c;Message Queuing Telemetry Transport&＃xff08;消息队列遥测传输&＃xff09;&＃xff0c;是IBM开发的一个即时通讯协议&＃xff0c;是一种二进制协议&＃xff0c;主要用于服务器和低功耗IoT&＃xff08;物联网&＃xff09;设备间的通信。该协议支持所有平台&＃xff0c;几乎可以把所有联网物品和外部连接起来&＃xff0c;被用来当做传感器和致动器的通信协议。 RabbitMQ通过插件可以支持该协议