- RocketMQ安装
- 一、安装
- 1.1官网下载
- 1.2 解压缩
- 二、启动
- 1.1启动namesrv
- 1.2 修改JVM启动参数
- 1.3 启动broker
- 三、测试
- 生产者推送消息
- 消费者拉取消息
- 四、关闭命令
官网地址
-d 指定解压到那个文件夹下
unzip -d /home/xzq/software/ rocketmq-all-4.9.2-bin-release.zip
nohup sh bin/mqnamesrv &
查看启动日志
tail -f ~/logs/rocketmqlogs/namesrv.log
jps查看是否启动成功
rocketMQ的运行参数默认设置的很大，如果你的机器内存不够，会启动失败。
vim bin/runserver.sh
xmn 新生代的内存大小
xmx 堆区最大的内存大小
xms 堆区的初始值大小
vim bin/runbroker.sh
nohup ./mqbroker -n localhost:9876 &
查看启动日志
tail -f ~/logs/rocketmqlogs/broker.log
jps查看
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
./bin/mqshutdown broker
./bin/mqshutdown namesrv
