单机RocketMQ-4.3.2
rocketmq-all-4.3.2-bin-release
下载地址:http://rocketmq.apache.org/dowloading/releases/
参考资料:https://www.cnblogs.com/YCcc/p/10863004.html
安装在192.168.1.133上
配置RocketMQ环境变量
vi /etc/profile
export ROCKETMQ_HOME=/usr/local/bigdata/rocketmq/rocketmq-all-4.3.2-bin-release
export PATH=$JAVA_HOME/bin:${ZOOKEEPER_HOME}/bin:${MONGO_HOME}/bin:${HADOOP_HOME}/bin:${HADOOP_HOME}/sbin:${SCALA_HOME}/bin:${SPARK_HOME}/bin:${SPARK_HOME}/sbin:${ROCKETMQ_HOME}/bin:$PATH
启动和停止namesvr
后台启动namesrv
nohup mqnamesrv &
后台启动namesrv,并将启动日志输入到指定日志文件中
nohup${ROCKETMQ_HOME}/bin/mqnamesrv >${ROCKETMQ_HOME}/../logs/namesrv.log &
查看启动信息
tail -f nohup.out
Java HotSpot(TM) 64-Bit Server VM warning: Using the DefNew young collector with the CMS collector is deprecated and will likely be removed in a future release
Java HotSpot(TM) 64-Bit Server VM warning: UseCMSCompactAtFullCollection is deprecated and will likely be removed in a future release.
The Name Server boot success. serializeType=JSON
查看namesrv服务是否启动成功
jps -l或者 ps -ef|grep mqnamesrv
[root@master rocketmq]#jps -l
20649 org.apache.rocketmq.namesrv.NamesrvStartup
20814 sun.tools.jps.Jps
[root@master rocketmq]#ps -ef|grep mqnamesrv
root 20646 7773 0 13:12 pts/0 00:00:00 /bin/sh ./rocketmq-all-4.3.2-bin-release/bin/mqnamesrv
root 20785 7773 0 13:14 pts/0 00:00:00 grep --color=auto mqnamesrv
停止namesrv
mqshutdown namesrv
启动broker
后台启动broker
nohup mqbroker -n 182.168.1.133:9876 &
或者后台启动namesrv,并将启动日志输入到指定日志文件中
nohup${ROCKETMQ_HOME}/bin/mqbroker -n 182.168.1.133:9876 >${ROCKETMQ_HOME}/../logs/broker.log &
查看启动信息
tail -f nohup.out
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/bigdata/rocketmq/rocketmq-all-4.3.2-bin-release/conf/hs_err_pid18856.log
原因是:bin/ 下的服务启动脚本 runserver.sh 、runbroker.sh 中对于内存的限制
修改配置文件
vim bin/runserver.sh
39 JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
改为
39JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn64m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=256m"
vim bin/runbroker.sh
39 JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g -Xmn4g"
改为
39JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn64m"
再次运行nohup mqbroker -n 182.168.1.133:9876 &
The broker[master, 172.17.0.1:10911] boot success. serializeType=JSON and name server is 182.168.1.133:9876
停止broker
mqshutdown broker
指定配置文件broker.conf后台启动broker
nohup${ROCKETMQ_HOME}/bin/mqbroker -c ${ROCKETMQ_HOME}/conf/broker.conf-n 182.168.1.133:9876 >${ROCKETMQ_HOME}/../logs/broker.log &
安装console监控平台
源码下载地址:https://github.com/apache/rocketmq-externals
参考资料:https://github.com/apache/rocketmq-externals/blob/master/rocketmq-console/doc/1_0_0/UserGuide_CN.md
https://guozh.net/rocketmqzhiconsolejiankongpingtaishiyongxiangjiesan/
修改配置文件application.properties,路径为:/usr/local/bigdata/rocketmq/rocketmq-externals-master/rocketmq-console/src/main/resources/application.properties
vim application.properties
rocketmq.config.namesrvAddr=192.168.1.99:9876
改为rocketmq所在机器的ip
rocketmq.config.namesrvAddr=192.168.133:9876
安装apache-maven-3.6.3
配置maven环境变量vim /etc/profile
export MAVEN_HOME=/usr/local/maven/apache-maven-3.6.3
export PATH=$JAVA_HOME/bin:${MAVEN_HOME}/bin:${ZOOKEEPER_HOME}/bin:${MONGO_HOME}/bin:${HADOOP_HOME}/bin:${HADOOP_HOME}/sbin:${SCALA_HOME}/bin:${SPARK_HOME}/bin:${SPARK_HOME}/sbin:${ROCKETMQ_HOME}/bin:$PATH
使配置文件生效source /etc/profile
测试maven环境变量是否配置成功
[root@master apache-maven-3.6.3]#mvn -version
Apache Maven 3.6.3 (cecedd343002696d0abb50b32b541b8a6ba2883f)
Maven home: /usr/local/maven/apache-maven-3.6.3
Java version: 1.8.0_201, vendor: Oracle Corporation, runtime: /usr/local/bigdata/jdk1.8.0_201/jre
Default locale: en_US, platform encoding: UTF-8
OS name: "linux", version: "3.10.0-957.el7.x86_64", arch: "amd64", family: "unix"
进入rocketmq-console文件夹,使用maven打jar包(下载依赖的jar包速度极慢,建议在windows上修改application.properties后提前打好jar包)
[root@master rocketmq-console]#pwd
/usr/local/bigdata/rocketmq/rocketmq-externals-master/rocketmq-console
打包
mvn clean package -Dmaven.test.skip=true
运行jar文件
nohup java -jar rocketmq-console-ng-1.0.1.jar &
浏览器访问Console管理界面:http://192.168.1.133:12581