leixuewen/rocketmq

RocketMQ Docker镜像文档

镜像概述

本镜像基于RocketMQ最新版构建，旨在提供便捷的RocketMQ部署方案，支持单机和集群环境快速搭建。通过环境变量可灵活切换运行模式，满足不同场景下的消息队列需求。

核心功能与特性

• 多运行模式：支持mqadmin、mqnamesrv、mqbroker及默认模式（同时运行mqnamesrv和mqbroker）
• 自定义JVM参数：通过环境变量配置JVM内存参数，优化性能
• 灵活配置：支持挂载自定义broker.conf配置文件，满足个性化需求
• 端口映射：默认开放RocketMQ核心端口，便于外部访问

使用场景

• 单机部署：快速搭建本地开发或测试环境
• 集群部署：通过多容器配合实现RocketMQ集群架构
• 管理工具：通过mqadmin模式执行RocketMQ管理命令

使用方法与配置说明

环境变量

ROCKETMQ_RUN_MODE

指定RocketMQ运行模式，可选值：

• mqadmin：启动管理工具
• mqnamesrv：仅启动NameServer
• mqbroker：仅启动Broker
• default：默认模式，同时启动NameServer和Broker

broker.conf配置说明

可通过挂载自定义broker.conf文件配置Broker参数，以下为配置示例及说明：

brokerClusterName = DefaultCluster  # 集群名称
brokerName = broker-a               # Broker名称
brokerId = 0                        # Broker ID（0表示主节点）
deleteWhen = 04                     # 消息删除时间（凌晨4点）
fileReservedTime = 48               # 消息文件保留时间（48小时）
brokerRole = ASYNC_MASTER           # Broker角色（异步主节点）
flushDiskType = ASYNC_FLUSH         # 刷盘方式（异步刷盘）
brokerIP1 = 192.168.1.9             # Broker对外服务IP
namesrvAddr = 192.168.1.9:9876      # NameServer地址

运行示例

默认模式（同时启动NameServer和Broker）

bash
docker run --name rocketmq \
  -e "JAVA_OPT_EXT=-Xms512M -Xmx512M -Xmn128m" \  # JVM内存配置
  -p 9876:9876 \                                  # NameServer端口
  -p 10909:10909 \                                # Broker内部通信端口
  -p 10911:10911 \                                # Broker客户端通信端口
  -v D:/Docker/rocketmq/broker.conf:/rocketmq/conf/broker.conf \  # 挂载自定义配置
  leixuewen/rocketmq

mqnamesrv模式（仅启动NameServer）

bash
docker run --name rocketmq \
  -e "JAVA_OPT_EXT=-Xms512M -Xmx512M -Xmn128m" \
  -e "ROCKETMQ_RUN_MODE=mqnamesrv" \              # 指定运行模式为NameServer
  -p 9876:9876 \
  -v D:/Docker/rocketmq/broker.conf:/rocketmq/conf/broker.conf \
  leixuewen/rocketmq

mqbroker模式（仅启动Broker）

bash
docker run --name rocketmq \
  -e "JAVA_OPT_EXT=-Xms512M -Xmx512M -Xmn128m" \
  -e "ROCKETMQ_RUN_MODE=mqbroker" \               # 指定运行模式为Broker
  -p ***:*** \
  -p ***:*** \
  -v D:/Docker/rocketmq/broker.conf:/rocketmq/conf/broker.conf \
  leixuewen/rocketmq