欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

RocketMQ 在windows下基本使用

程序员文章站 2022-03-23 12:57:44
...

下载安装文件

https://spring-cloud-alibaba-group.github.io/github-pages/hoxton/zh-cn/index.html#_spring_cloud_alibaba_rocketmq_binder

Windows下启动RocketMq

1.配置环境变量

首先要有Java环境,这个不会的去网上搜教程

配置ROCKETMQ_HOME,NAMESRV_ADDR两个环境变量,ROCKETMQ_HOME的变量值是下载RocketMq文件的存放地址,如下图:

RocketMQ 在windows下基本使用

RocketMQ 在windows下基本使用

 

 

2.启动NameServer

直接双击bin目录下的mqnamesrv.cmd脚本来启动NameServer

RocketMQ 在windows下基本使用

 

看到 The Name Server boot success 字样,表示NameServer己启动成功

RocketMQ 在windows下基本使用

 

3.启动Broker

直接双击bin目录下的mqbroker.cmd脚本来启动Broker,如下图

RocketMQ 在windows下基本使用

3.启动Broker之二 (上一种方式可能会有连不上的情况)

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

RocketMQ 在windows下基本使用RocketMQ 在windows下基本使用

4.验证RocketMq功能

 

RocketMQ自带了恬送与接收消息的脚本tools.cmd,用来验证RocketMQ的功能是否正常 。

首先,打开一个cmd窗口,跳转到bin目录下

RocketMQ 在windows下基本使用

 

启动消费者

依次输入以下命令

set NAMESRV_ADDR=localhost:9876
tools.cmd org.apache.rocketmq.example.quickstart.Consumer

结果如下图:

RocketMQ 在windows下基本使用

 

启动生产者

重新打开一个cmd窗口,跳转到bin目录下,依次执行以下命令:

set NAMESRV_ADDR=localhost:9876
tools.cmd org.apache.rocketmq.example.quickstart.Producer

启动成功后,生产者会发送1000个消息,然后自动推出,结果如下图:

RocketMQ 在windows下基本使用

 

此时,在消费者界面按下Ctrl+C,就会接收到刚刚生产者发出的消息。如下图:

RocketMQ 在windows下基本使用

 

这样就验证了RocketMq的功能。

 

参考:https://zhuanlan.zhihu.com/p/93400133

       https://blog.csdn.net/chenzz2560/article/details/90238769

相关标签: 技术网站