RabbitMQ集群部署之镜像模式

news/2024/11/24 14:05:57/

RabbitMQ集群的普通模式中,一旦创建队列的主机宕机,队列就会不可用。不具备高可用能力。如果要解决这个问题,必须使用官方提供的镜像集群方案。

官方文档地址:https://www.rabbitmq.com/ha.html

1.镜像模式的特征

默认情况下,队列只保存在创建该队列的节点上。而镜像模式下,创建队列的节点被称为该队列的主节点,队列还会拷贝到集群中的其它节点,也叫做该队列的镜像节点。

但是,不同队列可以在集群中的任意节点上创建,因此不同队列的主节点可以不同。甚至,一个队列的主节点可能是另一个队列的镜像节点

用户发送给队列的一切请求,例如发送消息、消息回执默认都会在主节点完成,如果是从节点接收到请求,也会路由到主节点去完成。镜像节点仅仅起到备份数据作用

当主节点接收到消费者的ACK时,所有镜像都会删除节点中的数据。

总结如下:

  • 镜像队列结构是一主多从(从就是镜像)
  • 所有操作都是主节点完成,然后同步给镜像节点
  • 主宕机后,镜像节点会替代成新的主(如果在主从同步完成前,主就已经宕机,可能出现数据丢失)
  • 不具备负载均衡功能,因为所有操作都会有主节点完成(但是不同队列,其主节点可以不同,可以利用这个提高吞吐量)

2.镜像模式的配置

镜像模式的配置有3种模式:

ha-modeha-params效果
准确模式exactly队列的副本量count集群中队列副本(主服务器和镜像服务器之和)的数量。count如果为1意味着单个副本:即队列主节点。count值为2表示2个副本:1个队列主和1个队列镜像。换句话说:count = 镜像数量 + 1。如果群集中的节点数少于count,则该队列将镜像到所有节点。如果有集群总数大于count+1,并且包含镜像的节点出现故障,则将在另一个节点上创建一个新的镜像。
all(none)队列在群集中的所有节点之间进行镜像。队列将镜像到任何新加入的节点。镜像到所有节点将对所有群集节点施加额外的压力,包括网络I / O,磁盘I / O和磁盘空间使用情况。推荐使用exactly,设置副本数为(N / 2 +1)
nodesnode names指定队列创建到哪些节点,如果指定的节点全部不存在,则会出现异常。如果指定的节点在集群中存在,但是暂时不可用,会创建节点到当前客户端连接到的节点。

这里我们以rabbitmqctl命令作为案例来讲解配置语法。

2.1.exactly模式

rabbitmqctl set_policy ha-two "^two\." '{"ha-mode":"exactly","ha-params":2,"ha-sync-mode":"automatic"}'
  • rabbitmqctl set_policy:固定写法
  • ha-two:策略名称,自定义
  • "^two\.":匹配队列的正则表达式,符合命名规则的队列才生效,这里是任何以two.开头的队列名称
  • '{"ha-mode":"exactly","ha-params":2,"ha-sync-mode":"automatic"}': 策略内容
    • "ha-mode":"exactly":策略模式,此处是exactly模式,指定副本数量
    • "ha-params":2:策略参数,这里是2,就是副本数量为2,1主1镜像
    • "ha-sync-mode":"automatic":同步策略,默认是manual,即新加入的镜像节点不会同步旧的消息。如果设置为automatic,则新加入的镜像节点会把主节点中所有消息都同步,会带来额外的网络开销

2.2.all模式

rabbitmqctl set_policy ha-all "^all\." '{"ha-mode":"all"}'
  • ha-all:策略名称,自定义
  • "^all\.":匹配所有以all.开头的队列名
  • '{"ha-mode":"all"}':策略内容
    • "ha-mode":"all":策略模式,此处是all模式,即所有节点都会称为镜像节点

2.3.nodes模式

