riftbit/rabbitmq

RabbitMQ 3.x 容器镜像文档

镜像概述

本镜像基于Alpine Linux构建，包含RabbitMQ 3.x版本及管理界面，同时预装多种额外插件，支持ETCD Swarm自动集群和经典集群部署模式，适用于需要高效消息队列服务的场景。

核心功能与特性

插件支持

可通过环境变量RABBITMQ_PLUGINS_ENABLE启用插件，多个插件以空格分隔。

额外安装的插件

• https://github.com/noxdafox/rabbitmq-message-deduplication%EF%BC%9A%E6%B6%88%E6%81%AF%E5%8E%BB%E9%87%8D
• https://github.com/rabbitmq/rabbitmq-lvc-exchange%EF%BC%9A%E6%9C%80%E5%90%8E%E4%BB%B7%E5%80%BC%E7%BC%93%E5%AD%98%E4%BA%A4%E6%8D%A2%E5%99%A8
• https://github.com/rabbitmq/rabbitmq-rtopic-exchange%EF%BC%9A%E6%AD%A3%E5%88%99%E4%B8%BB%E9%A2%98%E4%BA%A4%E6%8D%A2%E5%99%A8
• https://github.com/rabbitmq/rabbitmq-delayed-message-exchange%EF%BC%9A%E5%BB%B6%E8%BF%9F%E6%B6%88%E6%81%AF%E4%BA%A4%E6%8D%A2%E5%99%A8
• https://github.com/rabbitmq/rabbitmq-routing-node-stamp%EF%BC%9A%E8%B7%AF%E7%94%B1%E8%8A%82%E7%82%B9%E6%A0%87%E8%AE%B0
• https://github.com/rabbitmq/rabbitmq-message-timestamp%EF%BC%9A%E6%B6%88%E6%81%AF%E6%97%B6%E9%97%B4%E6%88%B3
• https://github.com/gotthardp/rabbitmq-auth-backend-ip-range%EF%BC%9AIP%E8%8C%83%E5%9B%B4%E8%AE%A4%E8%AF%81%E5%90%8E%E7%AB%AF
• https://github.com/rabbitmq/rabbitmq-management-exchange%EF%BC%9A%E7%AE%A1%E7%90%86%E4%BA%A4%E6%8D%A2%E5%99%A8
• https://github.com/gotthardp/rabbitmq-email%EF%BC%9A%E9%82%AE%E4%BB%B6%E9%80%9A%E7%9F%A5

RabbitMQ 3.8.x 自带插件

(参考: [***]

• rabbitmq_auth_backend_oauth2
• rabbitmq_auth_backend_ldap
• rabbitmq_auth_backend_http
• rabbitmq_auth_mechanism_ssl
• rabbitmq_auth_backend_cache
• rabbitmq_peer_discovery_etcd
• rabbitmq_peer_discovery_k8s
• rabbitmq_peer_discovery_consul
• rabbitmq_peer_discovery_aws
• rabbitmq_top
• rabbitmq_prometheus
• rabbitmq_recent_history_exchange
• rabbitmq_jms_topic_exchange
• rabbitmq_event_exchange
• rabbitmq_consistent_hash_exchange
• rabbitmq_amqp1_0
• rabbitmq_federation
• rabbitmq_federation_management
• rabbitmq_management
• rabbitmq_management_agent
• rabbitmq_mqtt
• rabbitmq_shovel
• rabbitmq_shovel_management
• rabbitmq_stomp
• rabbitmq_trust_store
• rabbitmq_web_stomp
• rabbitmq_web_mqtt
• rabbitmq_web_stomp_examples
• rabbitmq_web_mqtt_examples

插件启用示例

docker
docker run -e RABBITMQ_PLUGINS_ENABLE='rabbitmq_mqtt rabbitmq_federation rabbitmq_federation_management' ...

使用场景

• 需要高可用消息队列服务的分布式系统
• 需实现消息去重、延迟消息等高级功能的业务场景
• 基于Swarm或ETCD的容器编排环境中的集群部署
• 需要通过管理界面监控和管理消息队列的场景

使用方法与配置说明

环境变量配置

核心插件与集群相关变量

自定义配置文件

通过挂载卷到/var/libbitmq，并创建additional.config文件添加入自定义配置，格式为key value。

配置示例（经典集群）

cluster_formation.peer_discovery_backend rabbit_peer_dcovery_classic_config
cluster_formation.classicic_configfig.nodes.1 rabbit@hostname1.eng.example.local
cluster_formation.classic_config.nodes.2 rabbit@hostname2.eng.example.local

部署示例

Docker Run 命令

docker
docker run -d \
  -p 5672:5672 \
  -p 1572:15672 \
  -e RABBITMQ_DEFAULT_USER=admin \
  -e RABBITMQ_DEFAULT_PASS=Passw0rd \
  -e RABBITMQ_ERLANG_COOKIE="MY-SECRET" \
 e RABBITMQ_PLUGINS_ENABLE="rabbitmq_delayed_message_exchange rabbitmq_management" \
  --name rabbitmq \
  riftbit/rabbitmq3:latest

Swarm 服务部署

bash
docker service create \
--name rabbitmq \
--mode global \
--constraint=node.labels.servicerole==queue \
-p ***:*** \
-p 25672:25672 \
-p 4370:4370 \
-p 5672:5672 \
-p 5671:5671 \
--network rabbit-net \
--network traefik-net \
--env RABBITMQ_DEFAULT_USER=admin \
--env RABBITMQ_DEFAULT_PASS=Passw0rd \
--env RABBITMQ_ERLANG_COOKIE="MY-SECRET" \
--env RABBITMQ_USE_LONGNAME=false \
--env RABBIT_ETCD_ENABLE=true \
--label traefik.port="***" \
--label traefik.docker.network="traefik-net" \
--label traefik.enable="true" \
--label traefik.frontend.rule="Host:rabbit.services.local" \
riftbit/rabbitmq3:latest