三 windows搭建rocketmq集群（双主双从）
目录
一 官网下载rocketmq
二 配置（很重要）
2.1 解压文件及准备工作
2.2 修改日志配置路径
2.3 配置重要文件
三 启动mq
四 启动脚本
五 页面查看效果
一 官网下载rocketmq
https://rocketmq.apache.org/dowloading/releases/
这里下载4.9.3版本
二 配置（很重要）
2.1 解压文件及准备工作
新建一个目录，我这里新建如下：
D:\soft\java\RocketMQ\many
将该文件解压至该目录下，如图所示：
然后在rocketmq-4.9.3该文件下新建三个文件夹，分别是：logs myconf store ，如图所示
记住文件目录（这个目录很重要，需要将该目录配置到环境变量中），具体如何配置，前面章节中有介绍，可点击链接：一 windows下安装RocketMQ+可视化页面搭建_易天雨的博客-CSDN博客_rocketmq可视化界面windows
D:\soft\java\RocketMQ\many\rocketmq-4.9.3
2.2 修改日志配置路径
打开三个文件，均做如下操作即可完成替换
2.3 配置重要文件
将如图所示的四个文件全部复制到myconf目录中，同时并在myconf文件夹中新建两个文件，分别为：namesrv1.properties和namesrv2.properties，设置端口号，如下
namesrv1.properties文件中内容为：listenPort=9876
namesrv2.properties文件中内容为：listenPort=9877
修改刚才复制的4个文件（直接复制以下内容全覆盖，具体内容可回去慢慢研究）：如下：
broker-a.properties
#所属集群名字
brokerClusterName=rocketmq-cluster
#broker名字，名字可重复,为了管理,每个master起一个名字,他的slave同他,eg:Amaster叫broker-a,他的slave也叫broker-a
brokerName=broker-a
#0 表示 Master，>0 表示 Slave
brokerId=0
#nameServer地址，分号分割
namesrvAddr=127.0.0.1:9876;127.0.0.1:9877
#在发送消息时，自动创建服务器不存在的topic，默认创建的队列数
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=D:/soft/java/RocketMQ/many/rocketmq-4.9.3/store/master1/broker-a
#commitLog 存储路径
storePathCommitLog=D:/soft/java/RocketMQ/many/rocketmq-4.9.3/store/master1/broker-a/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=D:/soft/java/RocketMQ/many/rocketmq-4.9.3/store/master1/broker-a/consumequeue
#消息索引存储路径
storePathIndex=D:/soft/java/RocketMQ/many/rocketmq-4.9.3/store/master1/broker-a/index
#checkpoint 文件存储路径
storeCheckpoint=D:/soft/java/RocketMQ/many/rocketmq-4.9.3/store/master1/checkpoint
#abort 文件存储路径
abortFile=D:/soft/java/RocketMQ/many/rocketmq-4.9.3/store/master1/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
broker-a-s.properties内容
#所属集群名字
brokerClusterName=rocketmq-cluster
#broker名字，名字可重复,为了管理,每个master起一个名字,他的slave同他,eg:Amaster叫broker-a,他的slave也叫broker-a
brokerName=broker-a-s
#0 表示 Master，>0 表示 Slave
brokerId=1
#nameServer地址，分号分割
namesrvAddr=127.0.0.1:9876;127.0.0.1:9877
#在发送消息时，自动创建服务器不存在的topic，默认创建的队列数
defaultTopicQueueNums=4
#是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
#是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
autoCreateSubscriptionGroup=true
#Broker 对外服务的监听端口,
listenPort=10921
#删除文件时间点，默认凌晨 4点
deleteWhen=04
#文件保留时间，默认 48 小时
fileReservedTime=120
#commitLog每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#检测物理文件磁盘空间
diskMaxUsedSpaceRatio=88
#存储路径
storePathRootDir=D:/soft/java/RocketMQ/many/rocketmq-4.9.3/store/slave1/broker-a-s
#commitLog 存储路径
storePathCommitLog=D:/soft/java/RocketMQ/many/rocketmq-4.9.3/store/slave1/broker-a-s/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=D:/soft/java/RocketMQ/many/rocketmq-4.9.3/store/slave1/broker-a-s/consumequeue
#消息索引存储路径
storePathIndex=D:/soft/java/RocketMQ/many/rocketmq-4.9.3/store/slave1/broker-a-s/index
#checkpoint 文件存储路径
storeCheckpoint=D:/soft/java/RocketMQ/many/rocketmq-4.9.3/store/slave1/checkpoint
#abort 文件存储路径
abortFile=D:/soft/java/RocketMQ/many/rocketmq-4.9.3/store/slave1/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
broker-b.properties内容
#所属集群名字
brokerClusterName=rocketmq-cluster
#broker名字，名字可重复,为了管理,每个master起一个名字,他的slave同他,eg:Amaster叫broker-a,他的slave也叫broker-a
brokerName=broker-b
#0 表示 Master，>0 表示 Slave
brokerId=0
#nameServer地址，分号分割
namesrvAddr=127.0.0.1:9876;127.0.0.1:9877
#在发送消息时，自动创建服务器不存在的topic，默认创建的队列数
defaultTopicQueueNums=4
#是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
#是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
autoCreateSubscriptionGroup=true
#Broker 对外服务的监听端口,
listenPort=10941
#删除文件时间点，默认凌晨 4点
deleteWhen=04
#文件保留时间，默认 48 小时
fileReservedTime=120
#commitLog每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#检测物理文件磁盘空间
diskMaxUsedSpaceRatio=88
#存储路径
storePathRootDir=D:/soft/java/RocketMQ/many/rocketmq-4.9.3/store/master2/broker-b
#commitLog 存储路径
storePathCommitLog=D:/soft/java/RocketMQ/many/rocketmq-4.9.3/store/master2/broker-b/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=D:/soft/java/RocketMQ/many/rocketmq-4.9.3/store/master2/broker-b/consumequeue
#消息索引存储路径
storePathIndex=D:/soft/java/RocketMQ/many/rocketmq-4.9.3/store/master2/broker-b/index
#checkpoint 文件存储路径
storeCheckpoint=D:/soft/java/RocketMQ/many/rocketmq-4.9.3/store/master2/checkpoint
#abort 文件存储路径
abortFile=D:/soft/java/RocketMQ/many/rocketmq-4.9.3/store/master2/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
broker-b-s.properties
#所属集群名字
brokerClusterName=rocketmq-cluster
#broker名字，名字可重复,为了管理,每个master起一个名字,他的slave同他,eg:Amaster叫broker-a,他的slave也叫broker-a
brokerName=broker-b-s
#0 表示 Master，>0 表示 Slave
brokerId=1
#nameServer地址，分号分割
namesrvAddr=127.0.0.1:9876;127.0.0.1:9877
#在发送消息时，自动创建服务器不存在的topic，默认创建的队列数
defaultTopicQueueNums=4
#是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
#是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
autoCreateSubscriptionGroup=true
#Broker 对外服务的监听端口,
listenPort=10951
#删除文件时间点，默认凌晨 4点
deleteWhen=04
#文件保留时间，默认 48 小时
fileReservedTime=120
#commitLog每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#检测物理文件磁盘空间
diskMaxUsedSpaceRatio=88
#存储路径
storePathRootDir=D:/soft/java/RocketMQ/many/rocketmq-4.9.3/store/slave2/broker-b-s
#commitLog 存储路径
storePathCommitLog=D:/soft/java/RocketMQ/many/rocketmq-4.9.3/store/slave2/broker-b-s/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=D:/soft/java/RocketMQ/many/rocketmq-4.9.3/store/slave2/broker-b-s/consumequeue
#消息索引存储路径
storePathIndex=D:/soft/java/RocketMQ/many/rocketmq-4.9.3/store/slave2/broker-b-s/index
#checkpoint 文件存储路径
storeCheckpoint=D:/soft/java/RocketMQ/many/rocketmq-4.9.3/store/slave2/checkpoint
#abort 文件存储路径
abortFile=D:/soft/java/RocketMQ/many/rocketmq-4.9.3/store/slave2/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
至此，全部配置完毕
三 启动mq
进入bin目录，cmd进入运行窗口：
// 启动端口号
.\mqnamesrv.cmd -c ..\myconf\namesrv1.properties
.\mqnamesrv.cmd -c ..\myconf\namesrv2.properties
// 启动配置
.\mqbroker.cmd -c ..\myconf\broker-a.properties
.\mqbroker.cmd -c ..\myconf\broker-a-s.properties
.\mqbroker.cmd -c ..\myconf\broker-b.properties
.\mqbroker.cmd -c ..\myconf\broker-b-s.properties
四 启动脚本
针对需要启动复杂问题，我这里提供了脚本启动方式，可按照如下配置，新建文件：start_mq.cmd，注意，后缀一定为cmd，即可一键启动，脚本内容如下：
# 启动端口号
set path=D:\soft\java\RocketMQ\many\rocketmq-4.9.3
start %path%\bin\mqnamesrv.cmd -c %path%\myconf\namesrv1.properties
start %path%\bin\mqnamesrv.cmd -c %path%\myconf\namesrv2.properties# 启动配置
start %path%\bin\mqbroker.cmd -c %path%\myconf\broker-a.properties
start %path%\bin\mqbroker.cmd -c %path%\myconf\broker-a-s.properties
start %path%\bin\mqbroker.cmd -c %path%\myconf\broker-b.properties
start %path%\bin\mqbroker.cmd -c %path%\myconf\broker-b-s.properties
五 页面查看效果
这里记住可视化页面查看
ok 搭建完毕
三 windows搭建rocketmq集群（双主双从）相关推荐
- 计算机集群搭建教程,Windows搭建Redis集群-详细教程
一.集群知识 1.集群的概念 所谓的集群,就是通过添加服务器的数量,提供相同的服务,从而让服务器达到一个稳定.高效的状态. 2.使用redis集群的必要性 问题:我们已经部署好了redis,并且能启动 ...
- 从零开始搭建Kubernetes集群（三、搭建K8S集群）
一.前言 在上一篇文章 从零开始搭建Kubernetes 1.10.0 集群(二.搭建虚拟机环境)中,我们已经搭建好了基础的虚拟机环境.现在,我们可以开启我们真正的K8S之旅. 我们将现有的虚拟机称之 ...
- 【云原生-K8s-1】kubeadm搭建k8s集群(一主两从)完整教程及kubernetes简介
- RocketMQ集群（版本4.7.1）搭建教程
快速搭建RocketMQ集群 前言:最近在学习了解RocketMQ,为了更好地对照了解,需要安装一套RocketMQ集群,自己实际上手操作一番.首先在google搜索一番,找了一篇教程,看了下,比较详 ...
- Storm之——搭建Storm集群
转载请注明出处:http://blog.csdn.net/l1028386804/article/details/78419484 一.机器规划 主机名 IP Zookeeper Nimbus Sup ...
- MacOS 单机搭建 Pulsar 集群
作者:高天赐 编辑:Irene Pulsar 是一个支持多租户的.高性能的消息中间件,本文详细记录了如何在 MacOS 上,利用一台服务器搭建一个简单测试集群的过程.后续我们会介绍如何在多台 Linu ...
- Linux教程：RocketMq介绍以及集群服务搭建（双主双从同步双写）并安装可视化平台RocketMq-Dashboard
一.介绍 1.什么是MQ MQ(Message Queue)消息队列,是基础数据结构中"先进先出"的一种数据结构.一般用来解决应用解耦,异步消息,流量削峰等问题,实现高性能,高可用 ...
- 第三章:RocketMQ集群与搭建
数据复制与刷盘策略 复制策略 复制策略是Broker的Master与Slave间的数据同步方式.分为同步复制与异步复制 同步复制(SYNC_MASTER):消息写入master后,master会等 ...
- MySQL 学习 - Replication集群 - 搭建 - 双主双从
前言 我们这里说的是双主双从集群搭建,当然这个是看你实际业务,说白了一点 两个主节点双向同步,A集群挂掉时,B集群因为双向同步,立即可以开始工作,实现高可用 基本原理 具体流程 主库将变更写入到主库的 ...
最新文章
- 一场由金山词霸引起的车祸 Process finished with exit code -1073741819 (0xC0000005)
- Android Bitmap转换WebP图片导致损坏的分析及解决方案
- 精度问题——直线方程的系数判断实际生产中三点能否确定一个圆
- SAP关于销售来自可选工厂的解决方案
- Js整理备忘（02）——运算符
- 想让AI在企业落地？微软最新Azure AI不容错过！
- 深度学习-计算机视觉--图像增广
- Matploblib work5
- 前端存储 (2) - sessionStorage ,localStorage
- 长春技师学院计算机系,长春技校排名前五十
- python操作库_python操作数据库
- pandas: pd.concat([df1,df3],axis默认=0纵向拼接)，concat常用于纵向拼接，默认outer join
- 年度总结—2019-2020
- macbook pro怎么养小宠物?macbook pro养宠物设置方法
- 做html5抽奖程序xu,用jQuery实现抽奖程序
- 索尼Xperia S＿4.0一键ROOT工具┇_┇免解锁┇_┇一分钟ROOT┇_┇
- winform窗体控件
- 44道Redis面试题，含参考答案！
- 常见的OutOfMemoryError原因及解决方案
- Html table添加空行
热门文章
- React学习笔记——redux里中间件Middleware的运行机理
- 数据结构 day07 基础知识学习 （二叉树 的 前中后遍历 ，插入节点，删除叶子节点， 二叉树的节点个数 ）
- 综述：用于自动驾驶的全景鱼眼相机的理论模型和感知介绍
- 【Python学习笔记—保姆版】第四章—关于Pandas、数据准备、数据处理、数据分析、数据可视化
- win10系统输入法图标不见了怎么找回
- 8个独立站海外营销工具
- NOTA-WL12，68Ga-NOTA-WL12一种基于肽的正电子发射断层扫描 (PET) 显像剂
- Fiddler简单的使用教程
- php获取远程网页地址吗,php怎么获取远程网站上的图片的地址？有什么思路吗？...
- android+win8+双系统,Android/Win8双系统 天敏iBox睿盒D9i评测上