配置搭建单机rocketmq及rocketmq集群

废话不说，直接就干

单节点rocketmq搭建：

1、官网下载rocketmq安装包：rocketmq-all-4.7.1-bin-release.zip

http://rocketmq.apache.org/release_notes/release-notes-4.7.1/

2、解压后，修改conf目录下的brocker.conf配置文件

namesrvAddr = localhost:9876
brokerClusterName = star-rocketmq-broker
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
storePathRootDir=/data/work/rocketmq/store
storePathCommitLog=/data/logs/rocketmq/commitlog

配置文件详解：

#所属集群名字
 
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 小时
 
fileReservedTime=120
 
#commitLog 每个文件的大小默认 1G
 
mapedFileSizeCommitLog=1073741824
 
#ConsumeQueue 每个文件默认存 30W 条，根据业务情况调整
 
mapedFileSizeConsumeQueue=300000
 
#destroyMapedFileIntervalForcibly=120000
 
#redeleteHangedFileInterval=120000
 
#检测物理文件磁盘空间
 
diskMaxUsedSpaceRatio=88
 
#存储路径
 
storePathRootDir=/usr/local/rocketmq/store
 
#commitLog 存储路径
 
storePathCommitLog=/usr/local/rocketmq/store/commitlog
 
#消费队列存储路径存储路径
 
storePathConsumeQueue=/usr/local/rocketmq/store/consumequeue
 
#消息索引存储路径
 
storePathIndex=/usr/local/rocketmq/store/index
 
#checkpoint 文件存储路径
 
storeCheckpoint=/usr/local/rocketmq/store/checkpoint
 
#abort 文件存储路径
 
abortFile=/usr/local/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
 
#发消息线程池数量
 
#sendMessageThreadPoolNums=128
 
#拉消息线程池数量
 
#pullMessageThreadPoolNums=128

3、修改jvm参数,需要修改bin目录下的runserver.sh和runbroker.sh

 

 4、先启动namesrve

nohup ./mqnamesrv &

5、然后启动broker

nohup ./mqbroker -c /data/app/rocketmq/conf/broker.conf > /dev/null 2>&1 &

6、然后测试是否正常，创建topic，然后查看topic状态，然后删除

sh mqadmin updatetopic -n localhost:9876 -c "broker名称" -t “topic名称”   创建指定topic
sh mqadmin topicstatus -n localhost:9876 -t “topic名称”                                    查看指定topic
sh mqadmin deletetopic -n localhost:9876 -c “broker名称” -t “topic名称”      删除指定topic