正文 

当前位置： 首页 > java > java教程

rocketmq双主集群

Dear、 Dear、     2022-08-29     279

关键词：

RocketMQ 双主集群

环境：

主机名 环境 IP 角色
master1 Centos7 172.16.0.89 master1
master2 Centos7 172.16.0.221 master2

 

1.安装

安装这里选择在官网上下载源码包安装。

wget -O /data/softs/src/rocketmq.tar.gz 
tar -zxvf /data/softs/src/rocketmq.tar.gz
mv /data/softs/src/alibaba-rocketmq /data/softs/src/rocketmq
cd /data/softs/src/rocketmq && make && make install

2.修改配置

安装完成后可以在$ROCKETMQ_HOME/conf/2m-noslave 下找到所需的配置文件

需求修改的地方不多

master1 对应修改broker-a.properties文件,master2 对应修改broker-b.properties文件

brokerClusterName=rocketmq-cluster  #所属集群名字 这个名字要一致
brokerName=broker-a/broker-b    #这里2个分别对应文件名
brokerId=0
namesrvAddr=172.16.0.89:9876;172.16.0.221:9876
listenPort=10911 #Broker 对外服务的监听端口

3.启动服务

启动服务的顺序： nameserver----broker

关闭服务的顺序： broker----nameserver

对应命令：

nohup sh $ROCKETMQ_HOME/bin/mqnamesrv & #启动nameserver

nohup sh $ROCKETMQ_HOME/bin/mqbroker -n 172.16.0.89:9876 -c $ROCKETMQ_HOME/conf/2m-noslave/broker-a/b.properties &
#启动broker
###两台master 启动 指定的IP要一致,即指定到同1台nameserver上

mqadmin clusterList  -n 172.16.0.89:9876#查看集群信息

Edit By MaHua

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模式-同步双... 查看详情

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

基于前面一主一从同步搭建我们企业级开发，一般采用的是双主双从同步，以及异步刷盘；同步消息保证消息不丢失，异步刷盘提高吞吐量；我们VM里再克隆两台机器；192.168.0.110机器作为m1主节点192.168.0.103... 查看详情

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

基于前面一主一从同步搭建我们企业级开发，一般采用的是双主双从同步，以及异步刷盘；同步消息保证消息不丢失，异步刷盘提高吞吐量；我们VM里再克隆两台机器；192.168.0.110机器作为m1主节点192.168.0.103... 查看详情

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

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

49.rocketmq双主搭建（本文非eamonsec原创）

...明：本文非EamonSec原创，copy自网上下载的某个个文件1、RocketMQ介绍1.1. 简介RocketMQ是一款分布式、队列模型的消息中间件，具有以下特点：能够保证严格的消息顺序提供丰富的消息拉取模式高效的订阅者水平扩展能力实时的消... 查看详情

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集群方案双主双从同步-和-异步复制方案... 查看详情

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双主发送消息slave_not_available状态(代码片段)

RocketMQ最佳实践之Producer投递状态发送消息时，将得到包含SendStatus的SendResult。首先，我们假设消息的isWaitStoreMsgOK =true(默认是true)。如果不是，我们将总会得到SEND_OK，如果没有抛出异常。下面是关于每个状态的描述列表:FLUSH_D... 查看详情

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实战-搭建高可用的分布式消息队列集群(代码片段)

文章目录RocketMQ各部分角色RocketMQ多集群配置和部署实战集群查看方式Broker配置参数介绍RocketMQ各部分角色NameServer，Broker，Producer，Consumer类比邮政系统，Producer是发信人；Consumer是收信人；Broker是负责暂存、... 查看详情

高可用集群架构keepalived双主热备

...备用节点永远访问不上，将造成服务器资源的浪费。1、双主热备的原理图 DNS是在云服务器中的 2、云服务器DNS解析配置如下图，同一个域名www配置了两个外网端口 3、Keepalived双主热备的实现nginx128节点点配置  ... 查看详情

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

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

rocket详细教程(代码片段)

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

keepalived双主模式高可用集群

    一、keepalived简介    keepalived是vrrp协议的实现，原生设计目的是为了高可用ipvs服务，keepalived能够配置文件中的定义生成ipvs规则，并能够对各RS的健康状态进行检测；通过共用的虚拟IP地址对外提... 查看详情

rocketmq集群部署配置

目标，使用2台机器部署RocketMQ多Master多Slave模式，异步复制集群模式。第一步，修改/etc/hosts文件192.168.116.115rocketmq1192.168.116.116rocketmq2集群机器配置完成之后，集群内进行ping一下，确保都通。编译得到环境gitclone-bdevelophttps://github.... 查看详情

双主模型高可用负载均衡集群的实现（keepalived+lvs-dr）

实现keepalived双主模型lvs高可用集群 一、拓扑图650)this.width=650;"src="https://s2.51cto.com/wyfs02/M01/9A/9B/wKiom1lYXyXjsm_NAAC0uSYuwXI603.gif"title="11.gif"width="500"height="352"border="0"hspace="0"vspace="0" 查看详情

docker部署rocketmq集群

最近搭建RocketMQ踩了一些坑，更新下第一步，创建目录mkdir-p/opt/rocketmq/logs/nameserver-amkdir-p/opt/rocketmq/logs/nameserver-bmkdir-p/opt/rocketmq/store/nameserver-amkdir-p/opt/rocketmq/store/nameserver-bmkd 查看详情