17rocketmq集群双主双从同步搭建(代码片段)

java1234_小锋 java1234_小锋     2022-12-12     424

关键词:

基于前面一主一从同步搭建

我们企业级开发,一般采用的是双主双从同步,以及异步刷盘;

同步消息保证消息不丢失,异步刷盘提高吞吐量;

我们VM里再克隆两台机器;

192.168.0.110 机器 作为m1主节点

192.168.0.103 机器作为s1从节点

192.168.0.111 机器 作为m2主节点

192.168.0.112 机器作为s2从节点

首先,我们把namesrvAddr配置修改,每个broker都要注册到所有nameserver

namesrvAddr=192.168.0.110:9876;192.168.0.103:9876;192.168.0.111:9876;192.168.0.112:9876;

刷盘机制都改成异步:

#- ASYNC_FLUSH 异步刷盘
#- SYNC_FLUSH 同步刷盘
flushDiskType=ASYNC_FLUSH

192.168.0.111 机器 作为m2主节点从m1主节点的broker-a.properties复制内容到broker-b.properties文件;

修改broker-b.properties配置文件;

修改内容如下:

brokerName=broker-b

192.168.0.112 机器 作为s2主节点从s1主节点的broker-a-s.properties复制内容到broker-b-s.properties文件;

修改broker-b-s.properties配置文件;

修改内容如下:

brokerName=broker-b

然后分别启动四个机器;

先启动nameserver:

nohup sh mqnamesrv &

再启动broker:

192.168.0.110 机器 作为m1主节点

nohup sh mqbroker -c /home/mq/rocketmq/conf/2m-2s-sync/broker-a.properties &

192.168.0.103 机器作为s1从节点

nohup sh mqbroker -c /home/mq/rocketmq/conf/2m-2s-sync/broker-a-s.properties &

192.168.0.111 机器 作为m2主节点

nohup sh mqbroker -c /home/mq/rocketmq/conf/2m-2s-sync/broker-b.properties &

192.168.0.112 机器作为s2从节点

nohup sh mqbroker -c /home/mq/rocketmq/conf/2m-2s-sync/broker-b-s.properties &

可视化控制台项目namesrvAddr配置改下:

启动控制台项目:

项目代码,生产端和消费端name-server都改下;

启动测试:

两个主节点一起分担消息处理;

我们模拟下,让a主节点broker挂掉;

sh mqshutdown broker

再运行代码测试,发现b主节点承担了所有消息接收和处理;实现了高可用;

说明:这个是锋哥的RocketMQ备课笔记,等备课完,会发布配套的视频教程,如有需要,可以先加锋哥WX:java1239 欢迎白嫖

rocketmq-双主双从集群+dashborad搭建(云服务器)(代码片段)

文章目录一、理论垫基础1.NameServer集群2.Producer集群3.Consumer集群4.Broker集群4.1节点间数据同步以及消息的持久化4.2Broker的集群模式4.2.1、单Master模式4.2.2、多Master模式4.2.3、多Master多Slave模式-异步复制4.2.4、多Master多Slave模式-同步双... 查看详情

rocketmq集群搭建2(代码片段)

1.修改配置配件本次搭的集群是双主双从的同步模式  双主双从的配置文件再上图所示的里面服务器:192.168.100.128内需配置(下图中的:broker-a.properties和broker-b-s.properties)   broker-a.properties中的配置文件如下#所... 查看详情

rocketmq4.5.1双主双从异步复制环境搭建(代码片段)

基础环境操作系统:CentOS7实例:192.168.63.129,192.168.63.130,192.168.63.131,192.168.63.132Java:jdk-8u191-linux-x64.tar.gz安装JDK先把系统里面自带的卸载掉 [[email protected]soft]#rpm-qa|grepjavapython-javapackages-3.4. 查看详情

安装部署rocketmq集群(双主双从)

参考技术A在前面,我们介绍了如果快速安装单个RocketMQ。快速安装意味着这只是在测试环境下的小打小闹,我们在单机安装的基础上,尝试安装RocketMQ集群。本次安装为了方便,使用的是已经编译好的二进制包进行安装部署。Rock... 查看详情

rocketmq双主双从同步写安装部署

1,机器ip软件版本jdk-8u131-linux-x64.tar.gzrocketmq-all-4.2.0-bin-release.ziprocketmq-console-ng-1.0.0.jar10.15.10.238HNVM015238nameserver1rocketmq-masterarocketmq-slaveb10.15.10.239HNVM015239nameserver2rock 查看详情

部署:单主部署一主一从部署双主双从部署代码测试(代码片段)

