经过对比发现rocketmq虽然吞吐量上没有kafka高，但是支持更多的业务场景，消息实时性更好，所以应用级选择rocketmq更适合。官网地址：https://rocketmq.apache.org/zh/docs/quickStart/01quickstart

1. 下载。当前最新版本是5.0

curl -o rocketmq-all-5.0.0-bin-release.zip https://dlcdn.apache.org/rocketmq/5.0.0/rocketmq-all-5.0.0-bin-release.zip

2. 解压缩

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

文件夹名字太长，重命名下

mv rocketmq-all-5.0.0-bin-release rocketmq

3. 启动 nameserver

cd rocketmq

nohup sh ./bin/mqnamesrv &

4. 查看是否启动成功

cat nohup.out

cat ~/logs/rocketmqlogs/namesrv.log

5. 启动Broker+Proxy

nohup sh bin/mqbroker -n localhost:9876 --enable-proxy >nohup2.out 2>&1 &

6. 查看是否启动成功

cat nohup2.out

cat ~/logs/rocketmqlogs/broker_default.log

7. 客户端测试消息收发

设置环境变量

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

ctrl+c退出

8. 关闭服务

sh bin/mqshutdown broker

sh bin/mqshutdown namesrv