MAC下搭建RocketMQ

时间:2024-04-11 11:50:46

RocketMQ 配置流程

1. 下载RocketMQ的二进制文件

cd /Users/sunww/Documents/JAVA/RocketMQ/rocketmq-all-4.4.0

cd distribution/target/apache-rocketmq

 

2.环境配置

在..bash_profile中加入mq的环境变量

export ROCKETMQ_HOME=/Users/sunww/Documents/JAVA/MQ/rocketmq-all-4.2.0-bin-release

在profile中加入mq的环境变量

ROCKETMQ_HOME=/Users/sunww/Documents/JAVA/MQ/rocketmq-all-4.2.0-bin-release

 

3. 启动路由(cd到bin目录下)

》》nohup sh bin/mqnamesrv &   启动

》》tail -f ~/logs/rocketmqlogs/namesrv.log   // 查看namaserver日志

》》 INFO main - The Name Server boot success  // 启动成功

 

4. 启动broker(cd到bin目录下)

》》 nohup sh bin/mqbroker -n localhost:9876 &   //启动

》》tail -f ~/logs/rocketmqlogs/broker.log   // 查看broker日志

》》 The broker[TF012778.local, 10.50.62.53:10911] boot success  // 启动成功

 

5. 路由和broker启动没反应解决:

同时打开/Users/sunww/Documents/JAVA/MQ/rocketmq-all-4.2.0-bin-release这个目录下的nohup.out文件内容,报错误如下:

sh: /usr/rocketmq/bin/runserver.sh: No such file or directory

可以知道环境变量的位置配置错了。此处应该指向到/Users/sunww/Documents/JAVA/MQ/rocketmq-all-4.2.0-bin-release/bin下面,重新修改环境变量(如上面的步骤2所示)

同时也可以查看mqnamesrv.sh文件(bin下)可以看到这里使用到了ROCKETMQ_HOME这个环境变量,需要设置环境变量

 

6.消息测试(cd /Users/sunww/Documents/JAVA/RocketMQ/rocketmq-all-4.4.0)

(1) 发送消息

export NAMESRV_ADDR=127.0.0.1:9876

sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

TF012778:rocketmq-all-4.2.0-bin-release sunww$ export NA=localhost:9876

TF012778:rocketmq-all-4.2.0-bin-release sunww$ export NAMESRV_ADDR=127.0.0.1:9876

MAC下搭建RocketMQ

(2) 接收消息

sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

TF012778:rocketmq-all-4.2.0-bin-release sunww$ sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

MAC下搭建RocketMQ

参考:https://blog.csdn.net/zhwyj1019/article/details/80264698

https://rocketmq.apache.org/docs/quick-start/  官方文档