1.直接去官网下载编译好的zip包;设置环境变量ROCKETMQ_HOME
rocketmq-all-4.8.0-bin-release.zip
下载
环境变量
2.进入解压包的bin目录,cmd打开;
开启NameServer
D:\Demos\rocketmq\rocketmq-all-4.8.0-bin-release\bin>start mqnamesrv.cmd
NameServer启动成功:
Java HotSpot(TM) 64-Bit Server VM warning:
Using the DefNew young collector with the CMS collector is deprecated and will likely be removed in a future release
Java HotSpot(TM) 64-Bit Server VM warning:
UseCMSCompactAtFullCollection is deprecated and will likely be removed in a future release.
The Name Server boot success. serializeType=JSON
开启Broker
D:\Demos\rocketmq\rocketmq-all-4.8.0-bin-release\bin>start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true
Broker启动成功:
The broker[SK-20210719XOMZ, 172.16.50.131:10911] boot success. serializeType=JSON and name server is 127.0.0.1:9876
注意:避坑指南,jdk路径有空格会无法启动broker
3.测试mq是否能正常使用;先新建变量
新建环境变量NAMESRV_ADDR 值:localhost:9876
环境变量
测试生产者发送消息
tools.cmd org.apache.rocketmq.example.quickstart.Producer
测试消费者接收消息
tools.cmd org.apache.rocketmq.example.quickstart.Consumer
测试通过!
测试通过
4.从git获取console源码,编译成jar包
地址:https://github.com/apache/rocketmq-externals,选择console分支,clone代码打成jar包
java -jar xxxx.jar运行
结果:
image.png