#集群名稱
brokerClusterName=rocket-nameserver
#broker-a,注意其它兩個分別為broker-b和broker-c
brokerName=broker-a
#brokerId等於0表示是MASTER節點,小於0是SLAVE節點,我這里全設置成主節點
brokerId=0
deleteWhen=04
fileReservedTime=48
#配置nameserver地址,多台以;分割:
namesrvAddr=rocket-nameserver-01:9876;rocket-nameserver-02:9876;rocket-nameserver-03:9876
#存儲路徑
storePathRootDir=/opt/rocketmq432/store
#commitlog存儲路徑
storePathCommitLog=/opt/rocketmq432/store/commitlog
#消息隊列
storePathConsumeQueue=/opt/rocketmq432/store/consumequeue
#消息索引
storePathIndex=/opt/rocketmq432/store/index
#checkpoint文件存儲過徑
storeCheckpoint=/opt/rocketmq432/store/checkpoint
#abort文件存儲路徑
abortFile=/opt/rocketmq432/store/abort
#限制的消息大小
maxMessageSize=65536
#角色和刷盤方式
brokerRole=ASYNC_MASTER
flushDiskType=ASYNC_FLUSH
啟動a:
1. nohup sh mqnamesrv &
2. nohup sh mqbroker -c /opt/rocketmq432/conf/2m-noslave/broker-a.properties autoCreateTopicEnable=true >/tmp/logs/mq.log 2>&1 &
啟動b:
1. nohup sh mqnamesrv &
2. nohup sh mqbroker -c /opt/rocketmq432/conf/2m-noslave/broker-b.properties autoCreateTopicEnable=true >/tmp/logs/mq.log 2>&1 &
啟動c:
1. nohup sh mqnamesrv &
2. nohup sh mqbroker -c /opt/rocketmq432/conf/2m-noslave/broker-c.properties autoCreateTopicEnable=true >/tmp/logs/mq.log 2>&1 &
停止服務:
先執行: sh mqshutdown broker
再執行: sh mqshutdown namesrv
消息隊列樣例測試導入:
export NAMESRV_ADDR=localhost:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer