Rocketmq集群高可用之主从模式搭建

1、修改RocketMQ(启动内存配置, 两个机器都要修改-如果有必要的话)
vim runserver.sh
JAVA_OPT="${JAVA_OPT} -server -Xms528m -Xmx528m -Xmn256m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

vim runbroker.sh
JAVA_OPT="${JAVA_OPT} -server -Xms528m -Xmx528m -Xmn256m"

启动两个机器的 nameserver
nohup sh bin/mqnamesrv &


2、编辑并启动rocketmq命令
conf/目录下有多个目录，如：
2m-2s-async 表示双主双从，异步复制，再里面有四个配置文件(如果只是主从即只需修改两个配置文件即可)
2m-2s-sync  表示双主双从，同步复制，再里面有四个配置文件(如果只是主从即只需修改两个配置文件即可)

主节点
编辑：conf/2m-2s-async/broker-a.properties
namesrvAddr=192.168.159.129:9876;192.168.159.130:9876
brokerClusterName=XdclassCluster   #节点名称保持一致
brokerName=broker-a                #boker名称保持一致
brokerId=0                         #borkerID主节点为0，从节点大于0
deleteWhen=04
fileReservedTime=48
brokerRole=ASYNC_MASTER            #boker角色主节点为主节点异步复制（根据选择的2m-2s-async）
flushDiskType=ASYNC_FLUSH

启动：
nohup sh bin/mqbroker -c conf/2m-2s-async/broker-a.properties &



从节点：
编辑：conf/2m-2s-async/broker-a.properties
namesrvAddr=192.168.159.129:9876;192.168.159.130:9876
brokerClusterName=XdclassCluster
brokerName=broker-a
brokerId=1                         #borkerID主节点为0，从节点大于0
deleteWhen=04
fileReservedTime=48
brokerRole=SLAVE                   #boker角色从节点为slave备节点
flushDiskType=ASYNC_FLUSH

启动：
nohup sh bin/mqbroker -c conf/2m-2s-async/broker-a.properties &



3、使用管控台
编辑：/opt/rocketmq-externals/rocketmq-console/src/main/resources/application.properties
增加： rocketmq.config.namesrvAddr=192.168.159.129:9876;192.168.159.130:9876
编译打包：
mvn clean package -Dmaven.test.skip=true
或
mvn install -Dmaven.test.skip=true

启动：
java -jar rocketmq-console-ng-1.0.0.jar