rabbitmqctl set_policy ha-nodes "^nodes\." '{"ha-mode":"nodes","ha-params":["rabbit@nodeA", "rabbit@nodeB"]}'
  • rabbitmqctl set_policy:固定写法
  • ha-nodes:策略名称,自定义
  • "^nodes\.":匹配队列的正则表达式,符合命名规则的队列才生效,这里是任何以nodes.开头的队列名称
  • '{"ha-mode":"nodes","ha-params":["rabbit@nodeA", "rabbit@nodeB"]}': 策略内容
    • "ha-mode":"nodes":策略模式,此处是nodes模式
    • "ha-params":["rabbit@mq1", "rabbit@mq2"]:策略参数,这里指定副本所在节点名称

3.测试

我们使用exactly模式的镜像,因为集群节点数量为3,因此镜像数量就设置为2。

运行下面的命令:

docker exec -it mq1 rabbitmqctl set_policy ha-two "^two\." '{"ha-mode":"exactly","ha-params":2,"ha-sync-mode":"automatic"}'

在这里插入图片描述

下面,我们创建一个新的队列:

在这里插入图片描述

在任意一个mq控制台查看队列:

在这里插入图片描述

3.1.测试数据共享

two.queue发送一条消息:

在这里插入图片描述

然后在mq1mq2mq3的任意控制台查看消息:

在这里插入图片描述

3.2.测试高可用

现在,我们让two.queue的主节点mq1宕机:

docker stop mq1

查看集群状态:

在这里插入图片描述

查看队列状态:

在这里插入图片描述

发现依然是健康的!并且其主节点切换到了rabbit@mq2上。


http://www.ppmy.cn/news/332348.html

相关文章

“住过一晚两万的ICU后,我还是建议你不要轻易买保险”

两个月前的一件事,让我突然明白「孤立无援」的含义。 (真实经历,经当事人授权,侵权必究) 一个朋友的发小,温婉独立,农村走出来的高校美女硕士。 有着体面的工作和生活,半年前刚刚步入…

复旦的新衣再登Nature!穿在身上能为手机充电,可水洗可弯折,刀戳车撵都不坏...

点击上方“AI遇见机器学习”,选择“星标”公众号 重磅干货,第一时间送达 杨净 鱼羊 发自 凹非寺量子位 报道 | 公众号 QbitAI 今天,一件来自中国的衣服登上了Nature。 没看出有什么特别?别眨眼,下一秒神奇的事情就发生…

我在翻译《Thinking in Java》(二)

1.4 隐藏的实现 应当将程序开发人员分成类创建者(负责创建新的数据类型)和客户端程序员(在编程中使用这些类的人)。客户端程序员的目标是收集足够多的类来进行快速程序开发。类创建者的目标则是设计一个类,并且提供客户…

开发环境的准备

创建自己的小程序账号 在开发自己的微信小程序之前,首先需要注册小程序账号,以下一步一步详细说明。 打开浏览器,输入 mp.weixin.qq.com: 因为是第一次使用,所以选择画面右上角的“立即注册”。 选择左下角的“小程序…

零基础入门微信小程序开发 (2020 版)

专栏亮点 零基础学习,初学者轻松入门就算你完全没有开发过微信小程序,甚至没有接触过小程序的相关技术(XML、JSON、JavaScript 等)也可以轻松入门!涵盖开发全周期,助你尽快完成自己的小程序:麻雀虽小,五脏俱全。专栏通过 9 篇文章覆盖从开发账号注册、开发工具安装、小…

Canvas实现缩放+涂鸦改进

几个月以前,有人问了我一个canvass怎么实现缩放和涂鸦的问题,我基于当时的想法写了一篇博客,但是后来发现当时做的不完善,所以实现上其实还是有一些其他问题的。但是因为前段时间太忙了,也就一直没有机会去改进它。现在…

C/C++/Java/Go/Rust,Python喊你来打擂:3秒钟内统计出小于1亿的素数个数

前几天,有个非计算机专业的同学问我,如何快速找出1亿之内的孪生素数——所谓孪生素数,就是差值为2的两个素数。原本以为这是一个很简单的问题,随便用python写了一个方法,没想到却要跑17分钟左右。改用C试试&#xff0c…

看到「财富自由」就想吐

这些年,网上关于财富自由的人生故事,可以说是数不胜数。 不过,其中 70% 像是真假参半的凡尔赛炫耀帖,剩下的那 30% 则更像是兜售某些产品的广告。 比如前几天很火的腾讯 35 岁员工准备退休的帖子,就挺能说明问题。 这种…