1:下载: http://rocketmq.apache.org/docs/quick-start/, 直接下载源代码版本

 

 

 

 

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.sh
JAVA_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

https://github.com/apache/rocketmq-externals/releases/tag/rocketmq-console-1.0.0

下载 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 &

 

 

访问http://127.0.0.1:8080/

就可以了