Windows 启动RocketMQ
一、下载RocketMQ
https://rocketmq.apache.org/docs/quick-start/
下载完成后将其解压至文件夹中,如“E:\rocketmq\rocketmq-4.9.2”
二、设置环境变量
NAMESRV_ADDR = 127.0.0.1:9876
ROCKETMQ_HOME = E:\rocketmq\rocketmq-4.9.2
三、启动mqnamesrv.cmd
路径:E:\rocketmq\rocketmq-4.9.2\bin
使用命令行执行以下命令
start mqnamesrv.cmd
四、启动broker
路径:E:\rocketmq\rocketmq-4.9.2\bin
使用命令行执行以下命令
mqbroker.cmd -n localhost:9876 autoCreateTopicEnable=true
五、启动接收者
路径:E:\rocketmq\rocketmq-4.9.2\bin
使用命令行执行以下命令
start tools.cmd org.apache.rocketmq.example.quickstart.Consumer
六、启动发送方
路径:E:\rocketmq\rocketmq-4.9.2\bin
使用命令行执行以下命令
start tools.cmd org.apache.rocketmq.example.quickstart.Producer
启动的发送/接受方都是官方的demo,执行的其实就是一个jar包,已经对应好了Topic,所以当启动了发送方后消费者会自动消费消息。