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
使用命令行执行以下命令
1start mqnamesrv.cmd
四、启动 broker
路径:E:\rocketmq\rocketmq-4.9.2\bin
使用命令行执行以下命令
1mqbroker.cmd -n localhost:9876 autoCreateTopicEnable=true
五、启动接收者
路径:E:\rocketmq\rocketmq-4.9.2\bin
使用命令行执行以下命令
1start tools.cmd org.apache.rocketmq.example.quickstart.Consumer
六、启动发送方
路径:E:\rocketmq\rocketmq-4.9.2\bin
使用命令行执行以下命令
1start tools.cmd org.apache.rocketmq.example.quickstart.Producer
启动的发送/接受方都是官方的 demo,执行的其实就是一个 jar 包,已经对应好了 Topic,所以当启动了发送方后消费者会自动消费消息。