【RocketMQ】001-RocketMQ 概述

野性酷女 2023-09-24 20:28 57阅读 0赞

# 【RockerMQ】001-RocketMQ 概述 #

### 文章目录 ###

*  【RockerMQ】001-RocketMQ 概述
 *  一、MQ 概述
 *   *  1、MQ 简介
     *  2、MQ 用途
     *   *  限流削峰
         *  异步解耦
         *  数据收集
     *  3、常见 MQ 产品
     *   *  概述
         *  对比
     *  4、MQ 常见协议
 *  二、RocketMQ 概述
 *   *  1、简介
     *  2、发展历史

# 一、MQ 概述 #

## 1、MQ 简介 ##

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

## 2、MQ 用途 ##

### 限流削峰 ###

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

> 自：提升系统的消化能力，一口气吃完容易噎死，慢慢吃！算是一种任务调度！

![image-20230225160449023][]

### 异步解耦 ###

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

> 自：任务调度性质更强！

![image-20230225160732753][]

### 数据收集 ###

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

> 自：MQ 记录了所有的消息，像是一个账本，或者日志，可以据此分析各项数据！

## 3、常见 MQ 产品 ##

### 概述 ###

*  ActiveMQ：ActiveMQ 是使用 Java 语言开发一款 MQ 产品。早期很多公司与项目中都在使用。但现在的**社区活跃度已经很低**。现在的项目中**已经很少使用了**。
 *  RabbitMQ：RabbitMQ是使用 ErLang 语言开发的一款 MQ 产品。其吞吐量较 Kafka 与 RocketMQ 要低，且由于其不是 Java 语言开发，所以公司内部对其实现**定制化开发难度较大**。
 *  Kafka：Kafka 是使用 Scala/Java 语言开发的一款 MQ 产品。其最大的特点就是**高吞吐率**，常用于**大数据领域**的实时计算、日志采集等场景。其没有遵循任何常见的 MQ 协议，而是使用**自研协议**。对于 Spring Cloud Netflix，其仅支持 RabbitMQ 与 Kafka。
 *  RocketMQ：RocketMQ 是使用 Java 语言开发的一款 MQ 产品。经过数年阿里双 11 的考验，**性能与稳定性非常高**。其没有遵循任何常见的 MQ 协议，而是使用**自研协议**。对于 **Spring Cloud Alibaba**，其支持 RabbitMQ、Kafka，但提倡使用 RocketMQ。

### 对比 ###

<table> 
 <thead> 
  <tr> 
   <th>关键词</th> 
   <th>ACTIVEMQ</th> 
   <th>RABBITMQ</th> 
   <th>KAFKA</th> 
   <th>ROCKETMQ</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>开发语言</td> 
   <td>Java</td> 
   <td>ErLang</td> 
   <td>Java</td> 
   <td>Java</td> 
  </tr> 
  <tr> 
   <td>单机吞吐量</td> 
   <td>万级</td> 
   <td>万级</td> 
   <td>十万级</td> 
   <td>十万级</td> 
  </tr> 
  <tr> 
   <td>Topic</td> 
   <td>-</td> 
   <td>-</td> 
   <td>百级Topic时会影响系统吞吐量</td> 
   <td>千级Topic时会影响系统吞吐</td> 
  </tr> 
  <tr> 
   <td>社区活跃度</td> 
   <td>低</td> 
   <td>高</td> 
   <td>高</td> 
   <td>高</td> 
  </tr> 
 </tbody> 
</table>

## 4、MQ 常见协议 ##

一般情况下MQ的实现是要遵循一些**常规性协议**的。常见的协议如下：

**JMS**

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

**STOMP**

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

**AMQP**

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

**MQTT**

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

# 二、RocketMQ 概述 #

## 1、简介 ##

RocketMQ 是一个**统一消息引擎、轻量级数据处理平台**。RocketMQ是一款**阿里巴巴**开源的**消息中间件**。 2016 年 11 月 28 日，阿里巴巴向 Apache 软件基金会捐赠 RocketMQ，成为 **Apache 孵化项目**。 2017 年 9 月 25 日，Apache 宣布 RocketMQ 孵化成为 **Apache 顶级项目**（TLP ），成为国内首个互联网中间件在 Apache 上的顶级项目。

官网地址：http://rocketmq.apache.org

## 2、发展历史 ##

*  2007 年，阿里开始**五彩石项目**，Notify 作为项目中交易**核心消息流转系统**，应运而生。Notify 系统是 RocketMQ 的雏形。
    
    > 消息流转系统，我觉得消息也就是事件嘛，要做什么事情先产生一个消息，存储起来，然后交给服务器完成！
 *  2010 年，B2B 大规模使用 ActiveMQ 作为阿里的消息内核。阿里急需一个**具有海量堆积能力的消息系统**。
    
    > 看来 ActiveMQ 不够用！这也是其社区活跃度低、逐渐被淘汰的原因吧。
 *  2011 年初，Kafka 开源。淘宝中间件团队在对 Kafka 进行了深入研究后，开发了一款新的 MQ，MetaQ。、
    
    > 使用 ActiveMQ + 研究 Kafka => 开发出 MetaQ
    > 
    > **新的工具 = 吸收旧工具优点 + 弥补旧工具不足 + 扩展新功能。**
 *  2012 年，MetaQ 发展到了 v3.0 版本，在它基础上进行了进一步的抽象，形成了 RocketMQ，然后就将其进行了开源。

> 新工具迭代更新多个版本后，基本稳定 => 开源（东西太烂的话，不好意思拿出来！）

*  2015 年，阿里在 RocketMQ 的基础上，又推出了一款专门针对阿里云上用户的消息系统 Aliware MQ。
    
    > 这属于阿里云定制版了吧！
 *  2016 年双十一，RocketMQ 承载了**万亿级**消息的流转，跨越了一个新的里程碑。 11 月 28 日，阿里巴巴向 Apache 软件基金会捐赠 RocketMQ，成为 Apache 孵化项目。
    
    > 星火燎原！
 *  2017 年 9 月 25 日，Apache 宣布 RocketMQ孵化成为 Apache 顶级项目（TLP ），成为国内首个互联网中间件在 Apache 上的顶级项目。
    
    > 有点羽化登仙的意思！

[image-20230225160449023]: https://img-blog.csdnimg.cn/img_convert/fc0e24280b1feabff5f0476de19a19fb.png
[image-20230225160732753]: https://img-blog.csdnimg.cn/img_convert/1556d48e71d8fbe0ffd50de1c5f4f23f.png