rocketmq双主双从部署+dashbord

1、主机规划

主机节点地址
主机Anamesrv192.168.2.228:9876
主机Abroker-a192.168.2.228:10911
主机Abroker-b192.168.2.228:11911
主机Bnamesrv192.168.2.229:9876
主机Bbroker-c192.168.2.229:10911
主机Bbroker-d192.168.2.229:11911

2、两台主机都需要执行，创建mq需要的文件

mkdir -p /mydata/rocketmq/data/namesrv/logs
sudo chmod 777  /mydata/rocketmq/data/namesrv/logs
mkdir -p /mydata/rocketmq/data/namesrv/store
chmod 777  /mydata/rocketmq/data/namesrv/store
mkdir -p /mydata/rocketmq/data/broker-a/logs
mkdir -p /mydata/rocketmq/data/broker-a/store
mkdir -p /mydata/rocketmq/etc/broker-a
chmod 777 /mydata/rocketmq/data/broker-a/logs
chmod 777 /mydata/rocketmq/data/broker-a/store
chmod 777 /mydata/rocketmq/etc/broker-a
mkdir -p /mydata/rocketmq/data/broker-b/logs
mkdir -p /mydata/rocketmq/data/broker-b/store
mkdir -p /mydata/rocketmq/etc/broker-b
chmod 777 /mydata/rocketmq/data/broker-b/logs
chmod 777 /mydata/rocketmq/data/broker-b/store
chmod 777 /mydata/rocketmq/etc/broker-b

3、部署broker-a

cd  /mydata/rocketmq/data
vi broker-a.conf
#输入以下内容brokerClusterName = rocketmq-cluster
brokerName = broker-a# 0表示broker master 非0表示 broker slaver
brokerId = 0# brokerIP1 当前broker监听的IP
brokerIP1 = 192.168.2.228# brokerIP2 存在broker主从时，在broker主节点上配置了brokerIP2的话,broker从节点会连接主节点配置的brokerIP2来同步
brokerIP2 = 192.168.2.228deleteWhen = 04
fileReservedTime = 48namesrvAddr = 192.168.2.228:9876;192.168.2.229:9876# 是否能够自动创建topic
autoCreateTopicEnable = true#Broker 对外服务的监听端口, 默认10911
# listenPort = 10911#commitLog每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#检测物理文件磁盘空间
diskMaxUsedSpaceRatio=88
#限制的消息大小
maxMessageSize=65536
#flushCommitLogLeastPages=4
#flushConsumeQueueLeastPages=2
#flushCommitLogThoroughInterval=10000
#flushConsumeQueueThoroughInterval=60000
#Broker 的角色
#- ASYNC_MASTER 异步复制Master
#- SYNC_MASTER 同步双写Master
#- SLAVE
brokerRole=SYNC_MASTER
#刷盘方式
#- ASYNC_FLUSH 异步刷盘
#- SYNC_FLUSH 同步刷盘
flushDiskType=SYNC_FLUSH
#checkTransactionMessageEnable=false
#发消息线程池数量
#sendMessageThreadPoolNums=128
#拉消息线程池数量
#pullMessageThreadPoolNums=128

4、部署broker-b

cd  /mydata/rocketmq/data
vi broker-b-s.conf
#输入以下内容brokerClusterName = rocketmq-cluster
brokerName = broker-bbrokerId = 1brokerIP1 = 192.168.2.228deleteWhen = 04
fileReservedTime = 48namesrvAddr = 192.168.2.228:9876;192.168.2.229:9876listenPort = 11911#是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
#是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
autoCreateSubscriptionGroup=true
#commitLog每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#检测物理文件磁盘空间
diskMaxUsedSpaceRatio=88
#限制的消息大小
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

5、主机B部署broker-c

cd  /mydata/rocketmq/data
vi broker-a.conf
#输入以下内容brokerClusterName = rocketmq-cluster
brokerName = broker-c# 0表示broker master 非0表示 broker slaver
brokerId = 0# brokerIP1 当前broker监听的IP
brokerIP1 = 192.168.2.229# brokerIP2 存在broker主从时，在broker主节点上配置了brokerIP2的话,broker从节点会连接主节点配置的brokerIP2来同步
brokerIP2 = 192.168.2.229deleteWhen = 04
fileReservedTime = 48namesrvAddr = 192.168.2.228:9876;192.168.2.229:9876# 是否能够自动创建topic
autoCreateTopicEnable = true#Broker 对外服务的监听端口, 默认10911
# listenPort = 10911#commitLog每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#检测物理文件磁盘空间
diskMaxUsedSpaceRatio=88
#限制的消息大小
maxMessageSize=65536
#flushCommitLogLeastPages=4
#flushConsumeQueueLeastPages=2
#flushCommitLogThoroughInterval=10000
#flushConsumeQueueThoroughInterval=60000
#Broker 的角色
#- ASYNC_MASTER 异步复制Master
#- SYNC_MASTER 同步双写Master
#- SLAVE
brokerRole=SYNC_MASTER
#刷盘方式
#- ASYNC_FLUSH 异步刷盘
#- SYNC_FLUSH 同步刷盘
flushDiskType=SYNC_FLUSH
#checkTransactionMessageEnable=false
#发消息线程池数量
#sendMessageThreadPoolNums=128
#拉消息线程池数量
#pullMessageThreadPoolNums=128

