1. 环境准备
JDK需要先安装好。
1. RocketMQ是用Java语言写的,所以需要JDK的支持。
2. 下载RocketMQ
建议下载这个低版本的
https://rocketmq.apache.org/release-notes/2020/12/21/4.8.0/
下载之后解压即可,目录结构如下:
3. 配置RocketMQ环境变量
我的电脑,鼠标右键 >> 属性
选择 高级系统设置:
选择 环境变量:
选择 新建:
变量名:ROCKETMQ_HOME
变量值:自己RecketMQ的安装目录
最后确定 保存即可。
4. 启动RecoketMQ
RocketMQ自身分为 NameServer 和 Broker 两个部分,因此,用作本机开发调试用的最小应用,应该分别启动一个NameServer和一个Broker节点。
(1)启动name server
进入自己的RocketMQ安装目录下的bin目录,输入下面命令启动 nameserver:
start mqnamesrv.cmd
启动成功会有如下提示,切记下面窗口不能关闭。
(2)启动broker
打开 命令提示符 界面,进入自己的RocketMQ安装目录下的bin目录,输入下面命令启动 broker:
start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true
启动成功会提示如下窗口,切记也不能关闭:
5、验证RocketMQ功能
RocketMQ自带了恬送与接收消息的脚本tools.cmd
,用来验证RocketMQ的功能是否正常。
tool.cmd脚本需要带参数执行,无法用简单的双击方式启动。因此,我们打开一个cmd窗口,并跳转到bin目录下。
打开cmd窗口并跳转到bin目录下
(1)启动消费者
与mqbroker.cmd
脚本类似,启动tool.cmd
命令之前我们要指定NameServer地址。
这里我们采用命令方式指定,并启动消费者。依次执行如下命令:
set NAMESRV_ADDR=localhost:9876
tools.cmd org.apache.rocketmq.example.quickstart.Consumer
启动消费者成功
(2)启动生产者
再打开一个cmd窗口,依次执行如下命令:
set NAMESRV_ADDR=localhost:9876
tools.cmd org.apache.rocketmq.example.quickstart.Producer
生产者启动命令
当生产者启动之后,会发送1000个消息,然后自动推出,当退出结束时会返回true:
生产者发送消息并退出
此时,在消费者界面按下Ctrl + C
,就会收到刚刚生产者发出的消息。
消费者接收消息
表示RocketMQ功能正常启动。
RocketMQ最小应用己经可以正常工作,能满足我们开发环境下调试代码的需求。
需要RocketMQ可视化部署的,可以点击下面的链接
RocketMQ可视化插件部署(细节实操版)