文章目录
- 创建自定义网络
- 创建NameServer容器
- 创建Broker容器
- 正式开始
- 启动 Nameserver 容器
- 启动 Broker 容器并关联 Nameserver
- docker exec -it rmqbroker vi /etc/rocketmq/broker.conf
- 检查 namesrv 解析
- 检查 Broker 注册状态
- Nameserver 日志
- Broker 日志
- 检查容器日志
- 手动指定 Broker 地址创建 Topic
- topic创建
- 验证 Topic 是否成功创建
- 检查 RocketMQ 集群状态
- 自动创建消费者组（Consumer Group）
- 查看消费者组列表
- 关联配置（可选）
- 注意事项
- 手动创建消费者组（备用方案）
创建自定义网络
docker network create my-rocketmq-network
创建NameServer容器
docker run -di --network my-rocketmq-network -p 9876:9876 --name=rmqserver \
-e "JAVA_OPT_EXT=-server -Xms128m -Xmx128m -Xmn128m" \
-e "JAVA_OPTS=-Duser.home=/opt" \
foxiswho/rocketmq:server-4.5.1
创建Broker容器
docker run -di --network my-rocketmq-network -p 10911:10911 -p 10909:10909 --name=rmqbroker \
-e "JAVA_OPTS=-Duser.home=/opt" \
-e "JAVA_OPT_EXT=-server -Xms128m -Xmx128m -Xmn128m" \
foxiswho/rocketmq:broker-4.5.1
sudo iptables -t nat -L -n --line-numbers
使用 -n 参数禁止端口到服务名称的解析
NAT表主要用于网络地址转换，包括DNAT（目标地址转换）和SNAT/MASQUERADE（源地址转换）。PREROUTING链处理进入的数据包，修改目标地址；POSTROUTING链处理离开的数据包，修改源地址。DOCKER链是Docker服务自动生成的规则，用于容器网络的管理。
MASQUERADE的作用是动态源地址转换，常用于动态IP的环境；DNAT则是目标地址转换，用于端口转发。同时，Docker创建的规则可能会影响用户手动添加的规则，尤其是在PREROUTING链中规则顺序的问题，Docker的规则可能优先执行，导致用户规则未生效。
Chain INPUT (policy ACCEPT)
num target prot opt source destinationChain INPUT (policy ACCEPT)
无规则：直接接受所有流量（默认策略为 ACCEPT）。
num target prot opt source destination
1 DOCKER all -- anywhere !loopback/8 ADDRTYPE match dst-type LOCAL含义：将所有目标地址为 本地主机 IP 且源地址 不是环回网段（!loopback/8，即非 127.0.0.0/8）的流量转发到 DOCKER 链。隐藏信息：Docker 使用此规则处理从本地主机发往容器网络的流量。
删除 Docker 的冲突规则：sudo iptables -t nat -D DOCKER 7
sudo iptables -t nat -I PREROUTING 1 -p tcp --dport 9876 -j DNAT --to-destination 内网ip:9876
正式开始
启动 Nameserver 容器
docker run -d --name rmqserver -p 9876:9876 -e "JAVA_OPT_EXT=-server -Xms256m -Xmx256m -Xmn128m" -e "JAVA_OPTS=-Duser.home=/opt" foxiswho/rocketmq:server-4.3.2
启动 Broker 容器并关联 Nameserver
docker run -d --name rmqbroker -p 10911:10911 -p 10909:10909 --link rmqserver:namesrv -e "NAMESRV_ADDR=namesrv:9876" -e "JAVA_OPT_EXT=-server -Xms256m -Xmx256m -Xmn128m" -e "JAVA_OPTS=-Duser.home=/opt" -e "BROKER_IP1=<公网IP>" foxiswho/rocketmq:broker-4.3.2
–link rmqserver:namesrv # 关联 Nameserver 容器
-e “NAMESRV_ADDR=namesrv:9876” # 使用容器别名访问 Nameserver
docker exec -it rmqbroker vi /etc/rocketmq/broker.conf
brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
brokerIP1 = 公网ip
autoCreateTopicEnable = true
listenPort = 10911
haListenPort = 10909
namesrvAddr = 公网ip:9876
autoCreateProducerGroup=true检查 namesrv 解析
ping namesrv # 应返回 172.17.0.3（rmqserver 容器的 IP）
cat /etc/hosts # 确认 namesrv 指向 rmqserver 的 IP
检查 Broker 注册状态
查看 Nameserver 中的 Broker 列表：
docker exec -it rmqserver sh mqadmin clusterList -n namesrv:9876
Nameserver 日志
docker logs -f rmqserver
Broker 日志
docker logs -f rmqbroker
检查容器日志
docker logs -f rmqserver | grep "boot success" # Nameserver 日志
docker logs -f rmqbroker | grep "boot success" # Broker 日志
手动指定 Broker 地址创建 Topic
如果自动注册失败，直接指定 Broker 的地址：
docker exec -it rmqbroker sh mqadmin updateTopic \-n namesrv:9876 \-t TopicTest \-b "Broker 的公网 IP:10911"
topic创建
docker exec -it rmqbroker sh mqadmin updateTopic -n namesrv:9876 -t TopicTest -b "公网ip:10911"
验证 Topic 是否成功创建
docker exec -it rmqbroker sh mqadmin topicList -n namesrv:9876
sudo iptables -A INPUT -p tcp --dport 10909 -j ACCEPT
网络模式选择
Bridge 模式：Docker 默认使用 bridge 网络模式，容器通过端口映射与宿主机通信。这种方式适合大多数场景，且配置简单。
Host 模式：如果你使用 host 模式，容器会直接使用宿主机的网络栈，端口映射不再需要，但可能会带来端口冲突的问题。
NAT 模式：NAT 模式通常用于虚拟机网络配置，Docker 容器一般不使用 NAT 模式。
检查 RocketMQ 集群状态
通过命令
mqadmin clusterList -n 192.168.33.1:9876
确认 Broker 和 NameServer 状态正常。
查看 Broker 日志
检查 Broker 日志（$ROCKETMQ_HOME/logs/rocketmqlogs/broker.log），排查是否有存储或网络错误。
使用命令行工具验证
查询消息：
mqadmin queryMsgByKey -n 192.168.33.1:9876 -t YourTopic -k YourKey
查看生产者组列表：
mqadmin producerConnection -n 192.168.33.1:9876 -g MyProducerGroup
自动创建消费者组（Consumer Group）
在RocketMQ中，订阅组（Subscription Group）包含消费者组的信息，所以自动创建订阅组实际上就是自动创建消费者组。
还需要考虑不同RocketMQ版本的差异。例如，4.5.0之后的版本可能默认行为不同，或者某些配置项有变化。
默认情况下，RocketMQ Broker 不会自动创建消费者组。需要通过以下配置显式启用：
Broker 配置文件（broker.conf）
# 允许自动创建订阅组（Subscription Group，包含消费者组）
autoCreateSubscriptionGroup = true# 设置 Broker 权限（6 表示读写权限）
brokerPermission = 6
关键配置解释
autoCreateSubscriptionGroup=true
允许 Broker 在消费者首次连接时自动创建订阅组（Subscription Group），即消费者组。
brokerPermission=6
确保 Broker 有权限自动创建组（默认值为 6，即读写权限，一般无需修改）。
查看消费者组列表
通过 RocketMQ 控制台或命令行工具检查消费者组是否自动创建：
mqadmin consumerConnection -n <namesrv-address> -g YourConsumerGroup
检查 Broker 日志
观察 Broker 日志（$ROCKETMQ_HOME/logs/rocketmqlogs/broker.log），确认无权限错误或组创建失败信息。
关联配置（可选）
调整消费者组重试队列
如果消费者组需要重试队列（Retry Queue），可配置：
# 每个订阅组的重试队列数量（默认 1）
retryQueueNums = 1# 消费重试次数（默认 16 次）
retryMaxTimes = 16
注意事项
生产环境建议
自动创建功能适合开发和测试环境。生产环境建议手动创建消费者组，并通过控制台或 CLI 管理，避免组名冲突或权限问题。
权限控制
如果 Broker 集群启用了 ACL（访问控制列表），需确保消费者客户端有权限创建订阅组。
版本兼容性
RocketMQ 4.5.0+ 版本支持 autoCreateSubscriptionGroup，低版本需升级。
手动创建消费者组（备用方案）
如果禁用自动创建，可通过命令行手动创建订阅组：
mqadmin updateSubGroup -n <namesrv-address> -c <cluster-name> -g YourConsumerGroup
