1.RocketMQ安装包下载
2.FinalShell连接虚拟机
3.上传bin压缩包并解压
4.创建基础目录结构
5.修改Hosts文件
6.设置配置文件broker-a.properties
#所属集群名字
brokerClusterName=rocketmq-cluster
#broker名字,注意此处不同的配置文件填写的不一样
brokerName=broker-a
#0表示Master主节点, > 0表示slave从节点
brokerId=0
#nameServer地址,分号分割
namesrvAddr=rocketmq-nameserver1:9876
#在发送消息时,自动创建服务器不存在的Topic,默认创建的队列数
defaultTopicQueueNums=4
#是否允许Broker 自动创建Topic,建议线下开启,线上关闭
autoCreateTopicEnable=true
#是否允许Broker自动创建订阅组,建议线下开启,线上关闭
autoCreateSubscriptionGroup=true
#Broker 对外服务的监听端口
listenPort=10911
#册除文件时间点,默认是凌晨4点
deleteWhen=04
#文件保留时间,默认48小时
ileReservedTime=120
#commitLog每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每个文件默认存30w条,根据业务情况调整
mapedFileSizeConsumeQueue=300000
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#检测物理文件磁盘空间
diskMaxUsedSpaceRatio=88
#存储路径
storePathRootDir=/usr/local/server/mq/rocketmq/store
#commitLog存储路径
storePathCommitLog=/usr/local/server/mq/rocketmq/store/commitlog
#消费队列存储路径
storePathConsumeQueue=/usr/local/server/mq/rocketmq/store/consumequeue
#消息索引存储路径
storePathIndex=/usr/local/server/mq/rocketmq/store/index
#checkpoint文件存储路径
storeCheckpoint=/usr/local/server/mq/rocketmq/store/checkpoint
#abort文件存储路径
abortFile=/usr/local/server/mq/rocketmq/store/abort
#限制的消息大小
maxMessageSize=65536
# flushCommitLogLeastPages=4
# flushConsumeQueueLeastPages=2
# flushCommitLogThoroughInterval=10000
# flushConsumeQueueThoroughInterval=60000
#Broker的角色
# - ASYNC_MASTER异步复制Master
# - SYNC_MASTER同步双写Master
# - SLAVE
brokerRole=ASYNC_MASTER
#刷盘方式
# - ASYNC_FLUSH 异步刷盘
# - SYNC_FLUSH 同步刷盘
flushDiskType=ASYNC_FLUSH
#checkTransactionMessageEnable=false
#发消息线程池数量
#sendMessageTreadPoolNums=128
#拉消息线程池数量
#pullMessageThreadPoolNums=128
注意!存储路径store文件夹不能自己创建,否则会起冲突报错
只需要把路径写在配置文件中程序会自己创建
7.进入conf目录,替换所有xml中的${user.home},保证日志路径正确
sed -i s#${user.home}#/usr/local/server/mq/rocketmq#g *.xml
8.修改运行配置文件
9.先启动namesrv(&表示后台运行)
nohup sh mqnamesrv &
10.再启动broker
nohup sh mqbroker &
#如果要指定配置文件启动
nohup sh mqbroker -c /usr/local/server/mq/rocketmq/conf/2m-2s-async/broker-a.properties &
11.输入jps命令查看一下
12.关闭namesrv(要在rocketmq的bin目录下)
sh mqshutdown namesrv
13.关闭broker(要在rocketmq的bin目录下)
sh mqshutdown broker
启动成功,安装完成 !