RocketMQ Server 安装

RocketMQ依赖Java环境，要求有JDK 1.8以上版本;

支持Windows和Linux平台;支持源码方式安装和使用已经编译好的安装包安装；

我们用windows平台安装RocketMQ Server编译好的安装包，来讲解RocketMQ：

下载地址: https://rocketmg.apache.org/dowloading/releases/ 或 https://gitee.com/apache/rocketmq

我们用最新版本: 4.9.0 release: https://www.apache.org/dyn/closer.ceipath=rocketma/4.9.0/rocketmg-all-4.9.0-bin-release.zip

解压后的目录:

第一步：配置环境变量

系统环境变量加两个配置：

ROCKETMQ_HOME="D:rocketmq'

NAMESRV_ADDR="1ocaThost:9876"

第二步：启动 Name Server

启动 Name Server

进入命令行执行： .\bin\mqnamesrv.cmd

第三步：启动 broker

启动 broker

进入命令行执行： .\bin\mqbroker.cmd -n localhost:9876 autoCreateTopicEnable=true

第四步：发送和接收消息测试

发送和接收消息测试

发送，执行测试类： .\bin\tools.cmd org.apache.rocketmq.example.quickstart.Producer

接收，执行测试类： .\bin\tools.cmd org.apache.rocketmq.example.quickstart.Consumer