Linux Centos 环境下搭建RocketMq集群（双主双从）

1、下载rocketmq的包

下载 | RocketMQ

2、配置环境变量

1、编辑环境变量文件：vim /etc/profile2、加入如下配置：
#rocketmq 4.9.8
ROCKETMQ_HOME=/home/rocketmq/rocketmq-4.9.8
export PATH=${ROCKETMQ_HOME}/bin:${PATH}3、刷新配置：source /etc/profile

3、修改相关参数

修改bin目录下的runserver.sh如下：

修改bin目录下的runbroker.sh如下：

4、启动和停止nameserver

1、启动命令
nohup sh /bin/mqnamesrv &2、查看日志
tail -f ~/logs/rocketmq/namesrv.log3、停止
./mqshutdown namesrv

5、启动和停止broker

1、启动命令
nohup sh /bin/mqbroker autoCreateTopicEnable=true &2、查看日志
tail -f ~/logs/rocketmq/broker.log3、停止
./mqshutdown broker

6、rocketmq集群配置

worker1 只需要启动nameserver即可

worker2中配置两个文件：broker-a.properties、broker-b-s.properties

worker3中配置两个文件：broker-b.properties、broker-a-s.properties

四个配置文件如下：

broker-a.properties

#所属集群名字，名字一样的节点就在同一个集群内
brokerClusterName=rocketmq-cluster
brokerIP1=192.168.10.200
brokerIP2=192.168.10.200
#broker名字，名字一样的节点就是一组主从节点。
brokerName=broker-a
#brokerid,0就表示是Master，>0的都是表示 Slave
brokerId=0
#nameServer地址，分号分割
namesrvAddr=192.168.10.200:9876;192.168.10.201:9876
#在发送消息时，自动创建服务器不存在的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=/home/rocketmq-4.9.8/data
#commitLog 存储路径
storePathCommitLog=/home/rocketmq-4.9.8/data/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/home/rocketmq-4.9.8/data/consumequeue
#消息索引存储路径
storePathIndex=/home/rocketmq-4.9.8/data/index
#checkpoint 文件存储路径
storeCheckpoint=/home/rocketmq-4.9.8/data/checkpoint
#abort 文件存储路径
abortFile=/home/rocketmq-4.9.8/data/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
brokerIP1=192.168.10.200
#broker名字，名字一样的节点就是一组主从节点。
brokerName=broker-b
#brokerid,0就表示是Master，>0的都是表示 Slave
brokerId=100
#nameServer地址，分号分割
namesrvAddr=192.168.10.200:9876;192.168.10.201:9876
#在发送消息时，自动创建服务器不存在的topic，默认创建的队列数
defaultTopicQueueNums=4
#是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
#是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
autoCreateSubscriptionGroup=true
#Broker 对外服务的监听端口
listenPort=11011
#删除文件时间点，默认凌晨 4点
deleteWhen=04
#文件保留时间，默认 48 小时
fileReservedTime=120
#commitLog每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#检测物理文件磁盘空间
diskMaxUsedSpaceRatio=88
#存储路径
storePathRootDir=/home/rocketmq-4.9.8/dataslave
#commitLog 存储路径
storePathCommitLog=/home/rocketmq-4.9.8/dataslave/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/home/rocketmq-4.9.8/dataslave/consumequeue
#消息索引存储路径
storePathIndex=/home/rocketmq-4.9.8/dataslave/index
#checkpoint 文件存储路径
storeCheckpoint=/home/rocketmq-4.9.8/dataslave/checkpoint
#abort 文件存储路径
abortFile=/home/rocketmq-4.9.8/dataslave/storeSlave/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
brokerIP1=192.168.10.201
brokerIP2=192.168.10.201
#broker名字，名字一样的节点就是一组主从节点。
brokerName=broker-b
#brokerid,0就表示是Master，>0的都是表示 Slave
brokerId=0
#nameServer地址，分号分割
namesrvAddr=192.168.10.200:9876;192.168.10.201:9876
#在发送消息时，自动创建服务器不存在的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=/home/rocketmq-4.9.8/data
#commitLog 存储路径
storePathCommitLog=/home/rocketmq-4.9.8/data/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/home/rocketmq-4.9.8/data/consumequeue
#消息索引存储路径
storePathIndex=/home/rocketmq-4.9.8/data/index
#checkpoint 文件存储路径
storeCheckpoint=/home/rocketmq-4.9.8/data/checkpoint
#abort 文件存储路径
abortFile=/home/rocketmq-4.9.8/data/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
brokerIP1=192.168.10.201
#broker名字，名字一样的节点就是一组主从节点。
brokerName=broker-a
#brokerid,0就表示是Master，>0的都是表示 Slave
brokerId=100
#nameServer地址，分号分割
namesrvAddr=192.168.10.200:9876;192.168.10.201:9876
#在发送消息时，自动创建服务器不存在的topic，默认创建的队列数
defaultTopicQueueNums=4
#是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
#是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
autoCreateSubscriptionGroup=true
#Broker 对外服务的监听端口
listenPort=11011
#删除文件时间点，默认凌晨 4点
deleteWhen=04
#文件保留时间，默认 48 小时
fileReservedTime=120
#commitLog每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#检测物理文件磁盘空间
diskMaxUsedSpaceRatio=88
#存储路径
storePathRootDir=/home/rocketmq-4.9.8/dataslave
#commitLog 存储路径
storePathCommitLog=/home/rocketmq-4.9.8/dataslave/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/home/rocketmq-4.9.8/dataslave/consumequeue
#消息索引存储路径
storePathIndex=/home/rocketmq-4.9.8/dataslave/index
#checkpoint 文件存储路径
storeCheckpoint=/home/rocketmq-4.9.8/dataslave/checkpoint
#abort 文件存储路径
abortFile=/home/rocketmq-4.9.8/dataslave/storeSlave/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

