官网文档地址：https://rocketmq.apache.org/zh/docs/quickStart/01quickstart

1 下载安装

需要提前安装java与maven

cd /opt
unzip rocketmq-all-5.1.0-source-release.zip
cd /opt/rocketmq-all-5.1.0
# 安装
mvn -Prelease-all -DskipTests -Dspotbugs.skip=true clean install -U
cd /opt/rocketmq-all-5.1.0/distribution/target/rocketmq-5.1.0/rocketmq-5.1.0

启动NameServer

# 启动namesrv
$ nohup sh bin/mqnamesrv &
 
# 验证namesrv是否启动成功
$ tail -f ~/logs/rocketmqlogs/namesrv.log
The Name Server boot success...

启动Broker和Proxy

### 先启动broker
$ nohup sh bin/mqbroker -n localhost:9876 --enable-proxy &

### 验证broker是否启动成功, 比如, broker的ip是192.168.1.2 然后名字是broker-a
$ tail -f ~/logs/rocketmqlogs/proxy.log 
The broker[broker-a,192.169.1.2:10911] boot success..

关闭服务

$ sh bin/mqshutdown broker
The mqbroker(36695) is running...
Send shutdown request to mqbroker with proxy enable OK(36695)

$ sh bin/mqshutdown namesrv
The mqnamesrv(36664) is running...
Send shutdown request to mqnamesrv(36664) OK

2 使用方式

2.1 工具测试消息收发

$ export NAMESRV_ADDR=localhost:9876
$ sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
 SendResult [sendStatus=SEND_OK, msgId= ...

$ sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
 ConsumeMessageThread_%d Receive New Messages: [MessageExt...

2.2 SDK测试消息收发

1. 引入依赖

<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-client-java</artifactId>
    <version>5.0.5</version>
</dependency>

1. 通过mqadmin创建 Topic