6、主机B部署broker-d

cd  /mydata/rocketmq/data
vi broker-b-s.conf
#输入以下内容brokerClusterName = rocketmq-cluster
brokerName = broker-dbrokerId = 1brokerIP1 = 192.168.2.229deleteWhen = 04
fileReservedTime = 48namesrvAddr = 192.168.2.228:9876;192.168.2.229:9876listenPort = 11911#是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
#是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
autoCreateSubscriptionGroup=true
#commitLog每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#检测物理文件磁盘空间
diskMaxUsedSpaceRatio=88
#限制的消息大小
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、下载dockercompose文件

#下载到/usr/local/bin目录
curl -SL https://github.com/docker/compose/releases/download/v2.7.0/docker-compose-linux-x86_64 -o /usr/local/bin/docker-compose

8、两台主机都编辑docker-compose.yml

cd /usr/local/bin
vi docker-compose.yml
#输入以下内容
version: '4.7'
services:rmqnamesrv-a:image: apache/rocketmq:4.7.1restart: alwayscontainer_name: rmqnamesrv-aports:- 9876:9876volumes:- /mydata/rocketmq/data/namesrv/logs:/opt/logs/rocketmqlogs- /mydata/rocketmq/data/namesrv/store:/opt/storeenvironment:- JAVA_OPT_EXT=-Duser.home=/opt -Xms512m -Xmx512m -Xmn300mcommand: sh mqnamesrvrmqbroker-a:image: apache/rocketmq:4.7.1container_name: rmqbroker-aports:- 10911:10911- 10909:10909- 10912:10912volumes:- /mydata/rocketmq/data/broker-a/logs:/home/rocketmq/logs- /mydata/rocketmq/data/broker-a/store:/home/rocketmq/store- /mydata/rocketmq/data/broker-a.conf:/home/rocketmq/rocketmq-4.7.1/conf/broker.confenvironment:- TZ=Asia/Shanghai- NAMESRV_ADDR=rmqnamesrv-a:9876- JAVA_OPTS=-Duser.home=/opt- JAVA_OPT_EXT=-server -Xms2048m -Xmx4096m -Xmn2048mcommand: sh mqbroker -c /home/rocketmq/rocketmq-4.7.1/conf/broker.conf autoCreateTopicEnable=true &links:- rmqnamesrv-a:rmqnamesrv-armqbroker-b-s:image: apache/rocketmq:4.7.1container_name: rmqbroker-b-sports:- 11911:11911- 11909:11909- 11912:11912volumes:- /mydata/rocketmq/data/broker-b/logs:/home/rocketmq/logs- /mydata/rocketmq/data/broker-b/store:/home/rocketmq/store- /mydata/rocketmq/data/broker-b-s.conf:/home/rocketmq/rocketmq-4.7.1/conf/broker.confenvironment:- TZ=Asia/Shanghai- NAMESRV_ADDR=rmqnamesrv-a:9876- JAVA_OPTS=-Duser.home=/opt- JAVA_OPT_EXT=-server -Xms2048m -Xmx4096m -Xmn2048mcommand: sh mqbroker -c /home/rocketmq/rocketmq-4.7.1/conf/broker.conf autoCreateTopicEnable=true &links:- rmqnamesrv-a:rmqnamesrv-a

9、启动部署

#部署启动
docker compose up -d
#卸载命令，不要执行
docker compose down

10、自定义dashbord密码

#部署启动
mkdir -p /apps/rocketmq-dashboard/data
vi users.properties
#输入以下内容
#超级管理员
admin=admin,1
#普通用户
xkc=xkc

11、dashbord启动

docker run -d -it --name dashboard -p 18081:8080 -e "JAVA_OPTS=-Drocketmq.namesrv.addr=192.168.2.228:9876;192.168.2.229:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false  -Drocketmq.config.loginRequired=true" -v /apps/rocketmq-dashboard/data:/tmp/rocketmq-console/data  apacherocketmq/rocketmq-dashboard:latest /bin/bash

