RocketMQ 单机部署

环境信息：

OS : CentOS 10 (stream)
内存 : 12G
网络模式 : NAT
JDK版本 : JDK11 

RocketMQ 官网 https://rocketmq.apache.org

quickstart 中有安装教程。最重要的问题在于 内存问题。 使用maven安装依赖时，一般需要4G内存

启动broker（即RocoketMQ），默认会申请8G内存

# 新版本的CentOS 可以在你获取不到软件包时，帮你自动安装
# 获取RocketMQ 软件包
wget <https://dist.apache.org/repos/dist/release/rocketmq/5.3.2/rocketmq-all-5.3.2-source-release.zip>

# 解压，使用maven 安装依赖
$ unzip rocketmq-all-5.3.2-source-release.zip
$ cd rocketmq-all-5.3.2-source-release/
$ mvn -Prelease-all -DskipTests -Dspotbugs.skip=true clean install -U
$ cd distribution/target/rocketmq-5.3.2/rocketmq-5.3.2

# 启动nameserver
$ nohup sh bin/mqnamesrv &
 
# 查看log 观察nameserver 已启动
$ tail -f ~/logs/rocketmqlogs/namesrv.log
The Name Server boot success...

# 启动broker
$ nohup sh bin/mqbroker -n localhost:9876  autoCreateTopicEnable=true  --enable-proxy &

# 观察log 查看broker已启动，如果没有启动查看nohup.out日志
$ tail -f ~/logs/rocketmqlogs/proxy.log 
The broker[broker-a,192.169.1.2:10911] boot success...

# 指定NAMESRV_ADDR 信息 , 启动生产者测试
$ export NAMESRV_ADDR=localhost:9876
$ sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

# 会有类似打印
SendResult [sendStatus=SEND_OK, msgId=C0A8E5820D65639FEE487113405203D9, offsetMsgId=C0A8E58200002A9F0000000000075396, messageQueue=MessageQueue [topic=TopicTest, brokerName=localhost.localdomain, queueId=2], queueOffset=496, recallHandle=null]

# 启动消费者测试，如果另外打开一个终端，需要重新声明NAMESRV_ADDR这个变量 
$ sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

# 会有类似打印
ConsumeMessageThread_please_rename_unique_group_name_4_16 Receive New Messages: [MessageExt [brokerName=localhost.localdomain, queueId=3, storeSize=242, queueOffset=491, sysFlag=0, bornTimestamp=1747925887032, bornHost=/192.168.229.130:45532, storeTimestamp=1747925887033, storeHost=/192.168.229.130:10911, msgId=C0A8E58200002A9F00000000000741A0, commitLogOffset=475552, bodyCRC=825146949, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message{topic='TopicTest', flag=0, properties={CONSUME_START_TIME=1747926144277, MSG_REGION=DefaultRegion, UNIQ_KEY=C0A8E5820D65639FEE487113403803C6, CLUSTER=DefaultCluster, MIN_OFFSET=0, TAGS=TagA, WAIT=true, TRACE_ON=true, MAX_OFFSET=500}, body=[72, 101, 108, 108, 111, 32, 82, 111, 99, 107, 101, 116, 77, 81, 32, 57, 54, 54], transactionId='null'}]]

# 关闭broker
$ sh bin/mqshutdown broker

# 关闭 NameServer
$ sh bin/mqshutdown namesrv

安装UI管理界面

RocketMQ的 仪表板 已经从rocketmq-console项目更新为rocketmq-dashboard

# 克隆项目
git clone <https://github.com/apache/rocketmq-dashboard> 

# 进入目录，使用mvn编译
mvn clean package -Dmaven.test.skip=true

# 使用java -jar 启动服务
nohup java -jar rocketmq-dashboard-2.0.1-SNAPSHOT.jar &

# 注意防火墙设置,通过localhost:8080 端口进行服务访问