当前位置：首页 > news >正文

005 公网访问 docker rocketmq

news 来源：原创 2025/9/12 10:13:15

文章目录

创建自定义网络
创建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