7、集群启动

启动顺序为：先启动3台服务器的nameserver，再启动worker2和worker3中的broker.

   启动nameserv：

#3台机器分别进入rocketmq安装目录，执行下面的命令：nohup sh bin/mqnamesrv &

  启动broker：

进入worker2，进入rocketmq的安装目录，执行一下两行，
nohup bin/mqbroker -c conf/broker-a.properties autoCreateTopicEnable=true &
nohup bin/mqbroker -c conf/broker-b-s.properties autoCreateTopicEnable=true &
查看日志：
tail -f ~/logs/rocketmq/broker.log进入worker3，进入rocketmq的安装目录，执行一下两行，
nohup bin/mqbroker -c conf/broker-b.properties autoCreateTopicEnable=true &
nohup bin/mqbroker -c conf/broker-a-s.properties autoCreateTopicEnable=true &

8、rockermq-console图形化管理界面

下载地址：
拉取rocketmq-console的源代码
github克隆项目到本地：git clone 
https://github.com/apache/rocketmq-externals.gitgitee克隆项目到本地：git clone 
https://gitee.com/zjj19941/rocketmq-externals-master.git修改启动端口
对rocketmq-console模块进行打包将打好的jar包上传至对应的服务器
maven打包命令：mvn package -DskipTests使用nohup对jar包进行后台启动：nohup java -jar rocketmq-console-ng-xxx.jar &如果没配置地址的话，可以在启动命令那儿加以下配置：
// > /home/soft/rocketmq/rocketmq-console.log 表示将标准输出重定向到指定的日志文件中；
// 2>&1 表示将标准错误输出也重定向到标准输出中；
nohup java -jar rocketmq-console-ng-1.0.0.jar --rocketmq.config.namesrvAddr='ip1:9876;ip2:9876' > /home/soft/rocketmq/rocketmq-console.log 2>&1 &

 浏览器访问localhost:端口，效果如下：

集群信息如下：

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.rhkb.cn/news/356074.html

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

修复kazam意外中断的视频文件

修复kazam意外中断的视频文件

0. Problem 在用kazam录视频的过程中，PC意外重启了，然后kazam没有把文件自动转换成MP4，而是存为以下两个文件： kazam_xxxxx.movie kazam-xxxxx.movie.mux这两个文件一个0k，另一个是有size的，但是没办法直…
阅读更多...
计算机组成原理 | 计算机系统概述

