SpringBoot整合RocketMq之===RocketMq集群（双主双从-4台机器）（无废话版）--------------------------------------------（二）

阳光穿透心脏的1/2处 2022-12-29 00:27 231阅读 0赞

# ![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70][] #

# 首先每台机器都要保证有rocketmq，可以按照单机rockemq来整到4台机器上。操作都是一样子的。 #

# 都成功以后才能进行4个机器的安装。 #

# [https://github.com/heidaodageshiwo/springboot\_rocketmq2][https_github.com_heidaodageshiwo_springboot_rocketmq2] #

# 4台机器修改  /etc/hosts（每台机器都要修改） #

#rocketmq  4台机器集群使用这个
    
     192.168.56.200 rocketmq-nameserver1
    
     192.168.56.201 rocketmq-nameserver2
    
     192.168.56.203 rocketmq-nameserver3
    
     192.168.56.204 rocketmq-nameserver4
    
     192.168.56.200 rocketmq-master1
    
     192.168.56.201 rocketmq-master2
    
     192.168.56.203 rocketmq-master1-slave
    
     192.168.56.204 rocketmq-master2-slave

# 1.单机使用的这个文件夹下的文件：2m-2s-async #

# 现在集群用这个（ 2m-2s-sync）每台机器都是修改这个文件夹下的文件 #

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 1][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 2][]

# 下面这4个文件：贴出来： #

# （注意：这4个文件，都要复制到这4台机器上面；但是里面的ip只要修改成每台机器的ip即可）； #

# 例如：204机器：  200就写200的ip   201就写201的ip   203就写203的ip   #

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 3][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 4][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 5][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 6][]

# broker-a.properties：（这是贴了204的ip，每台机器修改即可ip） #

#机器的ip地址
    
    brokerIP1=192.168.56.204
    #所属集群名字
    
    brokerClusterName=rocketmq-cluster
    
    #broker名字，注意此处不同的配置文件填写的不一样
    
    brokerName=broker-a
    
    #0 表示Master ,>0表示slave
    
    brokerId=0
    
    #nameServer 地址，分号分割
    
    namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876;rocketmq-nameserver3:9876;rocketmq-nameserver4:9876;
    
    #在发送消息时，自动创建服务器不存在的Topic,默认创建的队列数
    
    defaultTopicQueueNums=4
    
    #是否允许Broker 自动创建Topic，建议线下开启，线上关闭
    
    autoCreateTopicEnable=true
    
    #是否允许Broker 自动创建订阅组，建议线下开启，线上关闭
    
    autoCreateSubscriptionGroup=true
    
    #Broker 对外服务的监听端口
    
    listenPort=10911
    
    #删除文件时间点，默认是凌晨4点
    
    deleteWhen=04
    
    #文件保留时间，默认是48小时
    
    fileReservedTime=120
    
    #commitLog每个文件的大小默认1G
    
    mapedFileSizeCommitLog=1073741824
    
    #ConsumeQuene每个文件默认存30W条，根据业务情况调整
    
    mapedFileSizeConsumeQueue=300000
    
    #检测物理文件磁盘空间
    
    diskMaxUsedSpaceRatio=88
    
    #存储路径
    
    storePathRootDir=/home/rocketmq/rocketmq/store
    
    #commitLog存储路径
    
    storePathCommitLog=/home/rocketmq/rocketmq/store/commitlog
    
    #消费队列存储路径
    
    storePathConsumeQueue=/home/rocketmq/rocketmq/store/consumequeue
    
    #消费索引存储路径
    
    storePathIndex=/home/rocketmq/rocketmq/store/index
    
    #checkpoint 文件存储路径
    
    storeCheckpoint=/home/rocketmq/rocketmq/store/checkpoint
    
    #abort 文件存储路径
    
    abortFile=/home/rocketmq/rocketmq/store/abort
    
    #限制的消息大小
    
    maxMessageSize=65536
    
    #broker的角色
    
    #ASYNC_MASTER异步复制Master
    
    #SYNC_MASTER同步双写Master
    
    #SLAVE
    
    brokerRole=SYNC_MASTER
    
    #刷盘方式
    
    #ASYNC_FLUSH 异步刷盘
    
    #SYNC_FLUSH 同步刷盘
    
    flushDiskType=ASYNC_FLUSH

# broker-a-s.properties： #

