消息队列RocketMQ环境搭建

1.下载:
配置环境变量
启动NameServer
启动Broker
发送和接收消息测试
- 模拟发送消息
- 模拟接收消息
控制台安装与启动

软硬件需求:
系统要求是 64 位的，JDK要求是1.8及其以上版本的

1.下载:

https://rocketmq.apache.org/download/
在这里插入图片描述
2.解压到指定目录
D:\Program Files

配置环境变量

1.选择下面的新建
在这里插入图片描述
变量名:ROCKETMQ_HOME=D:\ProgramFiles\rocketmq-4.9.3
注:D:\ProgramFiles\rocketmq-4.9.3为下载后mq文件地址(每个人不一样)

2.再次选择下面的新建
NAMESRV_ADDR=127.0.0.1:9876
在这里插入图片描述

启动NameServer

进入到(下载的rocketmq文件下的bin目录)bin目录输入命令: mqnamesrv.cmd
在这里插入图片描述

启动成功:

启动Broker

进入到((下载的rocketmq文件下的bin目录))bin目录输入命令:
mqbroker.cmd-n 127.0.0.1:9876 atuoCreateTopicEnable=true
启动成功:
在这里插入图片描述

发送和接收消息测试

模拟发送消息

进入到bin目录输入命令:
tools.cmd org.apache.rocketmq.example.quickstart.Producer
在这里插入图片描述

模拟接收消息

进入到bin目录输入命令:
tools.cmd org.apache.rocketmq.example.quickstart.Consumer
在这里插入图片描述

控制台安装与启动

在这里插入图片描述

在解压目录rocketmq-console的pom.xml中添加如下JAXB依赖

<dependency>
 <groupId>javax.xml.bind</groupId>
 <artifactId>jaxb-api</artifactId>
 <version>2.3.0</version>
 </dependency>
 <dependency>
 <groupId>com.sun.xml.bind</groupId>
 <artifactId>jaxb-impl</artifactId>
 <version>2.3.0</version>
 </dependency>
 <dependency>
 <groupId>com.sun.xml.bind</groupId>
 <artifactId>jaxb-core</artifactId>
 <version>2.3.0</version>
 </dependency>
 <dependency>
 <groupId>javax.activation</groupId>
 <artifactId>activation</artifactId>
 <version>1.1.1</version>
 </dependency>