本文只讲RocketMQ集群的搭建(异步复制)，具体理论知识后续会在写新文章详细介绍;
环境
- JDK1.8
- Centos7
主机-两台
- centos7_1 :172.16.54.130
- centos7_2 :172.16.54.128
软件资源
- JDK1.8 :https://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html
- RocketMQ4.5.2 :http://mirrors.tuna.tsinghua.edu.cn/apache/rocketmq/4.5.2/rocketmq-all-4.5.2-bin-release.zip
安装JDK
首先分别在两台主机上安装JDK1.8，具体安装方法这里就不说了，网上随便搜一搜都有；
配置RocketMQ
把下载的RocketMQ包分别上传到两台服务器上，然后用命令解压:
# unzip rocketmq-all-4.5.2-bin-release.zip
编写配置文件
这一步很重要，集群的搭建关键在于配置文件的编写，首先看看RocketMq配置文件的解析:
#所属集群名字
brokerClusterName=rocketmq-cluster
#broker名字，每队master和slave保持一致
brokerName=broker-a
#0 表示 Master，>0 表示 Slave
brokerId=0
#指定主机ip
brokerIP1 = 主机IP
#nameServer地址，分号分割
namesrvAddr=主机IP:9876;主机IP: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
#检测物理文件磁盘空间
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
#Broker 的角色
#- ASYNC_MASTER 异步复制Master
#- SYNC_MASTER 同步双写Master
#- SLAVE
brokerRole=ASYNC_MASTER
#刷盘方式
#- ASYNC_FLUSH 异步刷盘
#- SYNC_FLUSH 同步刷盘 flushDiskType=ASYNC_FLUSH
#checkTransactionMessageEnable=false
#abort 文件存储路径
abortFile=/usr/javawork/apache-rocketmq/store/abort
#限制的消息大小 maxMessageSize=65536
以上配置可根据个人需求加入到自己的配置文件中；RocketMQ官方已经为我们创建好了简单的集群配置文件，进去解压后的文件夹，在进入到conf文件夹，可以看到里面有三个文件夹：
- 2m-2s-async :2个master，2个slave，async异步复制
- 2m-2s-sync :2个master，2个slave，sync同步双写
- 2m-noslave :2个master,没有slave
这里我们用async异步复制模式，进入文件夹，分别编辑：
centos7_1主机编辑如下两个配置文件
注意，master和slave的文件存储路径不能用同一个路径，所以必须要区分开。
broker-a.properties
brokerClusterName=DefaultCluster
brokerName=broker-a
brokerId=0
deleteWhen=04
fileReservedTime=48
brokerRole=ASYNC_MASTER
flushDiskType=ASYNC_FLUSH
namesrvAddr=172.16.54.128:9876;172.16.54.130:9876
listenPort=10911
#存储路径
storePathRootDir=/usr/local/rocketmq/master/store
#commitLog 存储路径
storePathCommitLog=/usr/local/rocketmq/master/store/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/usr/local/rocketmq/master/store/consumequeue
#消息索引存储路径
storePathIndex=/usr/local/rocketmq/master/store/index
#checkpoint 文件存储路径
storeCheckpoint=/usr/local/rocketmq/master/store/checkpoint
这个监听端口设置设置成10911后还会自动监听10909,10912这两个端口，所以要配置文件要避免设置到相应的端口。
broker-a-s.properties
brokerClusterName=DefaultCluster
brokerName=broker-a
brokerId=1
deleteWhen=04
fileReservedTime=48
brokerRole=SLAVE
flushDiskType=ASYNC_FLUSH
namesrvAddr=172.16.54.128:9876;172.16.54.130:9876
listenPort=20911
#存储路径
storePathRootDir=/usr/local/rocketmq/slave/store
#commitLog 存储路径
storePathCommitLog=/usr/local/rocketmq/slave/store/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/usr/local/rocketmq/slave/store/consumequeue
#消息索引存储路径
storePathIndex=/usr/local/rocketmq/slave/store/index
#checkpoint 文件存储路径
storeCheckpoint=/usr/local/rocketmq/slave/store/checkpoint
这个监听端口设置设置成20911后还会自动监听20909,20912这两个端口，所以要配置文件要避免设置到相应的端口。
centos7_2主机编辑如下两个配置文件
和centos7_1主机配置一样，这边就不写了，不过brokerName要设置成不同的，我这边设置成broker-b。
设置RocketMQ运行的JVM内存(非必须)
此项设置非必须，如果你主机内存很大的话可以不设置，RocketMQ默认要8G。
进入rocketmq-all-4.5.2-bin-release/bin目录，两台主机分别设置runbroker.sh和runserver.sh这两个文件。
- runbroker.sh：找到如下一行配置
JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g -Xmn4g"
改成：
JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m"
- runserver.sh: 找到如下一行配置
JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
改成：
JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
启动RocketMQ
启动RocketMQ前为了方便访问，先关闭两台主机的防火墙。执行如下命令：
# service firewalld stop
进入rocketmq-all-4.5.2-bin-release/bin这个目录，两台主机分别执行以下命令：
- 启动namesrv
# nohup sh mqnamesrv &
- 启动broker-master
# nohup sh mqbroker -c ../conf/2m-2s-async/broker-a.properties &
- 启动broker-slave
# nohup sh mqbroker -c ../conf/2m-2s-async/broker-a-s.properties &
注意两台主机启动broker时后面的-c记得加载你配置好的配置文件路径，别加载错了
搭建Console可视化控制台
任意一台机器或者本地下载Console源码，地址：https://github.com/apache/rocketmq-externals，或者有git的话直接用命令拉取：
# git clone https://github.com/apache/rocketmq-externals.git
进去目录：
# cd rocketmq-externals-master/rocketmq-console
修改配置文件：
# vim src/main/resources/application.properties
添加两个namesvr的主机ip
rocketmq.config.namesrvAddr=172.16.54.128:9876;172.16.54.130:9876
然后进项目跟目录，运行项目
# mvn sprint-boot:run
浏览器访问：
image
原文地址: https://mjava.top
