原创

linux安装rocketmq步骤

1.先安装jdk1.8+

2.下载rocketmq的安装包
官网下载地址: https://rocketmq.apache.org/dowloading/releases/
我下载的是4.3.0版:https://archive.apache.org/dist/rocketmq/4.3.0/rocketmq-all-4.3.0-bin-release.zip
3.下载完成后,上传到服务器
新建目录 mkdir -p /opt/app/rocketmq
将rocketmq-all-4.3.0-bin-release.zip上传至目录/opt/app/rocketmq下
4.解压缩rocketmq-all-4.3.0-bin-release.zip

5.创建rocketmq数据存放的目录,日志目录,索引目录,消费者队列的目录

mkdir -p /opt/app/rocketmq/store/{commitlog,consumequeue,index,checkpoint,abort}

6.修改配置文件conf/broker.conf,完整配置如下

#所属集群名称
brokerClusterName=DefaultCluster
#brock的名字
brokerName=broker-a
#brocker的编号,0表示master,大于0的是slave
brokerId=0
#凌晨4点删除数据
deleteWhen=04
#文件保存时间
fileReservedTime=48
#broker的角色,
brokerRole=ASYNC_MASTER
#写入磁盘的方式
flushDiskType=ASYNC_FLUSH
#nameserver的地址
namesrvAddr=192.168.124.13:9876
#在发送消息时, 自动创建服务器不存在的topic,默认创建的队列数
defaultTopicQueueNums=4
#是否允许Broker 自动创建Topic, 建议线下开启,线上关闭
autoCreateTopicEnable=true
#是否 允许Broker 自动创建订阅组, 建议线下开启,线上关闭
autoCreateSubscriptionGroup=true
#Broker 对外服务的监听端口
listenPort=10911
#存储路径
storePathRootDir=/opt/app/rocketmq/store
#commitLog 存储路径
storePathCommitLog=/opt/app/rocketmq/store/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue= /opt/app/rocketmq/store/consumequeue
#消息索 引存储路径
storePathIndex= /opt/app/rocketmq/store/index
#checkpoint 文件存储路径
storeCheckpoint= /opt/app/rocketmq/store/checkpoint
#abort文件存储路径
abortFile= /opt/app/rocketmq/store/abort

7.修改conf文件夹下面的logback_*.xml,使用以下命令把${user.home}替换成rocketmq的安装目录

sed -i 's#${user.home}#/opt/app/rocketmq#g' logback_*.xml

8.修改bin目录下的runbroker.sh,runserver.sh的javaoptions修改成下面的大小,避免启动保错(可视机器配置调整内存值大小)
JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m -XX:PermSize=128m -XX:MaxPermSize=320m"

9.后台启动namesrv
nohup sh bin/mqnamesrv -n 192.168.124.13:9876 &
10.查看启动日志
tail -f /opt/app/rocketmq/logs/rocketmq/logs/namesrv.log
11.后台运行启动broker
nohub sh bin/mqbroker &
12.查看启动日志
tail -f /opt/app/rocketmq/logs/rocketmqlogs/broker.log

13.也可以使用jps命令查看所有java的进程
jps

rocketmq

14.下载管理控制台jar包mqrocketmq-console-ng-1.0.0.jar
下载地址: https://qiniu.iotjike.com/doc/soft/mqrocketmq-console-ng-1.0.0.jar

下载后启动: 

java -jar /opt/app/rocketmq/logs/rocketmq/rocketmq-console-ng-1.0.0.jar --server.port=8561 --rocketmq.config.namesrvAddr=192.168.124.13:9876 &

启动后访问: http://192.168.124.13:8561 ,如下图所示

GCoverGCoverheadlimitexceeded

至此,安装rocketmq安装完成。

正文到此结束
Loading...