四、RocketMq本地集群搭建：多master-slaver异步

参照：https://github.com/apache/rocketmq/blob/master/docs/cn/operation.md

master可读可写，slaver只能写；即如果master挂了，则mq不能接收消息了，
但是不影响消费者从slaver消费消息
master-slaver集群不支持自动选举功能，master是在配置文件中指定死的，如果master挂了，不会从slaver中选举master

1、修改配置文件conf\2m-2s-async
broker-a.properties

brokerClusterName=DefaultCluster
brokerName=broker-a
brokerId=0
deleteWhen=04
fileReservedTime=48
brokerRole=ASYNC_MASTER
flushDiskType=ASYNC_FLUSH
#同一台机器上的broker的端口号相差大一点,不然会报错地址已被绑定
# https://www.likecs.com/show-204784161.html
listenPort=10911
brokerIP1 = 127.0.0.1
namesrvAddr = 127.0.0.1:9876
#存储路径
storePathRootDir=E:\\SelfStudy\\rocketmq_jq\\store1

broker-a-s.properties

brokerClusterName=DefaultCluster
brokerName=broker-a
brokerId=1
deleteWhen=04
fileReservedTime=48
brokerRole=SLAVE
flushDiskType=ASYNC_FLUSH
#同一台机器上的broker的端口号相差大一点
#https://www.likecs.com/show-204784161.html
listenPort=10920
brokerIP1 = 127.0.0.1
namesrvAddr = 127.0.0.1:9876
#存储路径
storePathRootDir=E:\\SelfStudy\\rocketmq_jq\\store2

broker-b.properties

brokerClusterName=DefaultCluster
brokerName=broker-b
brokerId=0
deleteWhen=04
fileReservedTime=48
brokerRole=ASYNC_MASTER
flushDiskType=ASYNC_FLUSH
#同一台机器上的broker的端口号相差大一点
#https://www.likecs.com/show-204784161.html
listenPort=10930
brokerIP1 = 127.0.0.1
namesrvAddr = 127.0.0.1:9876
#存储路径
storePathRootDir=E:\\SelfStudy\\rocketmq_jq\\store3

broker-b-s.properties

brokerClusterName=DefaultCluster
brokerName=broker-b
brokerId=1
deleteWhen=04
fileReservedTime=48
brokerRole=SLAVE
flushDiskType=ASYNC_FLUSH
#同一台机器上的broker的端口号相差大一点
#https://www.likecs.com/show-204784161.html
listenPort=10940
brokerIP1 = 127.0.0.1
namesrvAddr = 127.0.0.1:9876
#存储路径
storePathRootDir=E:\\SelfStudy\\rocketmq_jq\\store4

2、创建storePathRootDir文件夹
就是配置文件里storePathRootDir对应的文件夹

3、复制四份修改配置文件后的rocketmq-4.9.4

4、进入rocketmq-1的bin目录下启动nameserver

mqnamesrv.cmd -n localhost:9876

5、分别进入对应的rocketmq的bin目录下执行命令，启动broker

# 在rocketmq-1\bin下执行
mqbroker.cmd -n localhost:9876 -c ../conf/2m-2s-async/broker-a.properties
# 在rocketmq-2\bin下执行
mqbroker.cmd -n localhost:9876 -c ../conf/2m-2s-async/broker-a-s.properties
# 在rocketmq-3\bin下执行
mqbroker.cmd -n localhost:9876 -c ../conf/2m-2s-async/broker-b.properties
# 在rocketmq-4\bin下执行
mqbroker.cmd -n localhost:9876 -c ../conf/2m-2s-async/broker-b-s.properties

6、仪表板观察集群

四、RocketMq本地集群搭建：多master-slaver异步相关推荐

linux系统下RocketMQ的集群搭建
前提已配置java环境 # java -version java version "1.8.0_271" Java(TM) SE Runtime Environment (buil ...
【RocketMQ】集群的搭建与高可用
RocketMQ分布式集群是通过Master和Slave的配合达到高可用性的. Master和Slave的区别:在Broker的配置文件中,参数brokerId的值为0表明这个Broker是Maste ...
搭建基于Docker社区版的Kubernetes本地集群
搭建基于Docker社区版的Kubernetes本地集群原文:搭建基于Docker社区版的Kubernetes本地集群 Kubernetes的本地集群搭建是一件颇费苦心的活,网上有各种参考资源,由于 ...
kafka集群搭建(消息)
1.Kafka使用背景在我们大量使用分布式数据库.分布式计算集群的时候,是否会遇到这样的一些问题: 我们想分析下用户行为(pageviews),以便我们设计出更好的广告位我想对用户的搜索关键词进行 ...
Zookeeper+Hadoop+Hbase+Hive+Kylin+Nginx集群搭建
Zookeeper+Hadoop+Hbase+Hive+Kylin+Nginx集群搭建一.虚拟机安装Centos7 1.准备工作 2.centos7安装过程 3.关闭防火墙(关键) 二.安装jdk ...
HBase详解（对hbase集群搭建、读写流程、hbase的javaApi等细致入微的讲解与保姆级的图解）
学HBase的意义是什么我本想用MySQL来与HBase作比较,但发现他们两者毫无可比性,因为两者运用领域不同,各自有各自的优点,就好比爬山穿登山鞋,潜水穿脚蹼一般. 一门技术的兴起,一个优秀的开源 ...
Swarm集群搭建( docker安装、docker-compose安装、portainer可视化安装、基本使用命令总结、项目集群部署案例)
docker安装.docker-compose安装.Swarm集群搭建.portainer可视化安装.和项目部署案例四台服务器,我这里选用四台虚拟机1核2G,系统centos7,ip:192.168 ...
kafka集群搭建教程（使用自带的zookeeper）
kafka集群搭建教程(使用自带的zookeeper) 一.kafka简介二.kafka名词解释三.zookeeper与Kafka 四.kafka集群搭建前准备 1.下载 2.检验jdk 3.系统 ...
ceph实战之ceph集群搭建
Ceph基础一.ceph起源 Ceph项目最早起源于Sage就读博士期间的工作(最早的成果于2004年发表),并随后贡献给开源社区.在经过了数年的发展之后,目前已得到众多云计算厂商的支持并被广泛应用 ...
Zookeeper+Hadoop+Hbase+Hive+Kylin+Nginx集群搭建三(zookeeper篇)
Zookeeper+Hadoop+Hbase+Hive+Kylin+Nginx集群搭建三(zookeeper篇) 四.Zookeeper集群搭建 1.下载安装zookeeper安装包 2.文件配置 3 ...

四、RocketMq本地集群搭建：多master-slaver异步

四、RocketMq本地集群搭建：多master-slaver异步相关推荐

最新文章

热门文章