RocketMQ 教程 快速入门

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-version

1.3 部署 RocketMQ

Apache RocketMQ 快速上手体验

# 上传到 /opt 目录# 解压到当前目录unziprocketmq-all-5.3.2-bin-release.zip

1.4 调整内存大小

cd/opt/rocketmq-all-5.3.2-bin-release/bin/vimrunserver.sh

cd/opt/rocketmq-all-5.3.2-bin-release/bin/vimrunbroker.sh

1.5 启动 NameServer 和 Broker

# 先启动 NameServernohupshbin/mqnamesrv&tail-f~/logs/rocketmqlogs/namesrv.log# 日志看到 The Name Server boot success... 说明启动成功

# 再启动 Brokernohupshbin/mqbroker-nlocalhost:9876 --enable-proxy&tail-f~/logs/rocketmqlogs/proxy.log# 日志看到 The broker[broker-a,192.169.1.2:10911] boot success... 说明启动成功

1.6 测试消息生产消费

# 利用环境变量 NAMESRV_ADDR，告诉客户端 NameServer 的地址。exportNAMESRV_ADDR=localhost:9876

# 启动生产者shbin/tools.sh org.apache.rocketmq.example.quickstart.Producer

# 启动消费者shbin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

2 Java SDK 测试消息收发

本地部署 RocketMQ | RocketMQ

<dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-client-java</artifactId><version>5.2.1</version></dependency>

shbin/mqadmin updatetopic-nlocalhost:9876-tTestTopic-cDefaultCluster

3 关闭 RocketMQ

# 先关闭 Brokershbin/mqshutdown broker# 再关闭 NameServershbin/mqshutdown namesrv