文章目录
- 1. 下载并解压
- 2. 实例
- 2.1 使用Maven打包、构建
- 2.2 修改 Nameserver 和 Broker 启动的配置
- 2.2 启动 nameserver 和 broker
- 3. 关闭 rocketmq 的命令
- 参考文献
1. 下载并解压
首先，你需要安装好 Java 环境、Maven。
网址：http://rocketmq.apache.org/dowloading/releases/ ，下载 rocketmq-all-4.4.0-source-release.zip ，解压。
进入 downloads 文件夹，浏览器下载的默认文件夹，移动刚下载 rocketmq-all-4.4.0 到 /usr/local 目录下。
cd Downloads
sudo mv ./rocketmq-all-4.4.0 /usr/local
cd /usr/local
ls
2. 实例
2.1 使用Maven打包、构建
cd rocketmq-all-4.4.0/
mvn -Prelease-all -DskipTests clean install -U
构建成功：
2.2 修改 Nameserver 和 Broker 启动的配置
修改 Nameserver 和 Broker 启动的配置，原配置需要的内存太大了，普通的电脑启动会失败。
cd /usr/local/rocketmq-all-4.4.0/distribution/target/apache-rocketmq
cd bin
ls
vim runserver.sh修改启动的堆内存的最小值-Xms，堆内存的最大值-Xmx，-Xmn 新生代的大小，Meta区的大小，永久代的最大值。
vim runbroker.sh
2.2 启动 nameserver 和 broker
cd /usr/local/rocketmq-all-4.4.0/distribution/target/apache-rocketmq
ls
启动 nameserver 并查看日志：
cd /usr/local/rocketmq-all-4.4.0/distribution/target/apache-rocketmq
nohup sh bin/mqnamesrv &
tail -f ~/logs/rocketmqlogs/namesrv.log
查看Java进程、看 nameServer 是否注册成功。
jps
启动 broker 并查看日志：
cd /usr/local/rocketmq-all-4.4.0/distribution/target/apache-rocketmq
nohup sh bin/mqbroker -n localhost:9876 &
tail -f ~/logs/rocketmqlogs/broker.log
查看Java进程、看 broker 是否注册成功。
jps
启动生产者，设置环境变量NAMESRV_ADDR为localhost:9876。
cd /usr/local/rocketmq-all-4.4.0/distribution/target/apache-rocketmq
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. 关闭 rocketmq 的命令
sh bin/mqshutdown namesrv
sh bin/mqshutdown broker参考文献