RocketMQ 的下载及安装

下载 

        RocketMQ 可以从官网下载，也可以从 Github 上获取，推荐从官网中获取 
        官网：http://rocketmq.apache.org/dowloading/releases/ 
        Github：https://github.com/apache/rocketmq/ 

        本书中将使用 4.8.0 的版本,从官网上获取的页面如下。

环境要求如下：

• Windows/Linux 64 位系统 
• JDK1.8(64 位) 
• 源码安装需要安装 Maven 3.2.x

安装 

windows 下的安装 
下载 
下载链接：https://archive.apache.org/dist/rocketmq/4.8.0/rocketmq-all-4.8.0-bin-release.zip 
解压运行版本(Binary)，确保已经安装好了 JDK1.8 
解压后的目录如下：

配置环境变量 

变量名：ROCKETMQ_HOME

变量值：MQ 解压路径\MQ 文件夹名 

启动  

在 RocketMQ 的架构中，都是需要先启动 NameServer 再启动 Broker 的。所以先启动
NameServer。 

• 启动 NameServer 

使用 cmd 命令框执行进入至‘MQ 文件夹\bin’下，然后执行‘start mqnamesrv.cmd’，启动
NameServer。成功后会弹出提示框，此框勿关闭。 

• 启动 Broker 

使用 cmd 命令框执行进入至‘MQ 文件夹\bin’下，然后执行‘start mqbroker.cmd -n 
127.0.0.1:9876 autoCreateTopicEnable=true’，启动 Broker。成功后会弹出提示框，此框勿
关闭。  

注意事项  

• 弹出提示框‘错误: 找不到或无法加载主类 xxxxxx’的处理

打开‘MQ 文件夹\bin’下的 runbroker.cmd，然后将‘%CLASSPATH%’加上英文双引号。保存
并重新执行 start 语句。 

再次启动

• 内存不足的处理方式 

 RocketMQ 默认的虚拟机内存较大，启动 Broker 如果因为内存不足失败，需要编辑如下
两个配置文件，修改JVM内存大小。编辑‘MQ文件夹\bin’下的runbroker.cmd和runserver. 
cmd 修改默认 JVM 大小（Linux 上对应同名 sh 文件） 

runbroker.cmd                 --broker 的配置 
runserver. cmd                --nameServer 的配置 

例如：配置以下参数将 RocketMQ 的启动 JVM 的 堆空间内存控制在 512m，新生代控制
 在 256m。元空间初始 128m，最大 320m。

• 修改 RocketMQ 的存储路径 

rocketmq 取的默认路径是 user.home 路径，也就是用户的根目录，一般存储放在跟路径
下的 /store 目录。 

源码中可以得到验证，如下图：

         所以这里会有一个问题，RocketMQ 很容易导致 C 盘空间不够，在使用过程中，创建一个主
题默认就是要创建 1G 的文件，很可能会导致出问题。

 所以在 windows 上容易导致 C 盘空间吃满。

解决方式有两种：

1、修改源码，比如：全局替换 user.home 参数为 mq.store，然后重新打包 
2、使用源码方式启动，源码启动时通过参数设置指定存储位置 
 

控制台插件

环境要求

运行前确保：已经有 jdk1.8，Maven(打包需要安装 Maven 3.2.x) 

下载 

老版本地址下载：https://codeload.github.com/apache/rocketmq-externals/zip/master 

新版本地址：https://github.com/apache/rocketmq-dashboard 
解压后如图(以下使用的是老版本，新版本参考老版本即可) 

启动 

后端管理界面是：rocketmq-console 
下载完成之后，进入‘\rocketmq-console\src\main\resources’文件夹，打开
‘application.properties’进行配置。

进入‘\rocketmq-externals\rocketmq-console’文件夹，执行‘mvn clean package 
-Dmaven.test.skip=true’，编译生成。

编译成功之后，cmd 命令进入‘target’文件夹，执行‘java -jar rocketmq-console-ng-2.0.0.jar’，启
动‘rocketmq-console-ng-2.0.0.jar’。

 浏览器中输入‘127.0.0.1:8089’，成功后即可进行管理端查看。

 控制台使用文档 

• 运维页面 

1. 你可以修改这个服务使用的 namesrv 的地址 
2. 你可以修改这个服务是否使用 VIPChannel(如果你的 mq server 版本小于 3.5.8，请设置不使用) 

• 驾驶舱 

1. 查看 broker 的消息量（总量/5 分钟图） 
2. 查看单一主题的消息量（总量/趋势图） 

• 集群 

1. 查看集群的分布情况：cluster 与 broker 关系、broker 
2. 查看 broker 具体信息/运行信息 
3. 查看 broker 配置信息 

主题页面 

1. 展示所有的主题，可以通过搜索框进行过滤 
2. 筛选 普通/重试/死信 主题 
3. 添加/更新主题 

• clusterName 创建在哪几个 cluster 上 
• brokerName 创建在哪几个 broker 上 
• topicName 主题名 
• writeQueueNums 写队列数量 
• readQueueNums 读队列数量 
• perm //2 是写 4 是读 6 是读写 

1. 状态 查询消息投递状态（投递到哪些 broker/哪些 queue/多少量等） 
2. 路由 查看消息的路由（现在你发这个主题的消息会发往哪些 broker，对应 broker 的queue 信息） 
3. CONSUMER 管理（这个 topic 都被哪些 group 消费了，消费情况何如） 
4. topic 配置（查看变更当前的配置） 
5. 发送消息（向这个主题发送一个测试消息） 
6. 重置消费位点(分为在线和不在线两种情况，不过都需要检查重置是否成功) 
7. 删除主题 （会删除掉所有 broker 以及 namesrv 上的主题配置和路由信息）

• 消费者页面 

1. 展示所有的消费组，可以通过搜索框进行过滤 
2. 刷新页面/每隔五秒定时刷新页面 
3. 按照订阅组/数量/TPS/延迟 进行排序 
4. 添加/更新消费组 

• clusterName 创建在哪几个集群上 
• brokerName 创建在哪几个 broker 上 
• groupName 消费组名字 
• consumeEnable //是否可以消费 FALSE 的话将无法进行消费 
• consumeBroadcastEnable //是否可以广播消费 
• retryQueueNums //重试队列的大小 
• brokerId //正常情况从哪消费 
• whichBrokerWhenConsumeSlowly//出问题了从哪消费 

1. 终端 在线的消费客户端查看，包括版本订阅信息和消费模式 
2. 消费详情 对应消费组的消费明细查看，这个消费组订阅的所有 Topic 的消费情况，每个queue 对应的消费 client 查看（包括 Retry 消息） 
3. 配置 查看变更消费组的配置 
4. 删除 在指定的 broker 上删除消费组

•  生产者页面 

通过 Topic 和 Group 查询在线的消息生产者客户端 
信息包含客户端主机 版本

• 消息查询页面 

1. 根据 Topic 和时间区间查询 *由于数据量大 最多只会展示 2000 条，多的会被忽略 
2. 根据 Topic 和 Key 进行查询 

• 最多只会展示 64 条 

1. 根据消息主题和消息 Id 进行消息的查询 
2. 消息详情可以展示这条消息的详细信息，查看消息对应到具体消费组的消费情况（如果异常，可以查看具体的异常信息）。可以向指定的消费组重发消息