uxpin2/rabbitmq

RabbitMQ 延迟交换机镜像

镜像概述

本镜像基于官方RabbitMQ稳定版本构建，已预装rabbitmq_delayed_message_exchange插件，在保留RabbitMQ核心消息队列功能的基础上，新增消息延迟传递能力，可直接用于需要定时或延迟处理消息的业务场景。

核心功能与特性

• 官方基础：基于官方RabbitMQ镜像构建，确保与RabbitMQ生态系统完全兼容
• 延迟插件：预安装延迟交换机插件，支持消息按指定时间延迟投递
• 毫秒级控制：支持精确到毫秒的消息延迟设置，满足不同业务延迟需求
• 功能完整：保留RabbitMQ全部原生功能（交换机、队列、绑定、消息确认等）
• 易于使用：无需手动安装插件，启动即可使用延迟交换机功能

使用场景

• 订单超时处理：如30分钟未支付的订单自动取消
• 定时任务触发：如定时发送通知、定时数据同步等
• 流量削峰：非紧急消息延迟处理，避免系统峰值压力
• 消息重试机制：失败消息延迟重试，提高系统容错性
• 定时提醒：如会议提醒、活动开始提醒等场景

使用方法

基本运行命令

bash
docker run -d --name rabbitmq-delayed \
  -p 5672:5672 \  # AMQP协议端口
  -p 15672:15672 \  # 管理界面端口
  rabbitmq:3-management-delayed  # 实际标签需根据官方最新版本调整

验证插件安装

1. 访问RabbitMQ管理界面：http://localhost:15672（默认账号密码：guest/guest）
2. 进入"Exchanges"页面，在交换机类型下拉菜单中确认包含"x-delayed-message"选项

创建延迟交换机

通过管理界面创建

1. 进入"Exchanges"页面，点击"Add a new exchange"
2. 填写交换机名称（如delayed_exchange）
3. 选择类型为"x-delayed-message"
4. 在"Arguments"中添加x-delayed-type参数，值为底层交换机类型（如direct、topic、fanout）
5. 点击"Add exchange"完成创建

通过命令行创建

bash
# 进入容器
docker exec -it rabbitmq-delayed bash

# 创建延迟交换机策略
rabbitmqctl set_policy delayed-exchange ".*" \
  '{"priority":0,"apply-to":"exchanges","definition":{"x-delayed-type":"direct"}}' \
  --apply-to exchanges

配置说明

环境变量配置

支持官方RabbitMQ所有环境变量，常用配置：

• RABBITMQ_DEFAULT_USER：默认管理员用户名（默认：guest）
• RABBITMQ_DEFAULT_PASS：默认管理员密码（默认：guest）
• RABBITMQ_DEFAULT_VHOST：默认虚拟主机（默认：/）
• RABBITMQ_SERVER_ADDITIONAL_ERL_ARGS：额外Erlang参数

数据持久化配置

为确保消息和配置持久化，建议挂载数据卷：

bash
docker run -d --name rabbitmq-delayed \
  -p 5672:5672 \
  -p 15672:15672 \
  -v /path/to/rabbitmq/data:/var/lib/rabbitmq \  # 数据持久化目录
  -v /path/to/rabbitmq/logs:/var/log/rabbitmq \  # 日志目录
  rabbitmq:3-management-delayed

docker-compose配置示例

yaml
version: '3'
services:
  rabbitmq:
    image: rabbitmq:3-management-delayed
    container_name: rabbitmq-delayed
    ports:
      - "5672:5672"
      - "***:***"
    environment:
      RABBITMQ_DEFAULT_USER: admin
      RABBITMQ_DEFAULT_PASS: password
      RABBITMQ_DEFAULT_VHOST: /myvhost
    volumes:
      - rabbitmq_data:/var/lib/rabbitmq
      - rabbitmq_logs:/var/log/rabbitmq
    restart: always

volumes:
  rabbitmq_data:
  rabbitmq_logs: