第一部分：RocketMQ简介

‌RocketMQ‌是由阿里巴巴开源的分布式消息中间件，现已成为Apache软件基金会的顶级项目。RocketMQ具有高性能、高可靠、高实时和分布式等特点，支持事务消息、顺序消息、批量消息、定时消息和消息回溯等功能‌。

基本概念和系统组成
RocketMQ的系统组成包括以下几个主要组件：

‌Producer‌：负责生成和发送消息。
‌Consumer‌：负责消费消息。
‌Broker‌：消息服务器，负责存储和转发消息。
‌NameServer‌：提供路由信息，帮助Producer找到对应的Broker。
RocketMQ使用Topic来组织消息，Producer向一些队列轮流发送消息，Consumer可以根据消费模式（广播消费或集群消费）来处理这些消息。RocketMQ还支持拉（pull）和推（push）两种消息模式，其中push模式实际上是基于pull模式实现的‌。

核心特性
RocketMQ的核心特性包括：

‌高性能‌：支持万亿级吞吐量，适用于微服务和大数据场景。
‌高可靠性‌：提供金融级的稳定性，广泛用于交易核心链路。
‌云原生‌：支持无限弹性扩缩，与K8s友好，适用于云边端一体化数据处理场景。
‌流处理‌：提供轻量、高扩展、高性能的流计算引擎。
‌生态友好‌：无缝对接微服务、实时计算、数据湖等周边生态‌。

应用场景
RocketMQ广泛应用于多种场景，包括：

‌限流削峰‌：通过暂存超量请求，避免系统被压垮。
‌异步解耦‌：通过异步调用降低系统耦合度，提升系统吞吐量和并发度。
‌数据收集‌：适用于分布式系统中的海量数据流处理，如业务日志、监控数据和用户行为数据的实时或批量采集汇总‌。

 

第二部分：RocketMQ下载安装和启动

一、官网下载rocketmq
1、官网地址：下载 | RocketMQ

打开网址：https://rocketmq.apache.org/zh/download/

我们下载5.3.0版本

2、解压到指定目录，比如：E:\rocketmq-all-5.3.0-bin-release

 

二、配置环境变量
打开电脑的高级系统设置，配置环境变量，变量名：ROCKETMQ_HOME 变量值：E:\rocketmq-all-5.3.0-bin-release

然后在系统变量中选中【path】点击编辑，在弹出窗里面选择新建，添加一行：%ROCKETMQ_HOME%\bin

 

三、启动nameserver和broker 
启动nameserver服务
1、可以直接到rockermq的解压目录的bin目录下，直接双击mqnamesrv.cmd运行

2、可以在bin目录使用cmd命令行启动，输入命令：start mqnamesrv.cmd

启动broker服务 
在bin目录使用cmd命令行启动，输入命令：

start mqbroker.cmd -n localhost:9876 autoCreateTopicEnable=true

四、部署rocketmq-dashboard控制台
1、官网下载rocketmq-dashboard代码 
官网文档说明：RocketMQ Dashboard | RocketMQ

官网列举了两种安装方式：docker镜像安装、源码安装

本文讲解源码安装方式，在编译rocketmq-dashboard源码之前，建议把maven的镜像仓库地址改成阿里云

2、修改配置文件
rocketmq-dashboard需要连接RocketMQ消息队列服务，所以需要在配置文件里指定RocketMQ消息队列的服务地址，找到rocketmq-dashboard源码的application.properties配置文件，目录路径为\rocketmq-dashboard-rocketmq-dashboard-1.0.0\src\main\resources

文件里搜索 rocketmq.config.namesrvAddr

 

五、把rocketmq设置成服务启动
1、在rocketmq目录中新建文件夹 
在rocketmq解压目录下新建一个文件夹，比如名字叫dashboard文件夹，然后把前面下载好的rocketmq-dashboard源码移动到该dashboard目录中

2、编写rocketmq启动脚本
在rocketmq解压目录下新建一个start.bat脚本，内容为：

start .\bin\mqnamesrv.cmd
start .\bin\mqbroker.cmd -n localhost:9876 autoCreateTopicEnable=true
java -jar .\dashboard\rocketmq-dashboard-rocketmq-dashboard-1.0.0\target\rocketmq-dashboard-1.0.0.jar