RocketMQ安装及测试 RocketMQ

1.下载地址
https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.5.1/rocketmq-all-4.5.1-bin-release.zip
2.解压

unzip rocketmq-all-4.5.0-bin-release.zip

3.解压之后，进入bin目录，启动服务
RocketMQ默认的内存较大，启动Broker如果因为内存不足失败，需要编辑如下两个配置文件
vi runbroker.sh
vi runserver.sh
参考设置：

JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m"

4.启动RocketMQ

nohup sh mqnamesrv &

查看启动日志

tail -f ~/logs/rocketmqlogs/namesrv.log

5.启动Broker

nohup sh mqbroker -n localhost:9876 &

查看日志

tail -f ~/logs/rocketmqlogs/broker.log

可通过jps查看是否启动成功

文章图片

6.测试RocketMQ
6.1 发送消息
设置环境变量

export NAMESRV_ADDR=localhost:9876

使用安装包的demo发送消息

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

6.2接收消息
设置环境变量

export NAMESRV_ADDR=localhost:9876

使用安装包的demo接收消息

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

7.关闭RocketMQ
关闭nameserver

sh mqshutdown namesrv

关闭broker

sh mqshutdown broker

【RocketMQ安装及测试】

RocketMQ安装及测试