aptible/rabbitmq

RabbitMQ Docker镜像文档

镜像概述

RabbitMQ是一款开源的消息代理（Message Broker）软件，基于高级消息队列协议（AMQP）构建，旨在实现分布式系统中高效、可靠的异步通信。通过Docker镜像部署RabbitMQ可快速搭建消息队列服务，减少环境配置复杂度，支持灵活扩展和集成到各类分布式架构中。

核心功能与特性

• 多协议支持：原生支持AMQP 0-9-1、AMQP 1.0，同时通过插件支持MQTT、STOMP等协议，满足不同场景的消息传递需求。
• 可靠消息传递：提供消息持久化、发布确认（Publisher Confirm）、消费者确认（Consumer Acknowledgment）等机制，确保消息不丢失。
• 灵活路由策略：支持直接路由（Direct）、主题路由（Topic）、扇出（Fanout）、头信息路由（Headers）等多种交换器类型，实现复杂消息路由逻辑。
• 高可用集群：支持多节点集群部署，提供镜像队列（Mirror Queue）机制，实现消息副本跨节点备份，保障服务可用性。
• 管理界面：内置Web管理界面（RabbitMQ Management），支持队列监控、用户管理、策略配置等操作，简化运维管理。
• 扩展性：通过插件系统支持功能扩展，如延迟队列、死信队列、消息追踪等高级特性。

使用场景

• 异步通信：实现服务间非实时通信，提高系统响应速度，如订单提交后异步处理支付、通知等后续操作。
• 服务解耦：通过消息队列隔离上下游服务，降低系统耦合度，如微服务架构中各服务通过消息队列交互，减少直接依赖。
• 流量削峰：应对突发高流量场景，如秒杀活动中通过消息队列缓冲请求，避免下游服务过载。
• 日志/数据收集：分布式系统中收集各节点日志或业务数据，统一汇总至处理服务，如ELK日志收集架构。
• 任务调度：分发异步任务至工作节点执行，如批量数据处理、定时任务调度。

使用方法与配置说明

基本部署（Docker Run）

默认启动（含管理界面）

RabbitMQ官方镜像默认包含管理插件，启动后可通过Web界面管理：

bash
docker run -d \
  --name rabbitmq \
  -p 5672:5672 \  # AMQP协议端口（客户端连接）
  -p 15672:15672 \  # 管理界面端口
  rabbitmq:latest

自定义用户与密码

通过环境变量设置默认用户（默认用户guest仅允许本地访问，生产环境需自定义）：

bash
docker run -d \
  --name rabbitmq \
  -p 5672:5672 \
  -p 15672:15672 \
  -e RABBITMQ_DEFAULT_USER=admin \  # 自定义管理员用户名
  -e RABBITMQ_DEFAULT_PASS=password \  # 自定义管理员密码
  rabbitmq:latest

数据持久化

挂载数据卷以持久化消息数据（避免容器重启后数据丢失）：

bash
docker run -d \
  --name rabbitmq \
  -p 5672:5672 \
  -p 15672:15672 \
  -v /path/on/host/rabbitmq/data:/var/lib/rabbitmq \  # 数据持久化目录
  -e RABBITMQ_DEFAULT_USER=admin \
  -e RABBITMQ_DEFAULT_PASS=password \
  rabbitmq:latest

Docker Compose部署

创建docker-compose.yml文件，配置更复杂的部署场景（如持久化、网络、依赖等）：

yaml
version: '3.8'
services:
  rabbitmq:
    image: rabbitmq:latest
    container_name: rabbitmq
    ports:
      - "5672:5672"   # AMQP端口
      - "15672:15672" # 管理界面端口
    environment:
      - RABBITMQ_DEFAULT_USER=admin
      - RABBITMQ_DEFAULT_PASS=password
      - RABBITMQ_SERVER_ADDITIONAL_ERL_ARGS=-rabbit log_levels [{connection,error},{default,error}]  # 调整日志级别
    volumes:
      - rabbitmq_data:/var/lib/rabbitmq  # 数据卷挂载（需提前创建命名卷）
    restart: unless-stopped  # 容器退出后自动重启（非手动停止时）

volumes:
  rabbitmq_data:  # 命名卷，用于持久化数据

启动命令：docker-compose up -d

核心配置参数（环境变量）

管理界面访问

启动容器后，通过浏览器访问 http://<主机IP>:15672 打开管理界面，使用配置的用户名/密码登录（如上述示例中的admin/password）。界面支持查看队列状态、交换机配置、消费者连接、消息统计等功能。

集群部署（基础配置）

RabbitMQ集群需确保各节点Erlang Cookie一致，且网络互通。以下为2节点集群示例（基于Docker Compose）：

yaml
version: '3.8'
services:
  rabbitmq1:
    image: rabbitmq:latest
    container_name: rabbitmq1
    ports:
      - "5672:5672"
      - "15672:15672"
    environment:
      - RABBITMQ_DEFAULT_USER=admin
      - RABBITMQ_DEFAULT_PASS=password
      - RABBITMQ_NODE_NAME=rabbit@rabbitmq1
      - RABBITMQ_ERLANG_COOKIE=MY_SECRET_COOKIE  # 集群Cookie，所有节点需相同
    volumes:
      - rabbitmq1_data:/var/lib/rabbitmq
    restart: unless-stopped

  rabbitmq2:
    image: rabbitmq:latest
    container_name: rabbitmq2
    ports:
      - "5673:5672"  # 避免端口冲突，映射为5673
      - "15673:15672"
    environment:
      - RABBITMQ_DEFAULT_USER=admin
      - RABBITMQ_DEFAULT_PASS=password
      - RABBITMQ_NODE_NAME=rabbit@rabbitmq2
      - RABBITMQ_ERLANG_COOKIE=MY_SECRET_COOKIE  # 与rabbitmq1一致
    volumes:
      - rabbitmq2_data:/var/lib/rabbitmq
    depends_on:
      - rabbitmq1
    restart: unless-stopped
    command: bash -c "rabbitmq-server -detached && rabbitmqctl stop_app && rabbitmqctl join_cluster rabbit@rabbitmq1 && rabbitmqctl start_app && tail -f /dev/null"  # 加入集群

volumes:
  rabbitmq1_data:
  rabbitmq2_data:

说明：集群部署后需通过管理界面或rabbitmqctl set_policy命令配置镜像队列策略，确保消息跨节点备份。

注意事项

• 安全配置：生产环境需禁用默认guest用户，自定义强密码，并限制管理界面访问IP（可通过网络策略或反向代理配置）。
• 资源限制：根据业务规模调整容器CPU/内存限制（通过--cpus、--memory参数），避免资源耗尽。
• 持久化：关键业务消息需开启队列持久化（durable=true）、消息持久化（delivery_mode=2），并配合数据卷挂载确保数据不丢失。
• 监控告警：通过管理界面API或第三方工具（如Prometheus + Grafana）监控队列长度、消息速率等指标，设置告警阈值。