RabbitMQ集群构建

逃离我推掉我的手 2022-02-01 15:31 418阅读 0赞

目录

RabbitMQ集群架构模式

主备模式

远程模式

多活模式

从零开始构建一个高可靠的RabbitMQ

RabbitMQ集群环境搭建

负载均衡组件HAProxy搭建

KeepAlicved搭建

集群的配置文件与集群运维故障、失败转移

配置文件

集群恢复与故障转移

高级插件的使用


RabbitMQ集群架构模式

主备模式

实现RabbitMQ的高可用集群,两者之间相互转换,当主节点宕机后,备用节点充当主节点。

主从节点:主节点提供读写,从节点提供读。

activemq利用zookeeper做主/备

image.png

远程模式

Shovel集群

镜像模式:集群模式的经典,保证100%数据不丢失,集群架构如下图:

image.png

多活模式

异地数据复制,双中心模式,多中心

image.png

从零开始构建一个高可靠的RabbitMQ

RabbitMQ集群环境搭建

负载均衡组件HAProxy搭建

高性能的负载均衡组件

image.png

KeepAlicved搭建

通过VRRP(Virtual Router RedundancyProtocol)虚拟路由器冗余协议的缩写,目的是解决静态路由单点故障问题的,就是上面的HAProxy出现故障的时候,能够保证党个别节点宕机时,整个网络可以不间断运行。

1556885516928-8e4c83da-065f-428e-ae06-0fd1ec1ce8e4.png

集群的配置文件与集群运维故障、失败转移

配置文件

image.png

image.png

集群恢复与故障转移

前提:两个节点A和B组成一个镜像队列

场景1:A先停,B后停

该场景下B是Master,先启动B,再启动A。或者先启动A,30s之后再启动B即可恢复镜像队列

场景2:A、B同时停机

该场景下可能是由于机房断电造成的,只需在30秒之后连续启动A和B即可恢复镜像

场景3:A先停,B后停,A无法恢复

先启动B,在B节点上调用控制台命令:rabbitmqctl forget_cluster_node A 解除与A的Cluster关系,再将新的Slave节点加入B即可重新恢复镜像队列

场景4:A先停,B后停,B无法恢复

执行forget_cluster_node —offline B(线下)命令将B剔除cluster,然后A正常启动,最后将新的Slave节点加入A即可重新恢复镜像队列

场景5:A先停,B后停,A、B无法恢复,但能得到A或B的磁盘文件

通过恢复数据,将A或B的数据库文件拷贝到新节点,再将新节点的hostname改成A或B的hostname,如果是A节点(Slave)的磁盘文件,场景4处理,如果是B(Master)的磁盘文件,场景3处理,最后将新的Slave加入到新节点后完成恢复

高级插件的使用

延迟插件

延迟队列可以做什么事情?

比如消息的延迟推送、定时任务(消息)的执行。包括一些消息重试策略的配合使用,以及用于业务削峰限流、降级的异步延迟消息都是延迟队列的实际应用场景

发表评论

表情:
评论列表 (有 0 条评论,418人围观)

还没有评论,来说两句吧...

相关阅读

    相关 RabbitMQ

    RabbitMQ集群 在RabbitMQ集群里,运行时状态包含交换器、队列、绑定器、用户、虚拟主机以及策略,它们对所有节点都可用。 这种共享运行时状态的特性,使得集群

    相关 RabbitMQ安装

    一、准备两台虚拟机 1、设置一台的别名为A,:`vi /etc/hostname` 2、设置另一台的别名为B:`vi /etc/hostname` 3、修改每一个虚

    相关 rabbitmq 部署

    rabbitmq 目前的主要功能是: 1.用作消息队列,发送消息,接受消息 2.用作websocket主动推送引擎,与web端建立长链接 为什么要用到rabbitmq 集

    相关 RabbitMQ

    一、RabbitMQ集群概述 rabbitmq有三种模式:单机模式,普通集群模式,镜像集群模式 1、单机模式: 本地测试用、生产环境不会用 2、普通集

    相关 rabbitmq简介

    rabbitmq自带内建集群,其旨在rabbitmq的高可用,允许消费者和生产者在rabbitmq节点崩溃的情况下继续运行,以及通过添加更多节点的方式来线性扩展消息的吞吐量。但