本文共 1776 字，大约阅读时间需要 5 分钟。

1:下载: , 直接下载源代码版本

2:使用maven进行源码编译:

mvn -Prelease-all -DskipTests clean install -U

3:环境配置

找到已经安装好的 jdk 位置，通过命令：/usr/libexec/java_home

在.zshrc中加入JAVA_HOME的环境变量

export JAVA_HOME=/Library/Java/JavaVirtualMachines/jdk1.8.0_201.jdk/Contents/Home

在.zshrc中加入JAVA_HOME的环境变量

ROCKETMQ_HOME=/Users/wangzeyu/Downloads/software/rocketmq/rocketmq-all-4.8.0-source-release

保存完生效

source ~/.bash_profile

调整启动内存vim bin/runserver.sh　　#调整nameserver启动的内存（如果服务器内存比较大，可以不调整），如果内存较小，不调整此文件，可能导致无法启动JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn512m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"　　vim bin/runbroker.shJAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m"

以守护进程的方式启动mqnamesrv

nohup sh bin/mqnamesrv &   这个命令可能会nohup: ignoring input and appending output to ‘nohup.out’,如果出现这个,执行: tail -f nohup.out这个时候ctrl+c就不会退出程序,仅仅是让程序后台运行

使用jsp查看启动

启动Broker

[root@wangzhi apache-rocketmq]# sh bin/mqbroker -n localhost:9876

使用jps查看启动

测试投递消息

需要先配置 NAMESRV_ADDR 到环境变量中 具体方法可以直接在终端输入命令，这种方式记录的 NAMESRV_ADDR 是临时的，关闭终端就生效了

export NAMESRV_ADDR=localhost:9876

发送消息测试  

可以看到终端输出大量日志，已经发送不了很多消息  

测试接受消息

sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

同样是终端输出大量日志，接受了很多消息   以上说明 RocketMQ 已经能正常使用了 

二、安装可视化控制台

1.下载项目

在 GitHub 中搜索 rocketmq-externals，其中 rocketmq-console 就是 RocketMQ 可视化控制台，我们可以将源码克隆下来，然后自己 mvn package，然后运行 jar 包。

或者直接下载官方提供的 1.0.0 版本的 rocketmq-console

下载 zip 包或者 tar 包

下载完后解压zip包

进入rocketmq-console文件夹

进入rocketmq-console的src/main/resources/文件夹

修改配置文件application.properties

配置rocketmq.config.namesrvAddr属性的值，即nameserver的服务地址

rocketmq.config.namesrvAddr=127.0.0.1:9876

保存修改后的配置文件，返回rocketmq-console目录

使用maven打包命令打包

mvn clean package -Dmaven.test.skip=true

打包完成后进入target目录

rocketmq-console-ng-2.0.0.jar即为打包后得到的jar包

启动程序

nohup java -jar rocketmq-console-ng-2.0.0.jar &

访问

就可以了

转载地址：https://blog.csdn.net/W_317/article/details/116562164 如侵犯您的版权，请留言回复原文章的地址，我们会给您删除此文章，给您带来不便请您谅解！