文档章节

RocketMQ双Master集群搭建

老菜鸟0217
 老菜鸟0217
发布于 10/10 18:43
字数 368
阅读 272
收藏 6

机器准备

2台独立的linux主机, 内网IP分别为: 172.31.175.142/143

172.31.175.142 NameServer1、 Broker Master1
172.31.175.143 NameServer2、 Broker Master2

安装配置

安装

下载二进制版本解压即可

wget http://mirrors.hust.edu.cn/apache/rocketmq/4.3.0/rocketmq-all-4.3.0-bin-release.zip
unzip rocketmq-all-4.3.0-bin-release.zip -d ~
cd ~
mv rocketmq-all-4.3.0-bin-release rocketmq

启动NameServer

命令的std输出使用默认的运行日志

mkdir -p ~/logs/rocketmqlogs
nohup sh bin/mqnamesrv >~/logs/rocketmqlogs/namesrv.log 2>&1 &
tail -100f ~/logs/rocketmqlogs/namesrv.log

配置/启动Broker

1) master1

进入172.31.175.142, 编辑预制的配置文件conf/2m-noslave/broker-a.properties, 追加namesrv地址

namesrvAddr=172.31.175.142:9876;172.31.175.143:9876
brokerClusterName=DefaultCluster
brokerName=broker-a
brokerId=0
deleteWhen=04
fileReservedTime=48
brokerRole=ASYNC_MASTER
flushDiskType=ASYNC_FLUSH

启动broker, 指定配置文件broker-a.properties

nohup sh bin/mqbroker -c ~/rocketmq/conf/2m-noslave/broker-a.properties >~/logs/rocketmqlogs/broker.log 2>&1 &
tail -100f ~/logs/rocketmqlogs/broker.log

2) master2

进入172.31.175.143, 编辑预制的配置文件conf/2m-noslave/broker-b.properties, 追加namesrv地址

namesrvAddr=172.31.175.142:9876;172.31.175.143:9876
brokerClusterName=DefaultCluster
brokerName=broker-b
brokerId=0
deleteWhen=04
fileReservedTime=48
brokerRole=ASYNC_MASTER
flushDiskType=ASYNC_FLUSH

启动broker, 指定配置文件broker-b.properties

nohup sh bin/mqbroker -c ~/rocketmq/conf/2m-noslave/broker-b.properties >~/logs/rocketmqlogs/broker.log 2>&1 &
tail -100f ~/logs/rocketmqlogs/broker.log

查看集群状态

sh bin/mqadmin clusterlist -n 172.31.175.142:9876;172.31.175.143:9876

双master集群信息如下

#Cluster Name     #Broker Name            #BID  #Addr                  #Version                #InTPS(LOAD)       #OutTPS(LOAD) #PCWait(ms) #Hour #SPACE
DefaultCluster    broker-a                0     172.31.175.142:10911   V4_3_0                   0.00(0,0ms)         0.00(0,0ms)          0 427546.59 -1.0000
DefaultCluster    broker-b                0     172.31.175.143:10911   V4_3_0                   0.00(0,0ms)         0.00(0,0ms)          0 427546.59 -1.0000

© 著作权归作者所有

老菜鸟0217
粉丝 40
博文 75
码字总数 37212
作品 0
海淀
程序员
私信 提问
加载中

评论(1)

老菜鸟0217
老菜鸟0217
“双master无从”的集群部署比较简单和节省机器, 缺陷就是“如果某个master挂掉时, 上面刚好有没有消费完的消息, 那么在这个master恢复正常之前,对应消息的消费就会出现延迟”, 其实大多数业务场景是能够容忍这种小概率故障的.
rocketmq源码解析之上下文介绍

说在前面 从今天开始对rocket-mq源码进行解析,版本4.3.0。 rocketmq、kafka、activemq等的比较这里就不介绍了,rocketmq官方文档介绍的很详细。 本人对rocketmq感兴趣的想深入研究下源码,此...

天河2018
10/25
0
0
说说MQ之RocketMQ(一)

原文出处:Valleylord RocketMQ 是出自 A 公司的开源产品,用 Java 语言实现,在设计时参考了 Kafka,并做出了自己的一些改进,消息可靠性上比 Kafka 更好,目前,RocketMQ 的文档仍然不够丰...

Valleylord
10/12
0
0
RocketMQ(六):namesrv再探

匠心零度 转载请注明原创出处,谢谢! RocketMQ网络部署图 NameServer:在系统中是做命名服务,更新和发现 broker服务。 Broker-Master:broker 消息主机服务器。 Broker-Slave: broker 消息...

匠心零度
10/29
0
0
滴滴出行基于RocketMQ构建企业级消息队列服务的实践

本文整理自滴滴出行消息队列负责人 江海挺 在Apache RocketMQ开发者沙龙北京站的分享。通过本文,您将了解到滴滴出行: 1. 在消息队列技术选型方面的思考; 2. 为什么选择 RocketMQ 作为出行...

阿里巴巴中间件
11/01
0
0
ROCKETMQ——2主2从集群部署

1.压缩包准备 两台服务器镜像操作 cd /opt mkdir soft cd soft 将两个压缩包复制到 soft目录 unzip apache-maven-3.2.2-bin.zip unzip rocketmq-all-4.2.0-source-release.zip 2.配置环境变量...

小王90年
08/28
0
0

没有更多内容

加载失败,请刷新页面

加载更多

java框架学习日志-5(常见的依赖注入)

依赖注入(dependency injection) 之前提到控制反转(Inversion of Control)也叫依赖注入,它们其实是一个东西,只是看的角度不同,这章详细说一下依赖注入。 依赖——指bean对象创建依赖于...

白话
12分钟前
1
0
《读书是教师最好的修行》读后感优秀范文2200字

《读书是教师最好的修行》读后感优秀范文2200字: 作者:吴淑英;《读书是教师最好的修行》一书,收录了作者对50本经典书籍阅读后阐发的感受。作者10年来坚持每周阅读一本书,并写一篇读后感...

原创小博客
14分钟前
0
0
红外接收器驱动开发

背景:使用系统的红外遥控软件没有反应,然后以为自己接线错误,反复测试,结果烧坏了一个红外接收器,信号主板没有问题。所以自己开发了一个红外接收器的python驱动。接线参见https://my.os...

mbzhong
今天
2
0
ActiveMQ消息传送机制以及ACK机制详解

AcitveMQ是作为一种消息存储和分发组件,涉及到client与broker端数据交互的方方面面,它不仅要担保消息的存储安全性,还要提供额外的手段来确保消息的分发是可靠的。 一. ActiveMQ消息传送机...

watermelon11
今天
1
0
HashTable和Vector为什么逐渐被废弃

HashTable,不允许键值为null,还一个就是put方法使用sychronized方法进行线程同步,单线程无需同步,多线程可用concurren包的类型。 如编程思想里面说的作为工具类,封闭性做的不好没有一个...

noob_chr
昨天
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部