一、下载资料及环境准备
这里 下载路径 可以下载对应的版本,本文以 4.9.5 为例:下载这里的Binary 为Linux 安装文件,Source 也下载,方便后续使用。

将下载后的包进行解压:

由于RockerMQ 的建议运行环境较大,但平时自己的服务器没有这么大,所以进行内存调整 。前提是将解压后的文件夹放入 /app/rocketmq,且Linux 虚拟机已安装jdk。现修改 runserver.sh 文件的内存大小:
cd /app/rocketmq/rocketmq-all-4.9.5-bin-release/bin
vim runserver.sh
输入/MaxMetaspaceSize 找到对应修改的地方 ,将这一行改为:
JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
同样调整 runbroker.sh 文件中的内存:
将
JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g"
修改为:
JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g"
查看本机已安装的jdk信息及环境变量:(此处将不介绍如何安装及配置环境变量,网上资料很多)

二、启动、停止 RocketMQ,消息收发
RocketMQ 的后端服务分为 nameserver 和 broker 两个服务。
1、后台启动 nameserver 服务
cd /app/rocketmq/rocketmq-all-4.9.5-bin-release/
nohup bin/mqnamesrv &

用 Clone session 复制一个连接会话用来跟踪日志:
cd /app/rocketmq/rocketmq-all-4.9.5-bin-release/
ll # 查看目录文件
tail -fn 500 nohup.out
查看日志,可以看到 Name server 启动成功的日志输出:

也可以 jps 查看Java 进程(看到 NamesrvStartup 就是刚才启动的进程):

2、后台启动 broker 服务
启动 broker 之前先要修改配置:conf/broker.conf: autoCreateTopicEnable=true
cd /app/rocketmq/rocketmq-all-4.9.5-bin-release/conf/
vim broker.conf
改好后保存即可:

后台启动 broker:
cd /app/rocketmq/rocketmq-all-4.9.5-bin-release/
nohup bin/mqbroker &
同样查看 nohup.out 的日志,如显示以下则表示成功启动:

同样使用 jps 指令可以检查服务的启动状态。使用 jsp 指令后,可以看到一个名为 BrokerStartup 的进程,则表示 broker 服务启动完成:

3、配置 MQ 相关的环境变量
vim /etc/profile
# 加入对应的环境变量
export ROCKETMQ_HOME=/app/rocketmq/rocketmq-all-4.9.5-bin-release
export PATH=$PATH:${ROCKETMQ_HOME}/bin
export NAMESRV_ADDR=localhost:9876
配置完成后退出并保存,使用 source /etc/profile 使环境变量生效。
后期可以直接使用 mqnamesrv 和 mqbroker 指令,具体可以参考下图使用:


4、在当前窗口启动MQ服务
配置了上述环境变量就可以快捷使用mq 命令启动(当前窗口):
1、启动 namesrv 如下
mqnamesrv start

2、启动 broker 如下:
mqbroker start

5、停止MQ 服务
1、停止 namesrv 服务 :
mqshutdown namesrv
2、停止 broker 服务:
mqshutdown broker
使用 jps 查看 namesrv 和 broker 的服务 已经停止:

6、使用自带测试类,实现消息收发
1、 生产者发送消息:
tools.sh org.apache.rocketmq.example.quickstart.Producer
这个指令默认往RocketMQ中发送1000条消息。在命令行窗口可以看到发送消息的日志:

2、消费者消费消息:
tools.sh org.apache.rocketmq.example.quickstart.Consumer
消费者启动完成后,可以看到消费到的消息:

注意:Consumer消费者的指令并不会主动结束,他会继续挂起,等待消费新的消息。我们可以使用CTRL+C停止该进程。
三、搭建RocketMQ Dashboard
在 下载链接 的底部可以找到 RocketMQ Dashboard 后下载:
解压后使用开发工具打开,配置好maven 工具,然后修改配置 rocketmq.config.namesrvAddr

使用 maven 插件进行打包:

在Linux 系统中执行以下命令启动 rocketmq-dashboard :
java -jar rocketmq-dashboard-1.0.1-SNAPSHOT.jar
使用ip + 端口号进行访问: http://192.168.217.130:8080/#/


至此RocketMQ 的namesrv 和 broker 、dashboard 就搭建好啦!



















