美文网首页
RocketMQ-主从搭建

RocketMQ-主从搭建

作者: 快点给我想个名 | 来源:发表于2019-02-15 17:13 被阅读0次

主从模式特点

主从模式环境构建可以保障消息的即时性和可靠性。
投递一条消息后，关闭主节点，从节点继续可以提供消费者数据进行消费，但是不能接受消息。
主节点上线后进行消费进度offset同步。

先关闭129上的服务(/usr/local/rocketmq/bin/ 目录下)
sh mqshutdown broker
sh mqshutdown namesrv

修改129、130主机hosts

192.168.6.129 rocketmq-nameserver1
192.168.6.129 rocketmq-master1
192.168.6.130 rocketmq-nameserver2
192.168.6.130 rocketmq-master1-slave1
之后就是同单master节点(1,2,4,5步)，上传tar包，解压，创建软连接，创建存储文件，创建日志文件，修改配置文件

主从配置

修改129服务上/usr/local/rocketmq/conf/2m-2s-async目录中的broker-a.properties配置文件

#所属集群名字
brokerClusterName=rocketmq-cluster
#broker名字，注意此处不同的配置文件填写的不一样  例如：在a.properties 文件中写 broker-a  在b.properties 文件中写 broker-b
brokerName=broker-a
#0 表示 Master，>0 表示 Slave
brokerId=0
#nameServer地址，这里nameserver是单台，如果nameserver是多台集群的话，就用分号分割（即namesrvAddr=ip1:port1;ip2:port2;ip3:port3或者修改hosts文件不使用IP而是域名）
namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876
#在发送消息时，自动创建服务器不存在的topic，默认创建的队列数。由于是4个broker节点，所以设置为4
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
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#检测物理文件磁盘空间
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
#abort 文件存储路径
abortFile=/usr/local/rocketmq/store/abort
#限制的消息大小
maxMessageSize=65536
#flushCommitLogLeastPages=4
#flushConsumeQueueLeastPages=2
#flushCommitLogThoroughInterval=10000
#flushConsumeQueueThoroughInterval=60000
#Broker 的角色
#- ASYNC_MASTER 异步复制Master
#- SYNC_MASTER 同步双写Master
#- SLAVE
brokerRole=ASYNC_MASTER
#刷盘方式
#- ASYNC_FLUSH 异步刷盘
#- SYNC_FLUSH 同步刷盘
flushDiskType=ASYNC_FLUSH
#checkTransactionMessageEnable=false
#发消息线程池数量
#sendMessageThreadPoolNums=128
#拉消息线程池数量
#pullMessageThreadPoolNums=128

修改129服务上/usr/local/rocketmq/conf/2m-2s-async目录中的broker-a-s.properties配置文件

#所属集群名字
brokerClusterName=rocketmq-cluster
#broker名字，注意此处不同的配置文件填写的不一样  例如：在a.properties 文件中写 broker-a  在b.properties 文件中写 broker-b
brokerName=broker-a
#0 表示 Master，>0 表示 Slave
brokerId=1
#nameServer地址，这里nameserver是单台，如果nameserver是多台集群的话，就用分号分割（即namesrvAddr=ip1:port1;ip2:port2;ip3:port3或者修改hosts文件不使用IP而是域名）
namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876
#在发送消息时，自动创建服务器不存在的topic，默认创建的队列数。由于是4个broker节点，所以设置为4
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
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#检测物理文件磁盘空间
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
#abort 文件存储路径
abortFile=/usr/local/rocketmq/store/abort
#限制的消息大小
maxMessageSize=65536
#flushCommitLogLeastPages=4
#flushConsumeQueueLeastPages=2
#flushCommitLogThoroughInterval=10000
#flushConsumeQueueThoroughInterval=60000
#Broker 的角色
#- ASYNC_MASTER 异步复制Master
#- SYNC_MASTER 同步双写Master
#- SLAVE
brokerRole=SLAVE
#刷盘方式
#- ASYNC_FLUSH 异步刷盘
#- SYNC_FLUSH 同步刷盘
flushDiskType=ASYNC_FLUSH
#checkTransactionMessageEnable=false
#发消息线程池数量
#sendMessageThreadPoolNums=128
#拉消息线程池数量
#pullMessageThreadPoolNums=128

复制上述两个文件到130服务器的对应目录下

scp broker-a.properties broker-a-s.properties 192.168.6.130:/usr/local/rocketmq/conf/2m-2s-async/

启动nameserver(在/usr/local/rocketmq/bin目录下)

129、130服务器上执行：nohup sh mqnamesrv &

启动broker

129上执行：nohup sh mqbroker -c /usr/local/rocketmq/conf/2m-2s-async/broker-a.properties > /dev/null 2>&1 &

130上执行：nohup sh mqbroker -c /usr/local/rocketmq/conf/2m-2s-async/broker-a-s.properties > /dev/null 2>&1 &

之后修改demo中的地址为多个，就ok了

相关文章

  • RocketMQ-主从搭建

    主从模式特点 主从模式环境构建可以保障消息的即时性和可靠性。投递一条消息后，关闭主节点，从节点继续可以提供消费者数...

  • Mysql主从和故障

    1) 搭建传统的mysql主从 2) 搭建GTID的mysql主从（建议使用基于GTID来搭建主从） 3) IO线...

  • DBA（MySQL）学习-主从复制基础

    1. 主从复制 1.1 介绍 1.2 主从复制的前提（如何搭建主从复制） 2. 搭建主从复制 2.1 搭建多实例 ...

  • 主从复制（基础）

    01，主从复制简介 02，主从搭建简述 03，主从复制搭建(Classic replication) 1 清理主库...

  • RocketMQ主从搭建

    RocketMQ-四种集群环境构建 1.单点模式 2.主从模式主节点消息收发，同步到从节点，主节点挂了，从节点可以...

  • Day011-MySQL主从复制

    1. 主从复制介绍 2. 主从复制的前提（搭建主从复制） 3. 搭建主从复制步骤 3.1 准备多实例 3.2 检查...

  • 32主从复制

    职责搭建主从复制，主从原理熟悉，主从的故障处理，主从延迟，主从的特殊架构的配置使用，主从架构的演变 主从复制介绍主...

  • RocketMQ-本地搭建

    中间件概念 即中间角色，不独立工作。 文件中间件，如 FastHDFS 消息中间件，如各种 MQ、Kafka 搜索...

  • redis集群

    一，主从复制搭建 哨兵

  • mysql 主从复制

    mysql 主从复制 网易数据库 石勇 提纲 什么是主从复制 主从复制的原理 主从复制的用途 主从复制的搭建 主从...

网友评论

      本文标题：RocketMQ-主从搭建

      本文链接：https://www.haomeiwen.com/subject/rldmeqtx.html

      延伸阅读

      深度阅读

      • 您也可以注册成为美文阅读网的作者，发表您的原创作品、分享您的心情！

      栏目导航

      热点阅读

      关于我们|服务条款|联系我们|RocketMQ-主从搭建|投稿指南|网站地图|RSS订阅|排版工具|手机版

      提供经典美文摘抄,优美散文欣赏,现代诗歌精选,短篇小说,心情随笔,表白情书范文,故事会在线阅读欣赏

      Copyright © 2014-2023 Haomeiwen.com All Rights Reserved. 好美文阅读网 版权所有

      备案信息：桂公网安备 45052102000051号 · 桂ICP备13007215号-3

      本站所收录作品、热点评论等信息部分来源互联网，目的只是为了系统归纳学习和传递资讯

      所有作品版权归原创作者所有，与本站立场无关，如不慎侵犯了你的权益，请联系我们告知，我们将做删除处理！