1. 官网下载地址:
下载 | RocketMQ
2. 配置环境:
我是在/etc/profile.d 新建了一个rocketmq_env.sh
配置了jdk, maven, 以及mq.
mq文件下载的
配置完之后,刷新环境source /etc/profile
3. 配置rocket mq 的jvm配置,就是两个启动脚本修改,虚拟机内存搞得1.5g 原始的配的大不够用。
a. 配置bin/runserver.sh
b. 配置bin/runbroker.sh
4. chmod 777 mqnamesrv
启动注册中心:
nohup ./mqnamesrv &
#看log
tail -f nohup.out
5. 配置conf: /opt/module/rocketmq-all-5.1.4-bin-release/conf/broker.conf
新增如下配置
5. 启动broker:
nohup ./mqbroker -c ../conf/broker.conf &
6.跑两步:
export NAMESRV_ADDR='localhost:9876'
# 生产者跑两步
./tools.sh org.apache.rocketmq.example.quickstart.Producer
消费者:
# 如果不行,把生产者的那个环境命令再输入一遍export NAMESRV_ADDR='localhost:9876'
./tools.sh org.apache.rocketmq.example.quickstart.Consumer
7. 退出mq:
# jps可以查看两个服务运行
jps
# 在mq文件/bin 路径下输入命令停止broker
./mqshutdown broker
# 停止注册中心:
./mqshutdown namesrv
# jps查看应该没有了
jps