RabbitMQ在CentOS上的高可用性

RabbitMQ在CentOS上的高可用性实现指南

RabbitMQ的高可用性（High Availability, HA）主要通过集群部署和镜像队列实现，确保节点故障时服务连续、消息不丢失。以下是在CentOS系统上的具体实现步骤：

一、前置准备

1. 安装Erlang环境

RabbitMQ基于Erlang编写，需先安装兼容版本的Erlang。推荐通过官方YUM仓库安装（以CentOS 7/8为例）：

# 添加Erlang解决方案仓库
sudo tee /etc/yum.repos.d/erlang.repo <<EOF
[erlang-solutions]
name=Erlang Solutions repository for CentOS-\$releasever - \$basearch
baseurl=https://packages.erlang-solutions.com/erlang/rpm/centos/\$releasever/\$basearch
enabled=1
gpgcheck=1
gpgkey=https://packages.erlang-solutions.com/erlang/solutions.asc
EOF

# 安装Erlang
sudo yum install -y erlang

# 验证安装
erl -version  # 应输出Erlang版本信息

2. 安装RabbitMQ Server

通过RabbitMQ官方YUM仓库安装最新稳定版：

# 添加RabbitMQ仓库
sudo tee /etc/yum.repos.d/rabbitmq.repo <<EOF
[rabbitmq-server]
name=RabbitMQ repository for CentOS-\$releasever - \$basearch
baseurl=https://packagecloud.io/rabbitmq/rabbitmq-server/el/\$releasever/\$basearch
repo_gpgcheck=1
gpgcheck=1
enabled=1
gpgkey=https://packagecloud.io/rabbitmq/rabbitmq-server/gpgkey
EOF

# 安装RabbitMQ
sudo yum install -y rabbitmq-server

# 启动服务并设置开机自启
sudo systemctl start rabbitmq-server
sudo systemctl enable rabbitmq-server

3. 配置主机名与hosts解析

确保节点间能通过主机名互相访问（以3节点为例）：

# 在各节点上设置主机名（如node1、node2、node3）
sudo hostnamectl set-hostname node1  # 替换为实际主机名
# 其他节点同理：node2、node3

# 编辑/etc/hosts文件，添加节点IP与主机名映射
echo -e "192.168.1.10 node1\n192.168.1.11 node2\n192.168.1.12 node3" | sudo tee -a /etc/hosts

4. 同步Erlang Cookie

Erlang Cookie是节点间认证的关键凭证，所有节点的Cookie文件必须完全一致（路径：/var/lib/rabbitmq/.erlang.cookie）：

# 在主节点（如node1）上复制Cookie到其他节点
sudo scp /var/lib/rabbitmq/.erlang.cookie user@node2:/var/lib/rabbitmq/
sudo scp /var/lib/rabbitmq/.erlang.cookie user@node3:/var/lib/rabbitmq/

# 在所有节点上设置Cookie权限（必须为400）
sudo chmod 400 /var/lib/rabbitmq/.erlang.cookie
sudo chown rabbitmq:rabbitmq /var/lib/rabbitmq/.erlang.cookie

二、搭建RabbitMQ集群

1. 启动所有节点的RabbitMQ服务

# 在各节点上执行
sudo systemctl start rabbitmq-server
sudo systemctl enable rabbitmq-server

2. 将节点加入集群

选择主节点（如node1），其他节点依次执行以下命令加入集群：

# 在从节点（如node2）上执行
sudo rabbitmqctl stop_app  # 停止RabbitMQ应用
sudo rabbitmqctl reset     # 清除本地数据（首次加入无需执行）
sudo rabbitmqctl join_cluster rabbit@node1  # 加入主节点集群
sudo rabbitmqctl start_app # 启动RabbitMQ应用

# 其他从节点（node3）重复上述步骤，将"node1"替换为已加入集群的节点（如node2）

3. 验证集群状态

在任意节点上执行以下命令，确认所有节点已加入集群：

sudo rabbitmqctl cluster_status

输出应包含所有节点的主机名（如node1@192.168.1.10、node2@192.168.1.11），且状态为running。

三、配置镜像队列（提升队列高可用）

镜像队列将队列数据复制到多个节点，确保节点故障时消息不丢失。建议将关键队列设置为镜像队列：

# 在任意节点上执行（如node1）
sudo rabbitmqctl set_policy ha-all "^ha\." '{"ha-mode":"all", "ha-sync-mode":"automatic"}'

参数说明：
- ha-mode="all"：队列会在所有节点上镜像（强一致性，适合关键业务）；
- ha-mode="exactly"：指定镜像节点数量（如{"ha-mode":"exactly", "ha-params":2}表示2个节点镜像）；
- ha-sync-mode="automatic"：自动同步队列数据（避免手动同步）；
- ^ha\.：匹配所有以ha.开头的队列（可根据业务调整正则表达式）。

注意：镜像队列会增加网络和存储开销，需根据业务需求权衡性能与可用性。

四、可选增强：负载均衡与高可用

为进一步提升服务可靠性，可结合HAProxy（负载均衡）和Keepalived（主备虚拟IP）实现入口高可用：

安装HAProxy：在单独的负载均衡节点上安装HAProxy，配置RabbitMQ后端节点池；
配置Keepalived：为HAProxy配置虚拟IP（VIP），当主HAProxy节点故障时，备节点自动接管VIP，确保客户端始终连接到可用入口。

五、验证高可用性

模拟节点故障：停止某个从节点（如node2）的RabbitMQ服务：
```
sudo systemctl stop rabbitmq-server
```
检查集群状态：在主节点上再次执行cluster_status，确认剩余节点仍处于running状态；
发送/接收消息：通过客户端向镜像队列发送消息，验证故障节点恢复后消息是否同步。

通过以上步骤，RabbitMQ在CentOS上的高可用性即可得到有效保障，满足生产环境对服务连续性的要求。