文章目录
- rocketMQ启动
- 1.下在相关的二进制文件
- 2.配置环境变量
- 3.启动NameServer
- 4.启动broker
- 5. MQ 启动!
- 5.1 测试发送数据
- 6.关闭服务
rocketMQ启动
1.下在相关的二进制文件
下载地址,点击即达
2.配置环境变量
3.启动NameServer
在文件夹下执行cmd进入黑窗口 .\bin\mqnamesrv.cmd 执行这个代码
4.启动broker
再开启一个黑窗口执行
.\bin\mqbroker.cmd -n localhost:9876 autoCreateTopicEnable=true
可能会遇到这个情况
原因是因为jdk的环境变量中配置的文件路径中含有空格 C:\Program Files\Java
解决方法
将文件夹的名字改回runbroker.cmd,运行成功
5. MQ 启动!
5.1 测试发送数据
执行 .\bin\tools.cmd org.apache.rocketmq.example.quickstart.Producer
发送消息
执行 .\bin\tools.cmd org.apache.rocketmq.example.quickstart.Consumer
6.关闭服务
windows 直接关闭黑窗口即可
linux 执行 shutdown命令