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

RabbitMQ 集群与高可用配置

通过 Erlang 的分布式特性(通过 magic cookie 认证节点)进行 RabbitMQ 集群,各 RabbitMQ 服务为对等节点,即每个节点都提供服务给客户端连接,进行消息发送与接收。

这些节点通过 RabbitMQ HA 队列(镜像队列)进行消息队列结构复制。本方案中搭建 3 个节点,并且都是磁盘节点(所有节点状态保持一致,节点完全对等),只要有任何一个节点能够工作,RabbitMQ 集群对外就能提供服务。

环境

CentOS 

RabbitMQ 

HAProxy 

RabbitMQ 集群安装在 3 个节点上:192.168.10.1、192.168.10.2、192.168.10.3;

HAProxy 安装在 192.168.10.4 上,用于对外提供 RabbitMQ 均衡。

配置步骤

1. 安装 erlang、rabbitmq

在 192.168.10.1、192.168.10.2、192.168.10.3 三个节点上安装,

然后开启 RabbitMQ 监控插件:

rabbitmq-plugins enable rabbitmq_management

2. 修改 /etc/hosts

加入集群 3 个节点的描述:

192.168.10.1 rabbitmqnode1 192.168.10.2 rabbitmqnode2 192.168.10.3 rabbitmqnode3

3. 设置 Erlang Cookie

Erlang Cookie 文件:/var/lib/rabbitmq/.erlang.cookie。这里将 rabbitmqnode1 的该文件复制到 rabbitmqnode2、rabbitmqnode3,由于这个文件权限是 400,所以需要先修改 rabbitmqnode2、rabbitmqnode3 中的该文件权限为 777:

# chmod 777 /var/lib/rabbitmq/.erlang.cookie

然后将 rabbitmqnode1 中的该文件拷贝到 rabbitmqnode2、rabbitmqnode3,最后将权限和所属用户/组修改回来:

# chmod 400 /var/lib/rabbitmq/.erlang.cookie # chown rabbitmq /var/lib/rabbitmq/.erlang.cookie # chgrp rabbitmq /var/lib/rabbitmq/.erlang.cookie

4. 使用 -detached 参数运行各节点

# rabbitmqctl stop

# rabbitmq-server -detached

5. 组成集群

将 rabbitmqnode2、rabbitmqnode3 与 rabbitmqnode1 组成集群:

rabbitmqnode2 # rabbitmqctl stop_app

rabbitmqnode2 # rabbitmqctl join_cluster rabbit@rabbitmqnode1

rabbitmqnode2 # rabbitmqctl start_app

rabbitmqnode3 # rabbitmqctl stop_app

rabbitmqnode3 # rabbitmqctl join_cluster rabbit@rabbitmqnode1

rabbitmqnode3 # rabbitmqctl start_app

此时 rabbitmqnode2 与 rabbitmqnode3 也会自动建立连接;如果要使用内存节点,则可以使用

rabbitmqnode2 # rabbitmqctl join_cluster --ram rabbit@rabbitmqnode1 加入集群。

集群配置好后,可以在 RabbitMQ 任意节点上执行 rabbitmqctl cluster_status 来查看是否集群配置成功。

6. 设置镜像队列策略

在任意一个节点上执行:

# rabbitmqctl set_policy ha-all "^" '{"ha-mode":"all"}'

将所有队列设置为镜像队列,即队列会被复制到各个节点,各个节点状态保持一直。

完成这 6 个步骤后,RabbitMQ 高可用集群就已经搭建好了,最后一个步骤就是搭建均衡器。

7. 安装并配置 HAProxy

在 192.168.10.4 上安装 HAProxy,然后修改 /etc/haproxy/haproxy.cfg:

listen rabbitmq_cluster 0.0.0.0:5672

mode tcp

balance roundrobin

server rabbitmqnode1 192.168.10.1:5672 check inter 2000 rise 2 fall 3

server rabbitmqnode2 192.168.10.2:5672 check inter 2000 rise 2 fall 3

server rabbitmqnode2 192.168.10.3:5672 check inter 2000 rise 2 fall 3

相关文章:

  • 【安全有效新方案】WSL 默认路径迁移实战:通过 PowerShell 符号链接实现自动重定向
  • 【大语言模型入门】—— 浅析LLM基座—Transformer原理
  • 面试八股---HTML
  • 【51单片机节日彩灯控制器设计】2022-6-11
  • Linux的基础IO
  • Segment Anything in High Quality之SAM-HQ论文阅读
  • 浮油 - 3 相分层和自由表面流 CFX 模拟
  • 消息队列:Redis Stream到RabbitMQ的转换
  • 【libm】 7 内核余弦函数 (k_cos.rs)
  • 大模型本周进展(0623~0629)
  • WSL安装发行版上安装podman
  • 常用期权定价模型
  • AI金融科技/区块链合规相关研究的经验
  • 力扣第85题-最大矩形
  • Java中对JSON的操作
  • StarRocks 3.5 新特性解读:Snapshot 快照恢复、大导入性能全面升级、分区管理更智能
  • redisson看门狗实现原理
  • OD 算法题 B卷【阿里巴巴找黄金宝箱4】
  • Vue 与react 生命周期对比
  • 机器学习-02(深度学习的基本概念)