MAC 下载安装、启动和关闭 RocketMQ实例_综合

文章目录

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

参考文献

http://rocketmq.apache.org/docs/quick-start/
https://cloud.tencent.com/developer/article/1409078