RocketMQ安装

RocketMQ安装

一、安装

1.1官网下载

官网地址

1.2 解压缩

-d 指定解压到那个文件夹下
unzip -d /home/xzq/software/ rocketmq-all-4.9.2-bin-release.zip

二、启动

1.1启动namesrv

nohup sh bin/mqnamesrv &
查看启动日志
tail -f ~/logs/rocketmqlogs/namesrv.log

jps查看是否启动成功

1.2 修改JVM启动参数

rocketMQ的运行参数默认设置的很大，如果你的机器内存不够，会启动失败。

vim bin/runserver.sh

xmn 新生代的内存大小
xmx 堆区最大的内存大小
xms 堆区的初始值大小

vim bin/runbroker.sh

1.3 启动broker

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