计算机组成原理 | 计算机系统概述

CPI:(Clockcycle Per Instruction)，指每条指令的时钟周期数。 时钟周期：对CPU来说，在一个时钟周期内，CPU仅完成一个最基本的动作。时钟脉冲是计算机的基本工作脉冲，控制着计算机的工作节奏。时钟周期 是一个时钟脉冲所…
阅读更多...
Elk安装及使用

Elk安装及使用

es安装及使用 单机版安装 集群安装 132 node-01 133 node-02 135 node-03 日志用户权限有问题 看日志 解决方案： 出现错误后，再次重启前，需要删除三个节点/data/下的内容 9300-http 9300-tcp logstasha安装及使用 Ssh错误 Yum安装默认路…
阅读更多...
小巧悦耳的百元耳机，也有纯净的音乐享受，西圣AVA2体验

小巧悦耳的百元耳机，也有纯净的音乐享受，西圣AVA2体验

无论是居家休闲还是出门在外，音乐成为了许多人生活中不可或缺的一部分。特别是在拥有一款既经济又好听的蓝牙耳机之后，我们就可以在通勤路上和办公室里，隔绝外界干扰，找回属于自己的天地，提升生活品质。目前我用的是一…
阅读更多...
【shell脚本速成】函数

【shell脚本速成】函数

文章目录 一、函数1.1、函数介绍1.2、函数定义1.3、函数调用 🌈你好呀！我是 山顶风景独好 🎈欢迎踏入我的博客世界，能与您在此邂逅，真是缘分使然！😊 🌸愿您在此停留的每一刻&#xf…
阅读更多...
LeetCode 19.删除链表的倒数第N个结点

LeetCode 19.删除链表的倒数第N个结点

链接 https://leetcode.cn/problems/remove-nth-node-from-end-of-list/description/ 题目: 给你一个链表，删除链表的倒数第 n 个结点，并且返回链表的头结点。 示例1： 输入：head [1,2,3,4,5], n 2 输出：[1,2,3,5…
阅读更多...
JMeter的基本使用与性能测试，完整入门篇保姆式教程

JMeter的基本使用与性能测试，完整入门篇保姆式教程

Jmeter 的简介 JMeter是一个纯Java编写的开源软件，主要用于进行性能测试和功能测试。它支持测试的应用/服务/协议包括Web (HTTP, HTTPS)、SOAP/REST Webservices、FTP、Database via JDBC等。我们最常使用的是HTTP和HTTPS协议。 Jmeter主要组件 线程组&#xff08…
阅读更多...
基于springboot实现影院订票系统项目【项目源码+论文说明】计算机毕业设计

基于springboot实现影院订票系统项目【项目源码+论文说明】计算机毕业设计

基于springboot实现影院订票系统演示 摘要 现代经济快节奏发展以及不断完善升级的信息化技术，让传统数据信息的管理升级为软件存储，归纳，集中处理数据信息的管理方式。本影院订票系统就是在这样的大环境下诞生，其可以帮助管理者在…
阅读更多...
python20 函数的定及调用

python20 函数的定及调用

