1.下载安装

地址1（官网地址）：http://rocketmq.apache.org/dowloading/releases/

地址2：http://47.105.44.10:8080/static/rocketmq-all-4.2.0-bin-release.zip

下载解压

环境变量设置NAMESRV_ADDR、ROCKETMQ_HOME：

启动NAMESERVER、BROKER：

mqnamesrv

start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true

使用正确JAVA版本

openjdk-14.0.2使用报错如下

功能验证：

x消费者启动：

set NAMESRV_ADDR=localhost:9876

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

生产者启动：

set NAMESRV_ADDR=localhost:9876

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

生产者发送消息后，之前打开的消费者会自动接收消息：

springboot使用rocketMQ发送接收消息

创建生产者：

只需注意参数producerGroupName、namesrvAddr即可（使用阿里云上的mq时才需要输入assessKey、aecretKey）

发送消息：

创建消费者1（实际上是对DefaultMQPushConsumer的包装，被动监听消息）：

消息监听：

创建消费者2（DefaultMQPullConsumer 主动拉取消息）