RocketMQ安装
Posted Lossdate
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了RocketMQ安装相关的知识,希望对你有一定的参考价值。
一、 环境
- RocketMQ: 4.5.1
https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.5.1/rocketmq-all-4.5.1-bin-release.zip
二、安装
-
下载rocketmq
4.5.1wget https://archive.apache.org/dist/rocketmq/4.5.1/rocketmq-all-4.5.1-bin-release.zip
-
解压
unzip rocketmq-all-4.5.1-bin-release.zip -d /opt cd /opt/ mv rocketmq-all-4.5.1-bin-release/rocketmq cd rocketmq/
-
配置环境变量
vim /etc/profile export ROCKET_HOME=/opt/rocketmq export PATH=$PATH:$ROCKET_HOME/bin
-
生效配置
. /etc/profile
-
修改脚本
rocketmq默认需要4G空间,虚拟机搭建可以修改小点
bin/runserver.sh
bin/runbroker.sh
例:#虚拟机内存比较小,由4G改为256M JAVA_OPT="$JAVA_OPT -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=64mm -XX:MaxMetaspaceSize=160mm"
jdk如果是8以上,则需要修改以下脚本
1)bin/runserver.shcd /opt/rocketmq/ vim bin/runserver.sh #删除 UseCMSCompactAtFullCollection UseParNewGC UseConcMarkSweepGC #虚拟机内存比较小,由4G改为256M JAVA_OPT="$JAVA_OPT -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=64mm -XX:MaxMetaspaceSize=160mm" -Xloggc修改为-Xlog:gc
2)bin/runbroker.sh
cd /opt/rocketmq/ vim bin/runbroker.sh #删除 PrintGCDateStamps PrintGCApplicationStoppedTime PrintAdaptiveSizePolicy UseGCLogFileRotation NumberOfGCLogFiles=5 GCLogFileSize=30m
3)bin/tools.sh
cd /opt/rocketmq/ vim bin/tools.sh #删除 JAVA_OPT="$JAVA_OPT -Djava.ext.dirs=$BASE_DIR/lib:$JAVA_HOME/jre/lib/ext"
-
测试(jdk8以上测试修改脚本)
mqnamesrv
mqbroker -n localhost:9876
-
启动
#启动NameServer mqnamesrv #新开窗口 #启动Broker mqbroker -n localhost:9876
-
启用SQL92消息过滤 (可选)
cd /opt/rocketmq/conf/ vim broker.conf #启用SQL92消息过滤 enablePropertyFilter=true #生效配置 mqbroker -c /opt/rocketmq/conf/broker.conf -p | grep -i propertyfilter #启动broker mqbroker -n localhost:9876 -c /opt/rocketmq/conf/broker.conf
三、RocketMQ环境测试
- 接收消息
#设置环境变量 export NAMESRV_ADDR=localhost:9876 #接收消息 sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
- 发送消息
#设置环境变量 export NAMESRV_ADDR=localhost:9876 #使用安装包的Demo发送消息 sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
- 关闭
#依次停止broker和namesrv mqshutdown broker mqshutdown namesrv
- etc
#查看主题 mqadmin topicList -n localhost:9876 #创建主题 mqadmin updateTopic -n localhost:9876 -b localhost:10911 -t tp_demo -w 6 #查看broker名 mqbroker -p #创建主题,8写8读 mqadmin updateTopic -b nodeA:10911 -n localhost:9876 -r 8 -t tp_demo -w 8 #删除主题的操作 mqadmin deleteTopic -c DefaultCluster deleteTopic -n localhost:9876 -t tp_demo #主题描述 mqadmin topicStatus -n localhost:9876 -t tp_demo
四、可视化工具 rocketmq-console
- 下载地址
https://github.com/apache/rocketmq-externals/archive/rocketmq-console-1.0.0.zip - 编译
IDEAD导入,JDK选择1.8
properties修改namesrvAddr
打包rocketmq.config.namesrvAddr=nodeA:9876
mvn clean package -DskipTests
- 启动
通过cmd启动
访问http://localhost:8080/java -jar rocketmq-console-ng-1.0.0.jar
以上是关于RocketMQ安装的主要内容,如果未能解决你的问题,请参考以下文章