#机器的ip地址
    
    brokerIP1=192.168.56.204
    #所属集群名字
    
    brokerClusterName=rocketmq-cluster
    
    #broker名字，注意此处不同的配置文件填写的不一样
    
    brokerName=broker-a
    
    #0 表示Master ,>0表示slave
    
    brokerId=1
    
    #nameServer 地址，分号分割
    
    namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876;rocketmq-nameserver3:9876;rocketmq-nameserver4:9876;
    
    #在发送消息时，自动创建服务器不存在的Topic,默认创建的队列数
    
    defaultTopicQueueNums=4
    
    #是否允许Broker 自动创建Topic，建议线下开启，线上关闭
    
    autoCreateTopicEnable=true
    
    #是否允许Broker 自动创建订阅组，建议线下开启，线上关闭
    
    autoCreateSubscriptionGroup=true
    
    #Broker 对外服务的监听端口
    
    listenPort=10911
    
    #删除文件时间点，默认是凌晨4点
    
    deleteWhen=04
    
    #文件保留时间，默认是48小时
    
    fileReservedTime=120
    
    #commitLog每个文件的大小默认1G
    
    mapedFileSizeCommitLog=1073741824
    
    #ConsumeQuene每个文件默认存30W条，根据业务情况调整
    
    mapedFileSizeConsumeQueue=300000
    
    #检测物理文件磁盘空间
    
    diskMaxUsedSpaceRatio=88
    
    #存储路径
    
    storePathRootDir=/home/rocketmq/rocketmq/store
    
    #commitLog存储路径
    
    storePathCommitLog=/home/rocketmq/rocketmq/store/commitlog
    
    #消费队列存储路径
    
    storePathConsumeQueue=/home/rocketmq/rocketmq/store/consumequeue
    
    #消费索引存储路径
    
    storePathIndex=/home/rocketmq/rocketmq/store/index
    
    #checkpoint 文件存储路径
    
    storeCheckpoint=/home/rocketmq/rocketmq/store/checkpoint
    
    #abort 文件存储路径
    
    abortFile=/home/rocketmq/rocketmq/store/abort
    
    #限制的消息大小
    
    maxMessageSize=65536
    
    #broker的角色
    
    #ASYNC_MASTER异步复制Master
    
    #SYNC_MASTER同步双写Master
    
    #SLAVE
    
    brokerRole=SLAVE
    
    #刷盘方式
    
    #ASYNC_FLUSH 异步刷盘
    
    #SYNC_FLUSH 同步刷盘
    
    flushDiskType=ASYNC_FLUSH

# broker-b.properties： #

#机器的ip地址
    
    brokerIP1=192.168.56.204
    #所属集群名字
    
    brokerClusterName=rocketmq-cluster
    
    #broker名字，注意此处不同的配置文件填写的不一样
    
    brokerName=broker-b
    
    #0 表示Master ,>0表示slave
    
    brokerId=0
    
    #nameServer 地址，分号分割
    
    namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876;rocketmq-nameserver3:9876;rocketmq-nameserver4:9876;
    
    #在发送消息时，自动创建服务器不存在的Topic,默认创建的队列数
    
    defaultTopicQueueNums=4
    
    #是否允许Broker 自动创建Topic，建议线下开启，线上关闭
    
    autoCreateTopicEnable=true
    
    #是否允许Broker 自动创建订阅组，建议线下开启，线上关闭
    
    autoCreateSubscriptionGroup=true
    
    #Broker 对外服务的监听端口
    
    listenPort=10911
    
    #删除文件时间点，默认是凌晨4点
    
    deleteWhen=04
    
    #文件保留时间，默认是48小时
    
    fileReservedTime=120
    
    #commitLog每个文件的大小默认1G
    
    mapedFileSizeCommitLog=1073741824
    
    #ConsumeQuene每个文件默认存30W条，根据业务情况调整
    
    mapedFileSizeConsumeQueue=300000
    
    #检测物理文件磁盘空间
    
    diskMaxUsedSpaceRatio=88
    
    #存储路径
    
    storePathRootDir=/home/rocketmq/rocketmq/store
    
    #commitLog存储路径
    
    storePathCommitLog=/home/rocketmq/rocketmq/store/commitlog
    
    #消费队列存储路径
    
    storePathConsumeQueue=/home/rocketmq/rocketmq/store/consumequeue
    
    #消费索引存储路径
    
    storePathIndex=/home/rocketmq/rocketmq/store/index
    
    #checkpoint 文件存储路径
    
    storeCheckpoint=/home/rocketmq/rocketmq/store/checkpoint
    
    #abort 文件存储路径
    
    abortFile=/home/rocketmq/rocketmq/store/abort
    
    #限制的消息大小
    
    maxMessageSize=65536
    
    #broker的角色
    
    #ASYNC_MASTER异步复制Master
    
    #SYNC_MASTER同步双写Master
    
    #SLAVE
    
    brokerRole=SYNC_MASTER
    
    #刷盘方式
    
    #ASYNC_FLUSH 异步刷盘
    
    #SYNC_FLUSH 同步刷盘
    
    flushDiskType=ASYNC_FLUSH

# broker-b-s.properties： #

