RocketMQ两主两从部署

一、下载rocketmq
https://rocketmq.apache.org/
版本4.9.8
二、安装

#解压授权：
unzip rocketmq-all-4.9.8-bin-release.zip 
mv rocketmq-all-4.9.8-bin-release rocketmq
chown -R rocketmq:rocketmq /mnt/rocketmq

#创建用户
useradd rocketmq
#切换用户
sudo -u rocketmq bash
=====================================================
以下操作都是rocketmq用户
#添加环境变量
vim ~/.bashrc

export ROCKERMQ_HOME=/mnt/rocketmq
JAVA_HOME=/mnt/jdk1.8.0_401
export PATH=$ROCKERMQ_HOME/bin:$JAVA_HOME/bin:$PATH

#加载
cd ~ ; source ~/.bashrc

三、修改配置
1.修改启动内存参数，默认是8g

vim /mnt/rocketmq/bin/runserver.sh
#大概在71行
JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

vim /mnt/rocketmq/bin/runbroker.sh
#大概在85行
JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m"

2.修改jdk变量，因为有时候程序读不到

#需要修改三个文件，都是一样的配置
vim /mnt/rocketmq/bin/runserver.sh
vim /mnt/rocketmq/bin/runbroker.sh
vim /mnt/rocketmq/bin/tools.sh
#找到这三行，更改第一行的信息、注释下面的两行
[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=/mnt/jdk1.8.0_401
#[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=/usr/java
#[ ! -e "$JAVA_HOME/bin/java" ] && error_exit "Please set the JAVA_HOME variable in your environment, We need java(x64)!"

3.修改broker配置
A服务器

vim /mnt/rocketmq/conf/2m-2s-async/broker-a.properties
#所属集群名字
brokerClusterName=rocketmq-cs
#broker名字，注意此处不同的配置文件填写的不一样
brokerName=broker-a
#0 表示 Master，>0 表示 Slave
brokerId=0
#nameServer地址，分号分割
namesrvAddr=192.168.0.215:9876;192.168.0.222:9876
#在发送消息时，自动创建服务器不存在的topic，默认创建的队列数
defaultTopicQueueNums=4
#是否允许Broker自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=false
#Broker对外服务的监听端口
listenPort=13920
#删除文件时间点，默认凌晨4点
deleteWhen=04
#文件保留时间，默认48小时
fileReservedTime=48
#检测物理文件磁盘空间
diskMaxUsedSpaceRatio=75
#存储路径
storePathRootDir=/mnt/rocketmq/data/broker-a
#commitLog存储路径
storePathCommitLog=/mnt/rocketmq/data/broker-a/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/mnt/rocketmq/data/broker-a/consumequeue
#消息索引存储路径
storePathIndex=/mnt/rocketmq/data/broker-a/index
#checkpoint文件存储路径
storeCheckpoint=/mnt/rocketmq/data/broker-a/checkpoint
#abort文件存储路径
abortFile=/mnt/rocketmq/data/broker-a/abort
#Broker的角色
#-ASYNC_MASTER异步复制Master
#-SYNC_MASTER同步双写Master
#-SLAVE
brokerRole=Master
#刷盘方式
#-ASYNC_FLUSH异步刷盘
#-SYNC_FLUSH同步刷盘
flushDiskType=ASYNC_FLUSH
#开启ACL认证机制
aclEnable=true

vim /mnt/rocketmq/conf/2m-2s-async/broker-b-s.properties
#所属集群名字 
brokerClusterName=rocketmq-cs
#broker名字，注意此处不同的配置文件填写的不一样
brokerName=broker-b
#0 表示 Master，>0 表示 Slave
brokerId=1
#nameServer地址，分号分割
namesrvAddr=192.168.0.215:9876;192.168.0.222:9876
#在发送消息时，自动创建服务器不存在的topic，默认创建的队列数
defaultTopicQueueNums=4
#是否允许Broker自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=false
#Broker对外服务的监听端口
listenPort=15920
#删除文件时间点，默认凌晨4点
deleteWhen=04
#文件保留时间，默认48小时
fileReservedTime=48
#检测物理文件磁盘空间
diskMaxUsedSpaceRatio=75
#存储路径
storePathRootDir=/mnt/rocketmq/data/broker-b
#commitLog存储路径
storePathCommitLog=/mnt/rocketmq/data/broker-b/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/mnt/rocketmq/data/broker-b/consumequeue
#消息索引存储路径
storePathIndex=/mnt/rocketmq/data/broker-b/index
#checkpoint文件存储路径
storeCheckpoint=/mnt/rocketmq/data/broker-b/checkpoint
#abort文件存储路径
abortFile=/mnt/rocketmq/data/broker-b/abort
#Broker的角色
#-ASYNC_MASTER异步复制Master
#-SYNC_MASTER同步双写Master
#-SLAVE
brokerRole=SLAVE
#刷盘方式
#-ASYNC_FLUSH异步刷盘
#-SYNC_FLUSH同步刷盘
flushDiskType=ASYNC_FLUSH
#开启ACL认证机制
aclEnable=true

B服务器

vim /mnt/rocketmq/conf/2m-2s-async/broker-a-s.properties
brokerClusterName=rocketmq-cs
brokerName=broker-a
brokerId=1
#nameServer地址，分号分割
namesrvAddr=192.168.0.215:9876;192.168.0.222:9876
#在发送消息时，自动创建服务器不存在的topic，默认创建的队列数
defaultTopicQueueNums=4
#是否允许Broker自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=false
#Broker对外服务的监听端口
listenPort=15920
#删除文件时间点，默认凌晨4点
deleteWhen=04
#文件保留时间，默认48小时
fileReservedTime=48
#检测物理文件磁盘空间
diskMaxUsedSpaceRatio=75
#存储路径
storePathRootDir=/mnt/rocketmq/data/broker-a
#commitLog存储路径
storePathCommitLog=/mnt/rocketmq/data/broker-a/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/mnt/rocketmq/data/broker-a/consumequeue
#消息索引存储路径
storePathIndex=/mnt/rocketmq/data/broker-a/index
#checkpoint文件存储路径
storeCheckpoint=/mnt/rocketmq/data/broker-a/checkpoint
#abort文件存储路径
abortFile=/mnt/rocketmq/data/broker-a/abort
#Broker的角色
#-ASYNC_MASTER异步复制Master
#-SYNC_MASTER同步双写Master
#-SLAVE
brokerRole=SLAVE
#刷盘方式
#-ASYNC_FLUSH异步刷盘
#-SYNC_FLUSH同步刷盘
flushDiskType=ASYNC_FLUSH
#开启ACL认证机制
aclEnable=true

vim /mnt/rocketmq/conf/2m-2s-async/broker-b.properties 
brokerClusterName=rocketmq-cs
brokerName=broker-b
brokerId=0
#nameServer地址，分号分割
namesrvAddr=192.168.0.215:9876;192.168.0.222:9876
#在发送消息时，自动创建服务器不存在的topic，默认创建的队列数
defaultTopicQueueNums=4
#是否允许Broker自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=false
#Broker对外服务的监听端口
listenPort=13920
#删除文件时间点，默认凌晨4点
deleteWhen=04
#文件保留时间，默认48小时
fileReservedTime=48
#检测物理文件磁盘空间
diskMaxUsedSpaceRatio=75
#存储路径
storePathRootDir=/mnt/rocketmq/data/broker-b
#commitLog存储路径
storePathCommitLog=/mnt/rocketmq/data/broker-b/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/mnt/rocketmq/data/broker-b/consumequeue
#消息索引存储路径
storePathIndex=/mnt/rocketmq/data/broker-b/index
#checkpoint文件存储路径
storeCheckpoint=/mnt/rocketmq/data/broker-b/checkpoint
#abort文件存储路径
abortFile=/mnt/rocketmq/data/broker-b/abort
#Broker的角色
#-ASYNC_MASTER异步复制Master
#-SYNC_MASTER同步双写Master
#-SLAVE
brokerRole=Master
#刷盘方式
#-ASYNC_FLUSH异步刷盘
#-SYNC_FLUSH同步刷盘
flushDiskType=ASYNC_FLUSH
#开启ACL认证机制
aclEnable=true

4.修改acl配置,根据需求添加白名单

vim /mnt/rocketmq/conf/plain_acl.yml
globalWhiteRemoteAddresses:
  - 192.168.0.*

accounts:
  - accessKey: RocketMQ
    secretKey: 12345678
    whiteRemoteAddress:
    admin: false
    defaultTopicPerm: DENY
    defaultGroupPerm: SUB
    topicPerms:
      - topicA=DENY
      - topicB=PUB|SUB
      - topicC=SUB
    groupPerms:
      # the group should convert to retry topic
      - groupA=DENY
      - groupB=PUB|SUB
      - groupC=SUB

  - accessKey: rocketmq2
    secretKey: 12345678
    whiteRemoteAddress: 192.168.1.*
    # if it is admin, it could access all resources
    admin: true

四、根据配置创建目录

mkdir -pv /mnt/rocketmq/data/broker-{a,b}/{commitlog,consumequeue,index}
mkdir -pv /mnt/rocketmq/conf/acl
mkdir -pv /mnt/rocketmq/log

五、启动、关闭、查看集群状态

#启动
#A服务器
cd /mnt/rocketmq/bin

nohup sh mqnamesrv >/mnt/rocketmq/log/mqnamesrv.log &

nohup sh mqbroker -c /mnt/rocketmq/conf/2m-2s-async/broker-a.properties >/mnt/rocketmq/log/broker-a.log &

nohup sh mqbroker -c /mnt/rocketmq/conf/2m-2s-async/broker-b-s.properties >/mnt/rocketmq/log/broker-b-s.log &

#B服务器
cd /mnt/rocketmq/bin
nohup sh mqnamesrv >/mnt/rocketmq/log/mqnamesrv.log &

nohup sh mqbroker -c /mnt/rocketmq/conf/2m-2s-async/broker-a-s.properties >/mnt/rocketmq/log/broker-a-s.log &

nohup sh mqbroker -c /mnt/rocketmq/conf/2m-2s-async/broker-b.properties >/mnt/rocketmq/log/broker-b.log &

#关闭（先关闭broker）
cd /mnt/rocketmq/bin/

sh mqshutdown broker

sh mqshutdown namesrv

#查看集群状态
cd /mnt/rocketmq/bin/
sh mqadmin clusterList -n 192.168.0.215:9876
#Cluster Name     #Broker Name            #BID  #Addr                  #Version                #InTPS(LOAD)       #OutTPS(LOAD) #PCWait(ms) #Hour #SPACE
rocketmq-cs       broker-a                0     192.168.0.215:13920    V4_9_8                   0.00(0,0ms)         0.00(0,0ms)          0 479287.17 0.0100
rocketmq-cs       broker-a                1     192.168.0.222:15920    V4_9_8                   0.00(0,0ms)         0.00(0,0ms)          0 479287.17 0.0100
rocketmq-cs       broker-b                0     192.168.0.222:13920    V4_9_8                   0.00(0,0ms)         0.00(0,0ms)          0 479287.17 0.0100
rocketmq-cs       broker-b                1     192.168.0.215:15920    V4_9_8                   0.00(0,0ms)         0.00(0,0ms)          0 479287.17 0.0100

六、添加主题和查看主题

#添加topic
sh mqadmin updatetopic -n 192.168.0.215:9876 -t CENTER-DATA-CENTER-INVENTORY -c rocketmq-cs

create topic to 192.168.0.215:13920 success.
create topic to 192.168.0.222:13920 success.
TopicConfig [topicName=CENTER-DATA-CENTER-INVENTORY, readQueueNums=8, writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, order=false]

#查看topic
sh mqadmin topiclist -n 192.168.0.215:9876 -c

#Cluster Name         #Topic                                            #Consumer Group                                 
rocketmq-cs           SCHEDULE_TOPIC_XXXX                                                                                                               
rocketmq-cs           RMQ_SYS_TRANS_HALF_TOPIC                                                                                                          
rocketmq-cs           CENTER-DATA-CENTER-INVENTORY                                                                                                      
rocketmq-cs           broker-b                                                                                                                          
rocketmq-cs           BenchmarkTest                                                                                                                     
rocketmq-cs           OFFSET_MOVED_EVENT                                                                                                                
rocketmq-cs           rocketmq-cs                                                                                                                       
rocketmq-cs           rocketmq-cs_REPLY_TOPIC                                                                                                           
rocketmq-cs           broker-a                                                                                                                          
rocketmq-cs           SELF_TEST_TOPIC 
#刚才创建的是第三个######################################

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 216,240评论 6赞 498
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 92,328评论 3赞 392
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 162,182评论 0赞 353
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 58,121评论 1赞 292
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 67,135评论 6赞 388
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 51,093评论 1赞 295
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 40,013评论 3赞 417
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 38,854评论 0赞 273
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 45,295评论 1赞 310
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 37,513评论 2赞 332
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 39,678评论 1赞 348
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 35,398评论 5赞 343
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 40,989评论 3赞 325
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 31,636评论 0赞 22
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 32,801评论 1赞 268
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 47,657评论 2赞 368
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 44,558评论 2赞 352

RocketMQ两主两从部署

推荐阅读更多精彩内容