一.RocketMQ单机部署Hosts添加信息我们首先进入/etc/hosts来添加信息vim/etc/hosts添加信息如下: 上传解压安装包 通过XFTP工具将apache-rocketmq.tar.gz传到/usr/local/software,然后添加/usr/local/apache-rocketmq目录,再将apache-rocketmq.ta 查看详情

rocketmq安装及集群搭建(代码片段)

...里写自定义目录标题一、下载安装1.下载2.基础概念3.启动RocketMQ二、安装RocketMQconsole1.使用git拉取项目2.修改配置文件3.打包4.启动项目三、搭建双主双从集群1.创建服务器1中的消息存储路径2.修改服务器1配置文件3.创建服务器2中... 查看详情

rocketmq单台,各种集群,可视化安装步骤(代码片段)

文章目录下载地址安装JDK1.8安装RocketMQ解压配置环境变量方便随时使用MQ命令配置MQ启动内存大小启动rocketmq测试关闭RocketMQRocketMQ可视化界面打包项目运行启动管理界面访问管理界面RocketMQ集群方案双主双从同步-和-异步复制方案... 查看详情

mysql搭建主从复制(一主一从,双主双从)(代码片段)

主从复制原理Mysql中有一个binlog二进制日志,这个日志会记录下所有修改了的SQL语句,从服务器把主服务器上的binlog二进制日志在指定的位置开始复制主服务器所进行修改的语句到从服务器上执行一遍。流程图2|0搭建一主... 查看详情

mysql主从复制搭建之一主一从双主双从搭建(代码片段)

1.MySQL主从复制原理1.1为什么要做主从复制?在业务复杂的系统中,有这么一个情景,有一句sql语句需要锁表,导致暂时不能使用读的服务,那么就很影响运行中的业务,使用主从复制,让主库负责写&#x... 查看详情

mycat学习第二天之性能监控,读写分离,集群搭建(代码片段)

...写分离2.4MySQL双主双从搭建2.5MyCat双主双从读写分离3.Mycat集群搭建 查看详情

rocket详细教程(代码片段)

目录1、RocketMQ整体介绍2、核心概念模型3、RocketMQ-源码包下载与结构说明4、RocketMQ-环境搭建(搭建一个实例)   4.1、Hosts添加信息   4.2、上传解压   4.3、创建存储路径   4.4、编辑RocketMQ配置文件   4.5、修改日志... 查看详情

keepalived双主双从配置(代码片段)

双主双从配置:(机器ip地址为自己本身机器的ip请勿使用博主的IP)配置过程时间有点长,代码比较多,配置的时候请看清加油,打工人配置环境:keepalived1:192.66.66.101keepalived2:192.66.66.102web1&#... 查看详情

4读写分离---双主双从(mycat)(代码片段)

双主双从一个主机m1用于处理所有写请求,它的从机s1和另一台主机m2还有它的从机s2负责所有读请求。当m1主机宕机后,m2主机负责写请求,m1、m2互为备机。  角色        地址master1  &nbs... 查看详情

rocketmq搭建(代码片段)

...4位操作系统,Linux/Unix/MacOS64位JDK1.8+1、下载安装包rocketmq-all-4.9.2-bin-release.zip2、加压安装包unziprocketmq-all-4.9.2-bin-release.zip3、默认配置修改修改rocketmq/bin目录下runbroker.sh、runserver.shjvm参数(按服务器内存大小适配置,... 查看详情

keepalive单主双主模型的配置(代码片段)

keepalive单主模式的配置一环境:关闭防火墙,iptables-AOUTPUT-d224.100.120.18-jREJECT或添加a记录关闭selinux,同步时间timedatectlset-timezoneAsia/Shanghai间timedatectlset-timezoneAsia/Shanghai二步骤:1yuminstallkeepalived#安装高可用软件2cd/etc/ 查看详情

16rocketmq集群一主一从同步搭建(代码片段)

基于前面的单机模式,我们VM里面克隆一下系统;192.168.0.110机器作为主节点192.168.0.103机器作为从节点配置项要点:brokerClusterName集群名称一样;brokerName同一组主从节点名称一样;brokerId为0表示Master主节点,... 查看详情

mmm双主-双从读写分离部署(代码片段)

...ysql-mmm-agent配置6.4其他节点配置6.5管理Monitor节点配置七MMM集群的启动7.1管理监控Monitor节点启动7.2所有agent节点启动八MMM基本维护8.1MMM常见命令8.2查看集群状态8.3查看集群运行模式8.4检查节点情况8.5日志文件九测试MMM9.1测试集群复... 查看详情