kubesail/rabbitmq

RabbitMQ (KubeSail内部版) 镜像文档

镜像概述

该镜像为KubeSail内部使用的RabbitMQ消息队列定制版本，基于标准RabbitMQ构建并进行针对性调整，核心特点是预集成延迟消息交换机（delayed_message_exchange），旨在满足KubeSail内部服务间的消息传递需求。

核心功能与特性

• 基于标准RabbitMQ：保留RabbitMQ原生消息队列功能，包括AMQP协议支持、队列管理、交换机等核心组件
• 延迟消息支持：预配置并启用delayed_message_exchange插件，支持消息延迟投递
• 内部环境优化：针对KubeSail内部服务架构调整默认配置，提升兼容性和性能
• 即开即用：无需额外配置即可使用延迟消息功能，简化部署流程

使用场景

• KubeSail内部微服务间的异步通信
• 需要延迟处理的业务场景（如定时任务触发、消息重试机制、延迟通知）
• 服务解耦与流量削峰场景
• 事件驱动架构中的消息中转

使用方法

基本部署

通过docker run命令快速启动容器：

bash
docker run -d \
  --name kube-sail-rabbitmq \
  -p 5672:5672 \  # AMQP协议端口
  -p 15672:15672 \  # 管理界面端口
  kube-sail/rabbitmq:latest

配置参数

可通过环境变量自定义配置：

带认证配置的部署示例

bash
docker run -d \
  --name kube-sail-rabbitmq \
  -p 5672:5672 \
  -p 15672:15672 \
  -e RABBITMQ_DEFAULT_USER=kubeadmin \
  -e RABBITMQ_DEFAULT_PASS=SecurePass123! \
  -e RABBITMQ_DEFAULT_VHOST=/kube \
  kube-sail/rabbitmq:latest

验证延迟消息交换机

1. 访问管理界面：http://<容器IP>:15672，使用配置的用户名密码登录
2. 导航至Exchanges页面，确认存在类型为x-delayed-message的交换机
3. 使用RabbitMQ客户端连接，测试延迟消息功能：

   python
   # Python示例代码
   import pika
   connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
   channel = connection.channel()
   
   # 声明延迟交换机
   channel.exchange_declare(
     exchange='delayed_exchange',
     exchange_type='x-delayed-message',
     arguments={'x-delayed-type': 'direct'}
   )
   
   # 发送延迟消息（延迟10秒）
   channel.basic_publish(
     exchange='delayed_exchange',
     routing_key='delayed_queue',
     body='Hello delayed message',
     properties=pika.BasicProperties(
       headers={'x-delay': 10000}  # 延迟时间（毫秒）
     )
   )
   connection.close()
   

注意事项

• 该镜像为KubeSail内部定制版本，外部环境使用前需评估兼容性
• 延迟消息功能依赖rabbitmq_delayed_message_exchange插件，已预安装并启用
• 生产环境建议挂载数据卷持久化消息数据：-v rabbitmq-data:/var/lib/rabbitmq
• 管理界面仅建议内部网络访问，生产环境应限制访问权限