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
(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
参考:https://blog.csdn.net/zhwyj1019/article/details/80264698
https://rocketmq.apache.org/docs/quick-start/ 官方文档