1.环境准备
2.下载
下载地址:
https://rocketmq.apache.org/
我下载的是4.9.2版本,也可以选择其他版本。
然后下载二进制的文件
选择这个镜像下载就可以了
3.安装
①先把下载好的压缩包传到linux上,然后解压出来
②修改初始内存
修改runserver.sh
修改runbroker.sh
将内存大小都设置为256m
4.启动
启动NameServer
nohup sh bin/mqnamesrv & //挂载启动
tail -f ~/logs/rocketmqlogs/namesrv.log //查看日志
出现这行日志就表明NameServer启动成功啦
启动broker
nohup sh bin/mqbroker -n localhost:9876 &
tail -f ~/logs/rocketmqlogs/broker.log
这就表示broker也启动成功了
5.发送/接收消息测试
发送消息
export NAMESRV_ADDR=localhost:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
接收消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
6.关闭Server
sh bin/mqshutdown broker
The mqbroker(1740) is running...
Send shutdown request to mqbroker(1740) OK
sh bin/mqshutdown namesrv
The mqnamesrv(1692) is running...
Send shutdown request to mqnamesrv(1692) OK