RocketMQ概述

素颜马尾好姑娘i 2023-05-30 06:12 10阅读 0赞

### 文章目录 ###

*  一、MQ 介绍
 *   *  1.1 MQ 的应用场景
     *  1.2 MQ 的优缺点
     *  1.3 JMS 和 AMQP 协议对比
     *  1.4 主流 MQ 产品的比较
 *  二、RocketMQ 的安装
 *  
 *  
 *  三、RocketMQ集群搭建
 *  四、RocketMQ 集群监控平台的搭建

# 一、MQ 介绍 #

## 1.1 MQ 的应用场景 ##

*  **应用解耦**

系统的耦合性越高，容错性就越低。以电商应用为例，用户创建订单后，如果耦合调用库存系统、物流系统、支付系统，任何一个子系统出了故障或者因为升级等原因暂时不可用，都会造成下单操作异常，影响用户使用体验。

使用消息队列解耦合，系统的耦合性就会提高了。比如物流系统发生故障，需要几分钟才能来修复，在这段时间内，物流系统要处理的数据被缓存到消息队列中，用户的下单操作正常完成。当物流系统恢复后，补充处理存在消息队列中的订单消息即可，终端系统感知不到物流系统发生过几分钟故障。  
![在这里插入图片描述][20210419210302652.png]

*  **流量削峰**

应用系统如果遇到系统请求流量的瞬间猛增，有可能会将系统压垮。有了消息队列可以将大量请求缓存起来，分散到很长一段时间处理，这样可以大大提到系统的稳定性和用户体验。

一般情况，为了保证系统的稳定性，如果系统负载超过阈值，就会阻止用户请求，这会影响用户体验，而如果使用消息队列将请求缓存起来，等待系统处理完毕后通知用户下单完毕，这样总不能下单体验要好。

处于经济考量目的：业务系统正常时段的`QPS`如果是1000([QPS等相关概念][QPS] )，流量最高峰是10000，为了应对流量高峰配置高性能的服务器显然不划算，这时可以使用消息队列对峰值流量削峰。

![在这里插入图片描述][20210419210648821.png]

*  **数据分发**

通过消息队列可以让数据在多个系统更加之间进行流通。数据的产生方不需要关心谁来使用数据，只需要将数据发送到消息队列，数据使用方直接在消息队列中直接获取数据即可。

![在这里插入图片描述][20210419210855629.png]

## 1.2 MQ 的优缺点 ##

**优点**：解耦、削峰、数据分发

**缺点**包含以下几点：

*  系统可用性降低
    
     系统引入的外部依赖越多，系统稳定性越差。一旦`MQ`宕机，就会对业务造成影响。如何保证`MQ`的高可用？
 *  系统复杂度提高
    
     `MQ`的加入大大增加了系统的复杂度，以前系统间是同步的远程调用，现在是通过  
    `MQ`进行异步调用。如何保证消息没有被重复消费？怎么处理消息丢失情况？那么保证消息传递的顺序性？
 *  一致性问题
    
     `A`系统处理完业务，通过`MQ`给`B`、`C`、`D`三个系统发消息数据，如果`B`系统、`C`系统处理成功，`D`系统处理失败。如何保证消息数据处理的一致性？

## 1.3 JMS 和 AMQP 协议对比 ##

<table> 
 <thead> 
  <tr> 
   <th></th> 
   <th>JMS</th> 
   <th>AMQP</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>定义</td> 
   <td>Java api</td> 
   <td>网络线级协议</td> 
  </tr> 
  <tr> 
   <td>跨语言</td> 
   <td>否</td> 
   <td>是</td> 
  </tr> 
  <tr> 
   <td>跨平台</td> 
   <td>否</td> 
   <td>是</td> 
  </tr> 
  <tr> 
   <td>Model</td> 
   <td>提供两种消息模型：Peer-2-Peer、Pub/sub</td> 
   <td>提供了五种消息模型：direct exchange、fanout exchange、topic change、headers exchange、system exchange，本质来讲，后四种和JMS的pub/sub模型没有太大差别，仅是在路由机制上做了更详细的划分。</td> 
  </tr> 
  <tr> 
   <td>支持消息类型</td> 
   <td>多种消息类型：TextMessage、MapMessage、BytesMessage、StreamMessage、ObjectMessage、Message （只有消息头和属性）</td> 
   <td>byte[]，当实际应用时，有复杂的消息，可以将消息序列化后发送。</td> 
  </tr> 
  <tr> 
   <td>综合评价</td> 
   <td>JMS 定义了JAVA API层面的标准；在java体系中，多个client均可以通过JMS进行交互，不需要应用修改代码，但是其对跨平台的支持较差；</td> 
   <td>AMQP定义了wire-level层的协议标准；天然具有跨平台、跨语言特性。</td> 
  </tr> 
 </tbody> 
</table>

## 1.4 主流 MQ 产品的比较 ##

