veryecs/rocketmq

RocketMQ 5.0.0 开发测试镜像

镜像概述

RocketMQ 5.0.0 开发测试镜像是用于快速部署和测试RocketMQ消息队列服务的Docker镜像，支持namesrv（名称服务器）、broker（消息代理）及proxy（代理）组件的部署与配置，适用于开发环境下的功能验证和本地测试。

核心功能与特性

• 支持独立启动namesrv组件，提供服务发现和路由功能
• 支持启动broker+proxy组合，实现消息存储、转发及代理服务
• 数据持久化：通过挂载目录实现日志和存储数据的持久化
• 环境变量配置：支持设置JVM堆大小（MAX_POSSIBLE_HEAP）等参数
• 网络端口映射：开放必要端口（9876、-）以支持服务访问

使用场景

• 开发环境中快速搭建RocketMQ服务进行功能测试
• 本地验证消息队列的消息收发功能
• 学习和研究RocketMQ 5.0.0的核心组件及配置

使用方法

1. 启动namesrv（名称服务器）

使用以下命令启动namesrv组件，负责服务发现和路由：

bash
docker run -d \
-p 9876:9876 \
-v /www/rocketmq/namesrv/logs:/root/logs \
-v /www/rocketmq/namesrv/store:/root/store \
--name rocketmq-namesrv \
-e "MAX_POSSIBLE_HEAP=128m" \
rocketmq:5.0.0 \
sh mqnamesrv

参数说明：

• -p 9876:9876：映射namesrv服务端口
• -v /www/rocketmq/namesrv/logs:/root/logs：挂载日志目录，实现日志持久化
• -v /www/rocketmq/namesrv/store:/root/store：挂载存储目录，实现数据持久化
• --name rocketmq-namesrv：指定容器名称
• -e "MAX_POSSIBLE_HEAP=128m"：设置JVM最大堆内存为128m
• rocketmq:5.0.0：使用的镜像名称及版本
• sh mqnamesrv：启动namesrv的命令

2. 启动broker+proxy（消息代理及代理服务）

使用以下命令启动broker和proxy组件，依赖已启动的namesrv：

bash
docker run -d \
-p 10912:10912 \
-p 10911:10911 \
-p 10909:10909 \
-v /www/rocketmq/broker/logs:/root/logs \
-v /www/rocketmq/broker/store:/root/store \
-v /www/rocketmq/broker/conf/broker.conf:/opt/rocketmq/conf/broker.conf \
--name rocketmq-broker-a \
--link rocketmq-namesrv:namesrv \
-e "NAMESRV_ADDR=namesrv:9876" \
-e "MAX_POSSIBLE_HEAP=128m" \
rocketmq:5.0.0 \
sh mqbroker -n namesrv:9876 --enable-proxy -c /opt/rocketmq/conf/broker.conf

参数说明：

• -p 10912:10912 -p 10911:10911 -p 10909:10909：映射broker和proxy的服务端口
• -v /www/rocketmq/broker/logs:/root/logs：挂载broker日志目录
• -v /www/rocketmq/broker/store:/root/store：挂载broker存储目录
• -v /www/rocketmq/broker/conf/broker.conf:/opt/rocketmq/conf/broker.conf：挂载broker配置文件
• --name rocketmq-broker-a：指定容器名称
• --link rocketmq-namesrv:namesrv：链接到namesrv容器，实现网络互通
• -e "NAMESRV_ADDR=namesrv:9876"：设置namesrv地址
• -e "MAX_POSSIBLE_HEAP=128m"：设置JVM最大堆内存为128m
• sh mqbroker -n namesrv:9876 --enable-proxy -c /opt/rocketmq/conf/broker.conf：启动broker并启用proxy，指定namesrv地址和配置文件

3. 测试消息收发

3.1 准备测试环境

下载并解压RocketMQ 5.0.0二进制包：

bash
wget https://dlcdn.apache.org/rocketmq/5.0.0/rocketmq-all-5.0.0-bin-release.zip
unzip rocketmq-all-5.0.0-bin-release.zip
cd rocketmq-all-5.0.0-bin-release

3.2 内网测试

设置namesrv地址并测试消息收发：

bash
export NAMESRV_ADDR=localhost:9876
# 发送消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
# 接收消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

3.3 公网测试

若需公网测试，需进行以下配置：

1. 在broker配置文件（/www/rocketmq/broker/conf/broker.conf）中添加参数：

   brokerIP1 = 公网IP
   namesrvAddr = 公网IP:9876
   

2. 确保云服务器安全组开放端口：9876、-
3. 系统防火墙开放端口：9876、-
4. 设置namesrv地址为公网IP:9876，执行消息收发命令