Java Spring Cloud Alibaba-RocketMQ：（一）RocketMQ 介绍以及基本使用

RocketMQ 介绍以及基本使用

• • 1.RocketMQ 介绍
  • 2.RocketMQ 基本使用
  • • 2.1 下载 RocketMQ
    • 2.2 RocketMQ 目录分析
    • 2.3 配置环境变量
    • 2.4 RocketMQ 的启动
    • 2.4.2 启动 Broker
    • 2.5 RocketMQ 的停止
    • 2.6 RocketMQ 控制台的安装

1.RocketMQ 介绍

• RocketMQ 是一款开源的分布式消息系统，基于高可用分布式集群技术，提供低延时的、高可靠的消息发布与订阅服务。同时，广泛应用于多个领域，包括异步通信解耦、企业解决方案、金融支付、电信、电子商务、快递物流、广告营销、社交、即时通信、移动应用、手游、视频、物联网、车联网等

---

具有以下特点：

• 能够保证严格的消息顺序
• 提供丰富的消息拉取模式
• 高效的订阅者水平扩展能力
• 实时的消息订阅机制
• 亿级消息堆积能力

2.RocketMQ 基本使用

2.1 下载 RocketMQ

• 使用浏览器打开：
• 传送门
• 这里我们选择 4.4.0 版本的原因在于，我们 spring cloud alibaba 版本为：2.2.0.RELEASE，它里面控制的 rocketMQ 的版是 4.4.0
  

2.2 RocketMQ 目录分析

• 将该压缩包复制到软件目录里面，使用压缩软件进行解压
  
• Benchmark：包含一些性能测试的脚本；
• Bin：可执行文件目录；
• Conf：配置文件目录；
• Lib：第三方依赖；
• LICENSE：授权信息;
• NOTICE：版本公告；

2.3 配置环境变量

• 找到配置环境变量的对话框：
  
• 点击新建创建一个环境变量：
  
• 变量名：ROCKETMQ_HOME
• 变量值：D:\devtools\rocketMQ\rocketmq-all-4.4.0-bin-release

2.4 RocketMQ 的启动

• 我们进入到${rocketMQ}/bin，在此目录里面启动和停止命令。

2.4.1 启动 NameServer

• 注意：弹出的黑窗口不要关闭

2.4.2 启动 Broker

• ./mqbroker.cmd -n localhost:9876
• 其中：
• -n localhost:9876 是为了指定 nameserver 的地址
  

2.5 RocketMQ 的停止

• 直接把弹出的黑框关闭，即可停止 RocketMQ 的 namesrv 和 broker。

2.6 RocketMQ 控制台的安装

• Rocketmq 控制台可以可视化 MQ 的消息发送！

2.6.1 下载 RocketMQ 控制台

• 直接从官网下载的是源码
  

2.6.2 复制到软件目录里面

2.6.3 运行该 jar

• java -jar rocketmq-console-ng-1.0.0.jar --rocketmq.config.namesrvAddr=127.0.0.1:9876
  
• 其中：

--rocketmq.config.namesrvAddr=127.0.0.1:9876 是为了指定 nameserver 的地址

• 运行成功后：
• 访问：
  http://localhost:8080/#/