2rocketmqserver安装(代码片段)

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

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

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

下载地址：https://rocketmq.apache.org/dowloading/releases/

我们用最新版本：4.9.0 release：https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.9.0/rocketmq-all-4.9.0-bin-release.zip

解压后的目录：

benchmark：里面是测试Demo；

bin：可执行脚本；

conf：配置文件；

lib：依赖的jar包；

我们把rocketmq解压包放到D盘根目录，重命名rocketmq；

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

ROCKETMQ_HOME="D:\\rocketmq"
NAMESRV_ADDR="localhost:9876"

第二步：启动Name Server

进入命令行执行：

.\\bin\\mqnamesrv.cmd

第三步：启动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

消息接收成功；

第五步：关闭服务

windows下直接关闭命令行窗口即可；

说明：这个是锋哥的RocketMQ备课笔记，等备课完，会发布配套的视频教程，如有需要，可以先加锋哥WX：java3459 欢迎白嫖

微信搜一搜公众号【java1234】关注这个放荡不羁的程序员，关注后回复【资料】有我准备的一线大厂笔试面试资料以及简历模板。