函数的定及调用 函数是将一段实现功能的完整代码，使用函数名称进行封装，通过函数名称进行调用。以此达到一次编写，多次调用的目的 用 def 关键字来声明 函数 格式： def 函数名(参数列表):函数体[:return 返回值是可选的&#xff0…
阅读更多...
MySQL按小时分组统计日志记录数量

MySQL按小时分组统计日志记录数量

业务场景 MySQL按小时分组统计日志记录数量。最近需要统计一些日志流水，统计出打卡的高峰期，所以需要对日志流水按小时进行分组统计，统计出每半小时或者每小时内的打卡次数 按小时统计 这里使用DATE_FORMAT函数，然后再根据crea…
阅读更多...
电脑怎么录制游戏视频？轻松捕捉每一帧精彩

电脑怎么录制游戏视频？轻松捕捉每一帧精彩

随着游戏产业的蓬勃发展，越来越多的玩家不仅满足于在游戏世界中的探索与冒险，更希望将自己的游戏精彩瞬间记录下来，分享给更多的朋友。可是电脑怎么录制游戏视频呢？本文旨在为广大游戏爱好者提供一份详细的电脑游戏视频录制攻略&a…
阅读更多...
excel基本操作

excel基本操作

excel 若要取消在数据表中进行的所有筛选 步骤操作： 单击“数据”选项卡。在“排序和筛选”组中，找到“清除”按钮。点击“清除”按钮。 图例： 将文本文件的数据导入到Excel工作表中进行数据处理 步骤： 在Excel中&#xff0c…
阅读更多...
气象数据NC、grb2解析成矢量json、CMIS、MICPS及图片应用到webgis

气象数据NC、grb2解析成矢量json、CMIS、MICPS及图片应用到webgis

一、基础概念 气象数据通常以多种格式存储和交换，以适应不同的应用需求和处理工具。以下是一些常见的气象数据格式及其转换方法的概述： 常见气象数据格式 1. NetCDF（Network Common Data Form）：一种自描述、自包含的…
阅读更多...
js如何使得四舍五入的百分比之和为100%

js如何使得四舍五入的百分比之和为100%

在JavaScript中，如果你想要确保一组四舍五入后的百分比之和严格等于100%，那么你不能直接对每个百分比进行四舍五入，因为四舍五入会引入误差。但是，你可以采用一种策略，即先对所有的百分比进行常规的四舍五入&#xff0…
阅读更多...
数据结构6---树

数据结构6---树

一、定义 树(Tree)是n(n>0)个结点的有限集。当n0时成为空树,在任意一棵非空树中: 1、有且仅有一个特定的称为根(Root)的结点; 2、当n>1时,其余结点可分为m(m>日)个互不相交的有限集T1、T2、...、 Tm，其中每一个集合本身又是一棵树，并且称为根的…
阅读更多...
“打造智能售货机系统，基于ruoyi微服务版本生成基础代码“

“打造智能售货机系统，基于ruoyi微服务版本生成基础代码“

目录 # 开篇 1. 菜单 2. 字典配置 3. 表配置 3.1 导入表 3.2 区域管理 3.3 合作商管理 3.4 点位管理 4. 代码导入 4.1 后端代码生成 4.2 前端代码生成 5. 数据库代码执行 6. 点位管理菜单顺序修改 7. 页面展示 8. 附加设备表 8.1 新增设备管理菜单 8.2 创建字…
阅读更多...
Python武器库开发-武器库篇之SMB服务暴力破解(五十五)

Python武器库开发-武器库篇之SMB服务暴力破解(五十五)

Python武器库开发-武器库篇之SMB服务暴力破解(五十五) SMB服务（Server Message Block）是一种用于文件共享、打印机共享和其他资源共享的网络协议。它最初由IBM开发，后来被微软广泛采用。 SMB服务允许多台计算机在网络上共享文件和资源&…
阅读更多...
中石化加油卡有什么用？

中石化加油卡有什么用？

对于有车一族来说，有一张加油卡真的可以省下不少钱 但是像我们这种没车的人，即使得到加油卡也毫无用武之地 久而久之，难免会造成卡过期的情况出现 还好，前两天把我手上堆积了好久的加油卡在收卡云上卖出去了，99折真…
阅读更多...
QT

QT

#include "widget.h" #include "ui_widget.h" Widget::Widget(QWidget *parent) : QWidget(parent) , ui(new Ui::Widget) ,Gcancle(new QPushButton("取消",this)) ,EmmEdit(new QLineEdit(this)) { ui->setupUi(this);…
阅读更多...
怎么看电脑实时充电功率

怎么看电脑实时充电功率

因为我想测试不同的充电器给电脑充电的速度，所以就想找一款软件可以看电脑当前充电功率的软件，我给一个图 直接搜索就可以下载了，charge rate就是功率，这里是毫瓦，换算单位是 1000mw1w 所以我这里充电功率是65w&…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023