kuberstack/kubernetes-rabbitmq-autocluster

基于Kubernetes后端的RabbitMQ自动集群镜像

镜像概述

本镜像基于官方RabbitMQ镜像构建，集成autocluster插件并添加Kubernetes后端支持，可在K8s环境中自动完成RabbitMQ集群的节点发现、初始化与维护，简化分布式消息队列的部署与管理流程。

核心功能

• 自动集群构建：通过K8s后端自动发现集群节点，实现无人工干预的集群搭建。
• 节点清理机制：定期检测并清理离线/失效节点，避免流量发送至无效节点。
• 灵活参数配置：支持通过环境变量自定义集群参数（如日志级别、清理间隔等）。
• 插件扩展能力：可添加额外RabbitMQ插件并在构建阶段激活。

使用场景

• 微服务架构中需要高可用消息队列的业务场景。
• Kubernetes集群内RabbitMQ集群的快速部署与运维。
• 需要自动维护节点状态的分布式消息系统。

配置说明

关键环境变量配置：

• RABBITMQ_USE_LONGNAME=true：K8s后端依赖此选项，必须设置为true。
• AUTOCLUSTER_LOG_LEVEL=debug：建议设置为debug以获取详细集群日志。
• AUTOCLUSTER_CLEANUP=true：启用节点清理功能（必填）。
• CLEANUP_INTERVAL=60：节点清理间隔（单位：秒）。
• AUTOCLUSTER_TYPE=k8s：指定集群后端类型为Kubernetes。

部署示例

构建镜像

Dockerfile示例：

dockerfile
FROM rabbitmq:latest
ENV RABBITMQ_USE_LONGNAME=true \
    AUTOCLUSTER_LOG_LEVEL=debug \
    AUTOCLUSTER_CLEANUP=true \
    CLEANUP_INTERVAL=60 \
    CLEANUP_WARN_ONLY=false \
    AUTOCLUSTER_TYPE=k8s \
    LANG=en_US.UTF-8
ADD plugins/*.ez /usr/lib/rabbitmq/lib/rabbitmq_server-3.6.8/plugins/
RUN rabbitmq-plugins enable --offline autocluster

Kubernetes部署步骤

1. 创建Erlang Cookie密钥：

bash
echo $(openssl rand -base64 32) > erlang.cookie
kubectl -n $namespace create secret generic erlang.cookie --from-file=erlang.cookie

2. 部署RabbitMQ Service：

bash
kubectl -n $namespace create -f manifestos/rabbitmq-service.yaml

3. 部署RabbitMQ Deployment：

bash
kubectl -n $namespace create -f manifestos/rabbitmq-deploy.yaml

4. 检查集群状态：

bash
FIRST_POD=$(kubectl get pods -n $namespace -l 'app=rabbitmq' -o jsonpath='{.items[0].metadata.name }')
kubectl -n $namespace exec -ti $FIRST_POD rabbitmqctl cluster_status

常见问题

• 错误：Unsupported backend: k8s：检查autocluster插件是否已添加K8s支持。
• 错误：Failed to get nodes from k8s -404：确认RabbitMQ Service已正常运行且网络可访问。
• 错误：Connection attempt from disallowed node：检查Erlang Cookie密钥是否正确配置且所有节点一致。