当前位置: 首页 > news >正文

RabbitMQ-镜像队列(Mirrored Queues)

作者介绍:简历上没有一个精通的运维工程师。请点击上方的蓝色《运维小路》关注我,下面的思维导图也是预计更新的内容和当前进度(不定时更新)。

图片

中间件,我给它的定义就是为了实现某系业务功能依赖的软件,包括如下部分:

Web服务器

代理服务器

ZooKeeper

Kafka

RabbitMQ(本章节)

上个小节我们介绍了RabbitMQ伪集群模式,虽然元数据是同步共享的,但是数据只存在某一台节点,当这个节点宕机以后,整个集群也就出现问题,所以本小节我们介绍一个新的正在的高可用方案:镜像队列(Mirrored Queues)。

宕机之前队列里面有不少数据,如下图。

图片

下图就是宕机以后的队列信息,全部都显示离线。

图片

镜像队列(Mirrored Queues)

下面的配置基于刚才的伪集群,注意这个高可用模式是针对虚拟主机级别配置。

./sbin/rabbitmqctl set_policy ha-all "^" '{"ha-mode": "exactly","ha-params": 3,"ha-sync-mode": "automatic","queue-master-locator": "min-masters"
}' --priority 10 --apply-to queues

上面的配置是就是设置默认的虚拟主机"/":

规则名字:ha-all。

针对队列:^ 代表所有队列。

镜像模式:静态指定(还有是所有节点都有镜像和指定节点有影响)。

镜像数量:3 (一主2个镜像)。

同步模式:自动同步,新节点加入时候会同步历史数据。

选主策略:节点宕机以后选举策略(最少master节点)。

策略优先级:10数值越高优先级越高,范围 0-99。

针对对象:队列,其他本身就高可用。

如果要设置其他虚拟主机或者查看其他虚拟主机则可以使用 -p xxx。

[root@rabbitmq01 rabbitmq_server-3.8.35]# ./sbin/rabbitmqctl list_policies
Listing policies for vhost "/" ...
vhost	name	pattern	apply-to	definition	priority
/	ha-all	^	queues	{"ha-mode":"exactly","ha-params":3,"ha-sync-mode":"automatic","queue-master-locator":"min-masters"}	10

这个时候,我们查看当前的镜像节点不同的队列就有不同的队列。​​​​​​​

[root@rabbitmq01 rabbitmq_server-3.8.35]# ./sbin/rabbitmqctl list_queues name messages synchronised_slave_pids
Timeout: 60.0 seconds ...
Listing queues for vhost / ...
name	messages	synchronised_slave_pids
test06	0	[<rabbit@rabbitmq02.1749892590.4412.1>, <rabbit@rabbitmq03.1749894297.1354.1>]
test07	0	[<rabbit@rabbitmq02.1749892590.4435.1>, <rabbit@rabbitmq03.1749894297.1392.1>]
test04	0	[<rabbit@rabbitmq03.1749894297.1344.1>, <rabbit@rabbitmq02.1749892590.4462.1>]
test02	1391	[<rabbit@rabbitmq02.1749892590.4429.1>, <rabbit@rabbitmq03.1749894297.1368.1>]
test05	0	[<rabbit@rabbitmq02.1749892590.4432.1>, <rabbit@rabbitmq03.1749894297.1389.1>]

离线一个节点还可以正常生产消息和消息消息。

图片

这样就可以实现集群的高可用。

http://www.lryc.cn/news/607001.html

相关文章:

  • 测试平台如何重塑CI/CD流程中的质量协作新范式
  • 什么是CI/CD?
  • 层次聚类:无需“猜”K值,如何让数据自己画出“家族图谱”?
  • HQChart实战教程58:K线主图仿TradingView实现
  • 日志归档存储策略在海外云服务器环境的容量规划方法
  • Bootstap Vue 之b-form-radio-group 不显示选中状态问题
  • Web学习:SQL注入之联合查询注入
  • 《协作画布的深层架构:React与TypeScript构建多人实时绘图应用的核心逻辑》
  • 《React Router深解:复杂路由场景下的性能优化与导航流畅性构建》
  • Positions, sizes, and layouts(位置、大小和布局)
  • 使用 whisper, 音频分割, 整理需求 2
  • 3D 建模核心术语扫盲:拓扑、UV 展开、烘焙与 AO 贴图解析
  • 2025年08月01日Github流行趋势
  • qt贝塞尔曲线演示工具
  • MongoDB 详细用法与 Java 集成完整指南
  • 如何安全管理SSH密钥以防止服务器被入侵
  • Java应用服务器选型指南:WebLogic vs. Tomcat、WebSphere、JBoss/Wildfly
  • Vue3中Markdown解析与渲染的完整解决方案:从安全到性能优化
  • 区块链技术如何确保智能合约的安全性和可靠性?
  • Qt 开发 IDE 插件开发指南
  • 在SQL SERVER 中如何用脚本实现每日自动调用存储过程
  • 将本地commit已经push到orgin后如何操作
  • 微波(Microwave)与毫米波(Millimeter wave)简介
  • windows mamba-ssm环境配置指南
  • 在 Docker 中启动 Nginx 并挂载配置文件到宿主机目录
  • 代码随想录算法训练营第三十八天
  • Mermaid流程图可视化系统:基于Spring Boot与Node.js的三层架构实现
  • h5独立部署
  • (转)mybatis和hibernate的 缓存区别?
  • AG-UI 协议全面解析--下一代 AI Agent 交互框架医疗应用分析(上)