#机器的ip地址
    
    brokerIP1=192.168.56.204
    #所属集群名字
    
    brokerClusterName=rocketmq-cluster
    
    #broker名字，注意此处不同的配置文件填写的不一样
    
    brokerName=broker-b
    
    #0 表示Master ,>0表示slave
    
    brokerId=1
    
    #nameServer 地址，分号分割
    
    namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876;rocketmq-nameserver3:9876;rocketmq-nameserver4:9876;
    
    #在发送消息时，自动创建服务器不存在的Topic,默认创建的队列数
    
    defaultTopicQueueNums=4
    
    #是否允许Broker 自动创建Topic，建议线下开启，线上关闭
    
    autoCreateTopicEnable=true
    
    #是否允许Broker 自动创建订阅组，建议线下开启，线上关闭
    
    autoCreateSubscriptionGroup=true
    
    #Broker 对外服务的监听端口
    
    listenPort=10911
    
    #删除文件时间点，默认是凌晨4点
    
    deleteWhen=04
    
    #文件保留时间，默认是48小时
    
    fileReservedTime=120
    
    #commitLog每个文件的大小默认1G
    
    mapedFileSizeCommitLog=1073741824
    
    #ConsumeQuene每个文件默认存30W条，根据业务情况调整
    
    mapedFileSizeConsumeQueue=300000
    
    #检测物理文件磁盘空间
    
    diskMaxUsedSpaceRatio=88
    
    #存储路径
    
    storePathRootDir=/home/rocketmq/rocketmq/store
    
    #commitLog存储路径
    
    storePathCommitLog=/home/rocketmq/rocketmq/store/commitlog
    
    #消费队列存储路径
    
    storePathConsumeQueue=/home/rocketmq/rocketmq/store/consumequeue
    
    #消费索引存储路径
    
    storePathIndex=/home/rocketmq/rocketmq/store/index
    
    #checkpoint 文件存储路径
    
    storeCheckpoint=/home/rocketmq/rocketmq/store/checkpoint
    
    #abort 文件存储路径
    
    abortFile=/home/rocketmq/rocketmq/store/abort
    
    #限制的消息大小
    
    maxMessageSize=65536
    
    #broker的角色
    
    #ASYNC_MASTER异步复制Master
    
    #SYNC_MASTER同步双写Master
    
    #SLAVE
    
    brokerRole=SLAVE
    
    #刷盘方式
    
    #ASYNC_FLUSH 异步刷盘
    
    #SYNC_FLUSH 同步刷盘
    
    flushDiskType=ASYNC_FLUSH

# 然后每台机器都要先启动namesrv 在启动broker： #

# nohup sh /home/rocketmq/rocketmq/bin/mqnamesrv & #

# 200机器： #

# nohup sh /home/rocketmq/rocketmq/bin/mqbroker -c /home/rocketmq/rocketmq/conf/2m-2s-sync/broker-a.properties > /dev/null 2>&1 & #

# 201机器： #

# nohup sh /home/rocketmq/rocketmq/bin/mqbroker -c /home/rocketmq/rocketmq/conf/2m-2s-sync/broker-a-s.properties > /dev/null 2>&1 & #

# 203机器： #

# nohup sh /home/rocketmq/rocketmq/bin/mqbroker -c /home/rocketmq/rocketmq/conf/2m-2s-sync/broker-b.properties > /dev/null 2>&1 & #

# 204机器： #

# nohup sh /home/rocketmq/rocketmq/bin/mqbroker -c /home/rocketmq/rocketmq/conf/2m-2s-sync/broker-b-s.properties > /dev/null 2>&1 & #

# 最后启动jar包即可： #

# nohup java -jar /home/rocketmq/rocketmq-console-ng/rocketmq-console-ng-2.0.0.jar #

# 修改配置文件： #

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 7][]

启动：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 8][]

连接成功
    Last login: Fri Dec 18 16:26:40 2020 from 192.168.56.11
    [root@mq1 ~]# jps
    29148 Jps
    28461 NamesrvStartup
    [root@mq1 ~]# nohup sh /home/rocketmq/rocketmq/bin/mqbroker -c /home/rocketmq/rocketmq/conf/2m-2s-sync/broker-a.properties > /dev/null 2>&1 & 
    [1] 32579
    [root@mq1 ~]# jps
    742 Jps
    32586 BrokerStartup
    28461 NamesrvStartup
    [root@mq1 ~]# nohup  java -jar /home/rocketmq/rocketmq-console-ng/rocketmq-console-ng-2.0.0.jar
    nohup: 忽略输入并把输出追加到"nohup.out"

关闭防火墙访问：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 9][]

# 至此：rocketmq  双主双从   同步复制  异步刷盘 集群搭建完毕！！ #

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70]: /images/20221120/24f1661b4e3d4f6e8f0e2c93e882da9a.png
[https_github.com_heidaodageshiwo_springboot_rocketmq2]: https://github.com/heidaodageshiwo/springboot_rocketmq2
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20201218164719661.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20201218171959236.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 3]: https://img-blog.csdnimg.cn/20201218172125956.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 4]: https://img-blog.csdnimg.cn/20201218172134397.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 5]: https://img-blog.csdnimg.cn/2020121817214024.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 6]: https://img-blog.csdnimg.cn/20201218172145312.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 7]: https://img-blog.csdnimg.cn/20201218171641949.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 8]: https://img-blog.csdnimg.cn/20201218171725431.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 9]: https://img-blog.csdnimg.cn/20201218171811653.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl,size_16,color_FFFFFF,t_70