RocketMQ——安装篇


一、安装清单

NameServer和BokerServer 下载地址:https://github.com/apache/rocketmq/releases/tag/rocketmq-all-4.9.3   RocketMQ Dashboard 下载地址: https://github.com/apache/rocketmq-dashboard  dashboard下载到源码后,打包jar(rocketmq-dashboard-1.0.1.jar)  

一、安装过程

以下是单点模式的安装过程

1.整体安装过程

先启动NameServer,再启动BokerServer,最后安装Dashboard   注意:Rocket默认设置的堆内存都比较大,默认8G,测试时需要自行调整   2.测试时调整内存 runserver.sh JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m" 改为 JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn1g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"   JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m" 改为 JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn1g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"   runbroker.sh JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g" 改为 JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g"   3.启动RocketMQ
#先启动NameServer
sh bin/mqnamesrv &
#验证namesrv. log是否启动成功
tail -f -n 50 ~/logs/rocketmqlogs/namesrv.log
#再启动BrokerServer
sh bin/mqbroker -c conf/broker.conf -n 127.0.0.1:9876 &
#验证broker.log是否启动成功
tail -f -n 50 ~/logs/rocketmqlogs/broker.log
  4.启动部署dashboard
#运行jar
java -jar rocketmq-dashboard-1.0.1.jar &

 

dashboard后台管理界面

5.验证消息生产消费
#设置Namesrv服务器的地址
export NAMESRV_ADDR=127.0.0.1:9876
#执行生产者Producer发送测试消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
#执行消费者Consumer消费测试消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

三、其他集群模式配置