RocketMQ集群搭建

目录

• 一、集群搭建理论：
• • 1.数据复制与刷盘策略：
  • 2.Broker集群模式：
• 二、磁盘阵列RAID:
• • 1.历史：
  • 2.等级：
  • 3.关键技术：
  • 4.分类：
  • 5.常见RAID等级：
• 三、集群搭建步骤：
• • （1）克隆rocketmqOS1：
  • （2）修改主机名：
  • （3）修改ip地址：
  • （4）修改配置文件：
  • （5）克隆一个rocketmqOS2:
  • （6）启动两台机器服务器：
• 四、mqadmin命令：

一、集群搭建理论：

1.数据复制与刷盘策略：

2.Broker集群模式：

二、磁盘阵列RAID: 1.历史：

2.等级：

3.关键技术：

4.分类：

5.常见RAID等级：

JBOD:

RAID0：

RAID1:

RAID10:

RAID01:

三、集群搭建步骤：

（1）克隆rocketmqOS1：

克隆完毕后，打开rocketmqOS1机器：

（2）修改主机名：

vim /etc/hostname
将主机名改成rocketmqOS1

（3）修改ip地址：

vim /etc/sysconfig/network-scripts/ifcfg-ens33
修改ipaddr为192.168.211.111，修改后重启reboot机器

（4）修改配置文件：

修改broker-a.properties:

cd /usr/src/software/rocketmq-4.9.2
vim conf/2m-2s-async/broker-a.properties

增加内容：192.168.211.111和192.168.211.112为我的两台机器的ip

namesrvAddr=192.168.211.111:9876;192.168.211.112:9876

修改broker-b-s.properties:

vim conf/2m-2s-async/broker-b-s.properties

增加内容：192.168.211.111和192.168.211.112为我的两台机器的ip

namesrvAddr=192.168.211.111:9876;192.168.211.112:9876
listenPort=11911
storePathRootDir=~/store-s
storePathCommitLog=~/store-s/commitlog
storePathConsumeQueue=~/store-s/consumequeue
storePathIndex=~/store-s/index
storeCheckpoint=~/store-s/checkpoint
abortFile=~/store-s/abort

需要增加的内容：

（5）克隆一个rocketmqOS2:

克隆后的主机名字为rocketmqOS2。

同样的像rocketmqOS1一样：
修改主机名hostname为：rocketmqOS2

vim /etc/hostname
将主机名改成rocketmqOS2

和修改ip地址为：192.168.211.112：

vim /etc/sysconfig/network-scripts/ifcfg-ens33
修改ipaddr为192.168.211.112，修改后重启reboot机器

修改broker-a-s.properties:

cd /usr/src/software/rocketmq-4.9.2
vim conf/2m-2s-async/broker-a-s.properties

增加以下内容：
namesrvAddr=192.168.211.111:9876;192.168.211.112:9876
listenPort=11911
storePathRootDir=~/store-s
storePathCommitLog=~/store-s/commitlog
storePathConsumeQueue=~/store-s/consumequeue
storePathIndex=~/store-s/index
storeCheckpoint=~/store-s/checkpoint
abortFile=~/store-s/abort

修改broker-b.properties:

修改broker-a.properties:

cd /usr/src/software/rocketmq-4.9.2
vim conf/2m-2s-async/broker-b.properties

增加内容：192.168.211.111和192.168.211.112为我的两台机器的ip

namesrvAddr=192.168.211.111:9876;192.168.211.112:9876

（6）启动两台机器服务器：

启动nameserver集群：

cd /usr/src/software/rocketmq-4.9.2
启动：nohup sh bin/mqnamesrv &
查看日志：tail -f ~/logs/rocketmqlogs/namesrv.log

启动两个master:
rocketmqOS1:

cd /usr/src/software/rocketmq-4.9.2
nohup sh bin/mqbroker -c conf/2m-2s-async/broker-a.properties &
tail -f ~/logs/rocketmqlogs/broker.log

rocketmqOS2:

cd /usr/src/software/rocketmq-4.9.2
nohup sh bin/mqbroker -c conf/2m-2s-async/broker-b.properties &
tail -f ~/logs/rocketmqlogs/broker.log

启动两个slave:

rocketmqOS1:

cd /usr/src/software/rocketmq-4.9.2
nohup sh bin/mqbroker -c conf/2m-2s-async/broker-b-s.properties &
tail -f ~/logs/rocketmqlogs/broker.log

rocketmqOS2:

cd /usr/src/software/rocketmq-4.9.2
nohup sh bin/mqbroker -c conf/2m-2s-async/broker-a-s.properties &
tail -f ~/logs/rocketmqlogs/broker.log

查看是否启动成功：jps

控制台的启动修改：然后重新打包启动：

四、mqadmin命令：