一、RocketMQ的安装
1、文档
官方网站
GitHub
https://github.com/apache/rocketmq
2、下载
wget https://mirror.bit.edu.cn/apache/rocketmq/4.7.0/rocketmq-all-4.7.0-bin-release.zip
我们是基于Centos8来的,面向官方文档学习,所以下载地址自然也是官方的。
去官方网站找合适的版本进行下载,目前我这里最新的是4.7.0版本。
http://rocketmq.apache.org/dowloading/releases/
3、准备工作
3.1、解压
unzip rocketmq-all-4.7.0-bin-release.zip
3.2、安装jdk
sudo yum install java-1.8.0-openjdk-devel
4、启动
4.1、启动namesrv
cd rocketmq-all-4.7.0-bin-release/bin ./mqnamesrv
4.2、启动broker
cd rocketmq-all-4.7.0-bin-release/bin ./mqbroker -n localhost:9876
常见错误以及解决方案:
常见错误:启动broker失败 Cannot allocate memory
[root@node-113b bin]# ./mqbroker -n localhost:9876 Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00000005c0000000, 8589934592, 0) failed ; error='Cannot allocate memory' (errno=12)# # There is insufficient memory for the Java Runtime Environment to continue. # Native memory allocation (mmap) failed to map 8589934592 bytes for committing reserved memory. # An error report file with more information is saved as: # /usr/local/rocketmq/bin/hs_err_pid1997.log
解决方案:
是由于默认内存分配的太大了,超出了本机内存,直接OOM了。
修改bin/目录下的如下两个脚本
runbroker.sh runserver.sh
在这两个脚本里都搜索-server -Xms
,将其内存分配小点,自己玩的话512MB就足够了,够够的了!
4.3、启动成功标识
namesrv启动成功标识:
二、RocketMQ控制台的安装
控制台目前获取方式有如下两种:
- 第三方网站去下载现成的,比如csdn等。
- 官方源码包自己编译而成,官方没有现成的。
我们这里当然采取官方方式。
1、官方文档
github仓库
https://github.com/apache/rocketmq-externals
中文指南
https://github.com/apache/rocketmq-externals/blob/master/rocketmq-console/doc/1_0_0/UserGuide_CN.md
2、下载源码
https://codeload.github.com/apache/rocketmq-externals/zip/master
3、修改配置(可选)
我们下载完解压后的文件目录如下:
修改rocketmq-console\src\main\resources\application.properties
文件的server.port
就欧了。默认8080。
4、编译打包
进入rocketmq-console
,然后用maven进行编译打包
mvn clean package -DskipTests
打包完会在target下生成我们spring boot的jar程序,直接java -jar
启动完事。
5、启动控制台
将编译打包好的springboot程序扔到服务器上,执行如下命令进行启动
java -jar rocketmq-console-ng-1.0.1.jar --rocketmq.config.namesrvAddr=127.0.0.1:9876
如果想后台启动就nohup &
访问一下看看效果: