网站首页 > 博客文章 正文
RocketMQBroker集群模式
单Master模式:只有一台Master服务器,一旦Broker服务器重启或宕机整个集群不可用,通常不会使用该模式;
多Master模式(无Slave节点):一个集群无Slave服务器,全部都是Master服务器(例如有3台Master服务器),
优点:集群配置简单,单Master服务器重启或宕机对应用无影响,性能最高。可通过磁盘RAID阵列保证消息不丢失;
缺点:单台机器宕机期间,这台服务器上未被消费的消息在机器恢复之前不可订阅,消息实时性会受到影响;
多Master多Slave模式-异步复制:每台Master配置一台Slave服务器,HA采用异步复制方式,主备有短暂消息延迟,毫秒级;
优点:Master宕机后,消费者仍可以从Slave消费,此过程对应用透明,不需要人工干预;
多Master多Slave模式-同步双写:每台Master配置一台Slave服务器,HA采用同步双写方式,主备都写入成功才向应用返回成功;
优点:数据同步和服务都没有单点问题,Master宕机情况系消息无延迟,服务可用性和数据可用性非常高;
缺点:性能比异步复制低一些,大约低10%,发送单个消息的RT会略高。
本教程采用的是多Master模式(无Slave节点)的方式搭建集群;
安装RocketMQ
安装maven
安装rocketmq-console需要用maven进行编译,如果没有安装过maven需要安装maven并配置环境变量
安装RocketMQ
配置RocketMQ集群
RocketMQ支持单Master模式、多Master模式(无slave节点)、多Master多Slave模式-异步复制、多Master多Slave模式-同步双写 四种集群部署模式,由于服务器数量的问题,这里采用的是多Master模式;
修改集群配置文件
我配置的是多Master模式(无slave节点)这里只列举了broker-a.properties文件的修改,broker-b.properties,broker-c.properties 这两个配置文件只需更改brokerName,其余配置与broker-a.properties 一样;
注意事项:RocketMQ broker默认要求分配的内存不低于4G,根据实际服务器的性能可以有所调整,服务器内存充足的情况下可以忽略此步骤;
- 启动集群
安装管理控制台
启动控制台后访问ip:8081(ip为控制台安装服务器的ip,端口号是配置文件中设置的)
猜你喜欢
- 2024-11-18 快速使用docker方式部署安装RocketMQ
- 2024-11-18 介绍新版RocketMQ v4.9.3 下载、安装、配置的完成过程
- 2024-11-18 docker-4:mac使用docker部署开发用rocketmq
- 2024-11-18 扩展RocketMQ 使其支持任意时间精度的消息延迟
- 2024-11-18 RocketMQ如何突破内网限制,实现内外网互通
- 2024-11-18 SpringBoot3.0 + RocketMq 构建企业级数据中台完结
- 2024-11-18 「转」Spring Cloud异步场景分布式事务怎样做?试试RocketMQ
- 2024-11-18 RocketMQ集群搭建
- 2024-11-18 RocketMQ 的持久化配置
- 2024-11-18 RocketMQ,如何处理消息积压问题
你 发表评论:
欢迎- 最近发表
- 标签列表
-
- powershellfor (55)
- messagesource (56)
- aspose.pdf破解版 (56)
- promise.race (63)
- 2019cad序列号和密钥激活码 (62)
- window.performance (66)
- qt删除文件夹 (72)
- mysqlcaching_sha2_password (64)
- ubuntu升级gcc (58)
- nacos启动失败 (64)
- ssh-add (70)
- jwt漏洞 (58)
- macos14下载 (58)
- yarnnode (62)
- abstractqueuedsynchronizer (64)
- source~/.bashrc没有那个文件或目录 (65)
- springboot整合activiti工作流 (70)
- jmeter插件下载 (61)
- 抓包分析 (60)
- idea创建mavenweb项目 (65)
- vue回到顶部 (57)
- qcombobox样式表 (68)
- vue数组concat (56)
- tomcatundertow (58)
- pastemac (61)
本文暂时没有评论,来添加一个吧(●'◡'●)