12、自定义的nginx负载均衡配置，需要配置nginx.conf文件，网上有很多坑说配置http模块，实际上配置http模块没法对mq负载均衡，正确需要在stream模块追加以下配置，如下：

stream {upstream mqserver {server 192.168.2.227:9876;server 192.168.2.228:9876;}server {listen 888;proxy_connect_timeout 1s;proxy_timeout 3s;proxy_pass mqserver;}
}

13、一键式部署的脚本，我有，但暂时不提供，有需要的可以联系博主

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

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

相关文章

Javaweb之SpringBootWeb案例员工管理之删除员工的详细解析

Javaweb之SpringBootWeb案例员工管理之删除员工的详细解析

3.3 删除员工 查询员完成之后，我们继续开发新的功能：删除员工。 3.3.1 需求 当我们勾选列表前面的复选框，然后点击 "批量删除" 按钮，就可以将这一批次的员工信息删除掉了。也可以只勾选一个复选框，仅删除一…
阅读更多...
超详细的 pytest 钩子函数 —— 之初始钩子和引导钩子来啦！

超详细的 pytest 钩子函数 —— 之初始钩子和引导钩子来啦！

前几篇文章介绍了 pytest 点的基本使用，学完前面几篇的内容基本上就可以满足工作中编写用例和进行自动化测试的需求。从这篇文章开始会陆续给大家介绍 pytest 中的钩子函数，插件开发等等。 仔细去看过 pytest 文档的小伙伴，应该都有发现 pyt…
阅读更多...
PSP - 提取 UniRef 数据库搜索的 MSA 序列物种 (Species) 信息

PSP - 提取 UniRef 数据库搜索的 MSA 序列物种 (Species) 信息

欢迎关注我的CSDN：https://spike.blog.csdn.net/ 本文地址：https://spike.blog.csdn.net/article/details/135702185 UniRef库：UniProt参考聚类（UniRef）的简称，提供了从UniProt知识库（包括异构体…
阅读更多...
[力扣 Hot100]Day7 接雨水

[力扣 Hot100]Day7 接雨水

题目描述 给定 n 个非负整数表示每个宽度为 1 的柱子的高度图，计算按此排列的柱子，下雨之后能接多少雨水。 出处 思路 就是寻找“凹”形区间，找使得左右两端点为最大的两个值的最长区间。这里我分了两种情况，右边大于等于左边…
阅读更多...
智慧校园安防系统功能 平安校园、宿舍管理的智慧校园解决方案---豌豆云

智慧校园安防系统功能 平安校园、宿舍管理的智慧校园解决方案---豌豆云

从“校园空间”出发，贴合“教学与教务”管理诉求，以“人脸识别”技术作为“身份管理”的立足点，融合“物联网和大数据”多项能力。 打造涵盖“通行考勤、平安校园、宿舍管理、会议签到和人脸支付”在内的智慧校园解决方案，助力校…
阅读更多...
MySQL深度分页优化问题

MySQL深度分页优化问题

☆* o(≧▽≦)o *☆嗨~我是小奥🍹 📄📄📄个人博客：小奥的博客 📄📄📄CSDN：个人CSDN 📙📙📙Github：传送门 📅&a…
阅读更多...
C语言基础入门48篇_00_如何学习一门新语言（针对初学者）

C语言基础入门48篇_00_如何学习一门新语言（针对初学者）

程序员之道，万变不离其宗，说相声讲究的是说、学、逗、唱，学习程序最快也是最好的办法就是：过、抄、仿、改、调、看、练、创、悟： 文章目录 1、过：2、抄代码：3、模仿改：4、勤调试&…
阅读更多...
RenderDoc 增加 DXBC to HLSL 的 shader viewer

RenderDoc 增加 DXBC to HLSL 的 shader viewer

目的 便于后续抓帧出来的 DXBC 转为 HLSL，提高可读性 原因 编写的原因，因为按照网上的大佬的BLOG，发现某个 etnlGD/HLSLDecompiler 上的工具使用上是有问题的 （有可能是以前的 render doc 版本没有问题，而我现在是在…
阅读更多...
字符串算法总结|双指针的总结

字符串算法总结|双指针的总结

在字符串旋转操作中主要是运用多次反转，最后得到结果。 例如反转字符串里的单词：可以先进行整体反转，最后进行单词反转。 例如从字符串的倒数第k位开始反转，此时可以先整体反转，在局部反转，在反转时可以用…
阅读更多...
KubeSphere平台使用

KubeSphere平台使用

