RabbitMQ Operator

消息队列

开源

在 Kubernetes 上运行高可用 RabbitMQ 集群

KubeBlocks RabbitMQ Operator 自动化管理 RabbitMQ 集群，支持 Quorum Queue 强一致性队列与 Erlang 分布式集群，提供自动故障恢复、Prometheus 监控与 Management UI，适合企业级消息可靠投递场景。

访问 GitHub

< 30s

Leader 重选举

100%

开源免费

2 步部署生产级 RabbitMQ Operator

安装 KubeBlocks

# 添加 Helm 仓库
helm repo add kubeblocks https://apecloud.github.io/helm-charts
helm repo update

# 安装 KubeBlocks
helm install kubeblocks kubeblocks/kubeblocks \
  --namespace kb-system --create-namespace

创建 RabbitMQ Operator 集群

apiVersion: apps.kubeblocks.io/v1
kind: Cluster
metadata:
  name: rabbitmq-cluster
  namespace: demo
spec:
  terminationPolicy: Delete
  componentSpecs:
    - name: rabbitmq
      componentDef: rabbitmq
      serviceVersion: "3.13.7"
      replicas: 3

核心能力

Quorum Queue 强一致性

基于 Raft 的 Quorum Queue 替代传统镜像队列，每次写入复制到多数节点后才返回成功，数据更安全。

自动 Leader 重选举

Quorum Queue Leader 故障后在 30 秒内自动选举新 Leader，客户端连接自动重定向到存活节点。

Prometheus 监控

内置 Prometheus 指标暴露（:15692），无需额外插件即可与 Grafana 监控体系集成。

管理 UI 集成

内置 Management Plugin（:15672），提供可视化队列、Exchange 与连接监控，支持通过 Ingress 安全暴露。

部署拓扑

Quorum Queue 高可用集群

KubeBlocks 将 RabbitMQ 部署为 3 或 5 节点 HA 集群，Quorum Queue 基于 Raft 协议跨节点复制消息，Leader 故障后自动选举新 Leader，30 秒内恢复服务。

Quorum Queue

Raft 共识

3 或 5 节点

AMQP 0-9-1

关键特性

Quorum Queue 每次写入复制到多数节点后才返回成功，数据安全性高于镜像队列

Leader 故障后自动选举新 Leader，通常在 30 秒内完成

所有节点接受 AMQP 连接，客户端可连接到任意存活节点

通过 Kubernetes Endpoints API 实现节点发现，无需外部 etcd 或 ZooKeeper

同时支持 Classic Queue 与 Quorum Queue，可按业务需求混合使用

AMQP 客户端AMQP 0-9-1STOMP / MQTT

↓

rabbitmq-cluster:5672ClusterIP 服务

↓

基于 Raft 法定数量 — 3 节点集群

rabbit-0主节点

:5672:15692

PVC · 20 Gi

rabbit-1从节点

:5672:15692

PVC · 20 Gi

rabbit-2从节点

:5672:15692

PVC · 20 Gi

常见问题

KubeBlocks RabbitMQ Operator 支持哪些 RabbitMQ 版本？

KubeBlocks RabbitMQ Operator 支持 RabbitMQ 3.8 至 4.2 共 9 个版本，支持通过 OpsRequest 滚动升级。

Quorum Queue 与镜像队列有什么区别？

Quorum Queue 基于 Raft 协议，每次写入需多数节点确认，数据一致性更强，脑裂风险更低。镜像队列为传统 RabbitMQ HA 机制，数据安全性较弱。RabbitMQ 3.9+ 推荐使用 Quorum Queue。

KubeBlocks RabbitMQ Operator 是否免费？

KubeBlocks开源版完全开源免费，涵盖所有核心功能。KubeBlocks企业版提供图形化控制台与商业支持等增值功能。