<table> 
 <thead> 
  <tr> 
   <th></th> 
   <th>ActiveMQ</th> 
   <th>RabbitMQ</th> 
   <th>RocketMQ</th> 
   <th>Kafka</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>开发语言</td> 
   <td>java</td> 
   <td>erlang</td> 
   <td>java</td> 
   <td>scala</td> 
  </tr> 
  <tr> 
   <td>单机吞吐量</td> 
   <td>万级</td> 
   <td>万级</td> 
   <td>10万级</td> 
   <td>10万级</td> 
  </tr> 
  <tr> 
   <td>时效性</td> 
   <td>ms级</td> 
   <td>us级</td> 
   <td>ms级</td> 
   <td>ms级以内</td> 
  </tr> 
  <tr> 
   <td>可用性</td> 
   <td>高（主从架构）</td> 
   <td>高（主从架构）</td> 
   <td>非常高（分布式架构）</td> 
   <td>非常高（分布式架构）</td> 
  </tr> 
  <tr> 
   <td>功能特性</td> 
   <td>成熟的产品，很多公司得到应用；有较多的文档；各种协议支持较好</td> 
   <td>基于erlang开发，所以并发能力很强，性能极强，延时很低；管理界面较丰富</td> 
   <td>MQ功能比较完备，扩展性佳</td> 
   <td>只支持主要的MQ功能，像一些消息查询、消息回溯等功能没有提供，在大数据领域应用广</td> 
  </tr> 
 </tbody> 
</table>

# 二、RocketMQ 的安装 #

#  #

*  下载：[官网][Link 1]下载`rocketmq-all-4.5.2-bin-release.zip`
 *  解压：`unzip rocketmq-all-4.5.2-bin-release.zip`
 *  编辑`bin`目录下的`runbroker`和`runserver`,修改默认的`JVM`大小

JAVA_OPT="${JAVA_OPT} -server -Xms200m -Xmx200m -Xmn100m"
    JAVA_OPT="${JAVA_OPT} -server -Xms200m -Xmx200m -Xmn100m -XX:MetaspaceSize=100m -XX:MaxMetaspaceSize=250m"

*  在解压目录新建4个启动停止文件并给文件添加执行权限，`chmod +x xxx.sh`
    
        [start_broker.sh]:nohup sh bin/mqbroker -n localhost:9876 autoCreateTopicEnable=true &
        [start_namesrv.sh]:nohup sh bin/mqnamesrv &
        [stop_broker.sh]:sh bin/mqshutdown broker
        [stop_namesrv.sh]:sh bin/mqshutdown namesrv
 *  启动`NameServer`、`Broker`后，进行测试：
    
        发送消息：1、export NAMESRV_ADDR=localhost:9876
        2、sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
        接收消息：1、export NAMESRV_ADDR=localhost:9876
        2、sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

#  #

# 三、RocketMQ集群搭建 #

*  `Producer`：消息的发送者；举例：发信者
 *  `Consumer`：消息接收者；举例：收信者
 *  `Broker`：暂存和传输消息；举例：邮局
 *  `NameServer`：管理`Broker`；举例：各个邮局的管理机构
 *  `Topic`：区分消息的种类；一个发送者可以发送消息给一个或者多个`Topic`；一个消息的接收者可以订阅一个或者多个`Topic`消息
 *  `Message Queue`：相当于是`Topic`的分区；用于并行发送和接收消息

![RocketMQ-集群搭建][RocketMQ-]

# 四、RocketMQ 集群监控平台的搭建 #

`Apache RocketMQ`有一个对其扩展的开源项目`rocketmq-externals`,这个项目中有一个子模块叫 rocketmq‐console ，这个便是管理控制台项目了，先将`rocketmq-externals`拉到本地，然后对`rocketmq‐console` 进行编译打包运行。

# 克隆项目
    git clone https://github.com/apache/rocketmq-externals.git
    
    cd rocketmq‐console 
    
    # 打包
    mvn clean package '‐Dmaven.test.skip=true' 
    
    #注意：打包前在 rocketmq‐console 中配置 namesrv 集群地址：
    rocketmq.config.namesrvAddr=192.168.2.100:9876;192.168.2.101:9876 
    
    # 启动rocketmq-console
    java ‐jar rocketmq‐console‐ng‐1.0.0.jar

启动成功后，我们就可以通过浏览器访问 `http://localhost:8080`进入控制台界面了

[20210419210302652.png]: https://img-blog.csdnimg.cn/20210419210302652.png
[QPS]: https://blog.csdn.net/qq_38697437/article/details/102959516
[20210419210648821.png]: https://img-blog.csdnimg.cn/20210419210648821.png
[20210419210855629.png]: https://img-blog.csdnimg.cn/20210419210855629.png
[Link 1]: http://rocketmq.apache.org/
[RocketMQ-]: https://img-blog.csdnimg.cn/20191107193148744.png