KubeSphere官网地址：https://kubesphere.io/zh/ KubeKey一键部署K8S集群：https://kubesphere.io/zh/docs/v3.4/installing-on-linux/introduction/multioverview/ 一台master node（初始化主节点）、两台 work node（ joi…
阅读更多...
SCI好看的配图-汇总

SCI好看的配图-汇总

文章目录 图源：Sustainable Cities and Society【期刊】条形图2热力图-地图 图源：Sustainable Cities and Society【期刊】 引自：A machine learning-driven spatio-temporal vulnerability appraisal based on socio-economic data for COV…
阅读更多...
如何编写一个好的测试用例？才能防止背黑锅

如何编写一个好的测试用例？才能防止背黑锅

如何编写一个好的测试用例？才能防止背黑锅 什么是测试用例？一个好的测试用例包含什么？测试用例的编写思路总结 什么是测试用例？ 在这之前，思考一个问题，下面这个简单的QQ登录页面，一共又多少条…
阅读更多...
关于运维·关于Zabbix监控平台的面试点

关于运维·关于Zabbix监控平台的面试点

目录 引言：明人不说暗话，今天分享几个在面试的时候常被问到关于Zabbix监控平台的面试点 1、zabbix的优点 2、zabbix的缺点 3、zabbix的监控模式 4、zabbix自定义监控怎么做 5、zabbix的自动发现功能 6、zabbix分布式监控有什么特点 引言&#xff1…
阅读更多...
代码随想录算法训练营第三十八天| 509.斐波那契数、70.爬楼梯、746.使用最小花费爬楼梯

代码随想录算法训练营第三十八天| 509.斐波那契数、70.爬楼梯、746.使用最小花费爬楼梯

代码随想录算法训练营第三十八天| 509.斐波那契数、70.爬楼梯、746.使用最小花费爬楼梯 题目 509.斐波那契数 斐波那契数 （通常用 F(n) 表示）形成的序列称为 斐波那契数列 。该数列由 0 和 1 开始，后面的每一项数字都是前面两项数字的和。…
阅读更多...
专业130+总分380+哈尔滨工程大学810信号与系统考研经验水声电子信息与通信

专业130+总分380+哈尔滨工程大学810信号与系统考研经验水声电子信息与通信

今年专业课810信号与系统130，总分380顺利考上哈尔滨工程大学，一年的努力终于换来最后的录取，期中复习有得有失，以下总结一下自己的复习经历，希望对大家有帮助，天道酬勤，加油！专业课&…
阅读更多...
入门设计者不容错过！5款网页原型设计工具推荐！

入门设计者不容错过！5款网页原型设计工具推荐！

即时设计 即时设计是一种支持团队合作的原型设计工具，不限于设备和人群的使用，浏览器可以打开和使用。在即时设计中，您可以从0到1创建一个Web页面原型，具有钢笔、矩形、矢量编辑、轮廓、文本、色彩填充等设计功能，足以…
阅读更多...
达梦数据库入门语法：从基础到进阶的指南

达梦数据库入门语法：从基础到进阶的指南

目录 博客前言： 达梦数据库语法介绍 一.创建表空间 1.图形化创建 2.语法创建 ​编辑​编辑 3.修改表空间参数 图形化修改 ​编辑​编辑 语法修改 4.设置加密算法、密码 二.创建用户 1.图形化 2.sql执行 ​编辑 3.授予权限 授予用户 DBA 权限 授予用户…
阅读更多...
三、RHCE--时间服务器

三、RHCE--时间服务器

三、RHCE--时间服务器 一、简介二、软件安装三、配置时间服务器客户端四、配置时间服务器服务端五、示例： 一、简介 NTP 是网络时间协议（Network Time Protocol）的简称，通过 udp 123 端口进行网络时钟同步。 Chrony是一个开源自由…
阅读更多...
k8s---ingress对外服务（traefik）

k8s---ingress对外服务（traefik）

目录 ingress的证书访问 traefik traefik的部署方式： deamonset deployment nginx-ingress与traefix-ingress相比较 nginx-ingress-controller ui访问 deployment部署 ingress的证书访问 ingress实现https代理访问: 需要证书和密钥 创建证书 密钥 secre…
阅读更多...
将 SQL Server 2022 数据库备份到 MinIO

将 SQL Server 2022 数据库备份到 MinIO

Microsoft 在将 S3 连接器和 Polybase 添加到 SQL Server 2022 时取得了重大飞跃。因此，企业可以利用他们保存到对象存储中的大量数据，并使用它来丰富 SQL Server 表。他们还可以利用对象存储来备份 SQL Server，这是开放性和云原生灵活性的又…
阅读更多...
最新文章

Copyright @ 2022~2023