文档章节

RocketMQ双Master集群搭建

零二一七
 零二一七
发布于 10/10 18:43
字数 368
阅读 233
收藏 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

© 著作权归作者所有

零二一七
粉丝 42
博文 72
码字总数 34678
作品 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 消息...

匠心零度
04/11
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
分布式消息中间件 RocketMQ:概述与源码编译篇

一、前言 Apache RocketMQ 是一个分布式消息中间件,其具有低延迟、高性能和可靠性、万亿级容量、灵活的可扩展性特性;它是阿里巴巴在2012年开源的分布式消息中间件,目前已经捐赠给 Apache...

阿里加多
07/21
0
0
Apache RocketMQ QuickStart

RocketMQ作为一款分布式的消息中间件(阿里的说法是不遵循任何规范的,所以不能完全用JMS的那一套东西来看它),经历了Metaq1.x、Metaq2.x的发展和淘宝双十一的洗礼,在功能和性能上远超Act...

程序员诗人
2017/09/29
0
0

没有更多内容

加载失败,请刷新页面

加载更多

CentOS7防火墙firewalld操作

firewalld Linux上新用的防火墙软件,跟iptables差不多的工具。 firewall-cmd 是 firewalld 的字符界面管理工具,firewalld是CentOS7的一大特性,最大的好处有两个:支持动态更新,不用重启服...

dingdayu
36分钟前
0
0
关于组件化的最初步

一个工程可能会有多个版本,有国际版、国内版、还有针对各种不同的渠道化的打包版本、这个属于我们日常经常见到的打包差异化版本需求。 而对于工程的开发,比如以前的公司,分成了有三大块业...

DannyCoder
48分钟前
1
0
Spring的Resttemplate发送带header的post请求

private HttpHeaders getJsonHeader() { HttpHeaders headers = new HttpHeaders(); MediaType type = MediaType.parseMediaType("application/json; charset=UTF-8"); ......

qiang123
昨天
2
0
Spring Cloud Gateway 之 Only one connection receive subscriber allowed

都说Spring Cloud Gateway好,我也来试试,可是配置了总是报下面这个错误: java.lang.IllegalStateException: Only one connection receive subscriber allowed. 困扰了我几天的问题,原来...

ThinkGem
昨天
25
0
学习设计模式——观察者模式

1. 认识观察者模式 1. 定义:定义对象之间一种一对多的依赖关系,当一个对象状态发生变化时,依赖该对象的其他对象都会得到通知并进行相应的变化。 2. 组织结构: Subject:目标对象类,会被...

江左煤郎
昨天
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部