RocketMQ 教程 快速入门1 搭建环境1.1 安装 JDK前置准备工作1.2 配置 JDK 环境变量# 获取 JDK 根目录路径dirname$(dirname$(readlink-f$(whichjava)))# 编辑环境变量添加以下内容vimvi/etc/profileexportJAVA_HOME/usr/lib/jvm/java-11-openjdk-11.0.23.0.9-2.el7_9.x86_64 2exportPATH$JAVA_HOME/bin:$PATH# 环境变量生效source/etc/profile# 验证环境变量echo$JAVA_HOMEjava-version1.3 部署 RocketMQApache RocketMQ 快速上手体验# 上传到 /opt 目录# 解压到当前目录unziprocketmq-all-5.3.2-bin-release.zip1.4 调整内存大小cd/opt/rocketmq-all-5.3.2-bin-release/bin/vimrunserver.shcd/opt/rocketmq-all-5.3.2-bin-release/bin/vimrunbroker.sh1.5 启动 NameServer 和 Broker# 先启动 NameServernohupshbin/mqnamesrvtail-f~/logs/rocketmqlogs/namesrv.log# 日志看到 The Name Server boot success... 说明启动成功# 再启动 Brokernohupshbin/mqbroker-nlocalhost:9876 --enable-proxytail-f~/logs/rocketmqlogs/proxy.log# 日志看到 The broker[broker-a,192.169.1.2:10911] boot success... 说明启动成功1.6 测试消息生产消费# 利用环境变量 NAMESRV_ADDR告诉客户端 NameServer 的地址。exportNAMESRV_ADDRlocalhost:9876# 启动生产者shbin/tools.sh org.apache.rocketmq.example.quickstart.Producer# 启动消费者shbin/tools.sh org.apache.rocketmq.example.quickstart.Consumer2 Java SDK 测试消息收发本地部署 RocketMQ | RocketMQdependencygroupIdorg.apache.rocketmq/groupIdartifactIdrocketmq-client-java/artifactIdversion5.2.1/version/dependencyshbin/mqadmin updatetopic-nlocalhost:9876-tTestTopic-cDefaultCluster3 关闭 RocketMQ# 先关闭 Brokershbin/mqshutdown broker# 再关闭 NameServershbin/mqshutdown namesrv