『RocketMq』环境搭建

第一步：官网下载

官网地址：http://rocketmq.apache.org/dowloading/releases/ 下载最新的release包

第二步：配置环境变量

配置环境变量：ROCKETMQ_HOME 应配置为 D:\rocketmq-all-5.1.4-bin-release\bin

第三步：启动 NameServer

NameServer的启动脚本是bin目录下的mqnamesrv.cmd，实际上是调用了runserver.cmd脚本来实现启动的动作，而在runserver.cmd脚本，java的默认启动参数中，启动时堆内存的大小为2g，老旧一点的机器上根本没有这么多空闲内存。因此，修改一下runserver.cmd脚本。将原来的内存参数注释掉。
rem set "JAVA_OPT=%JAVA_OPT% -server -Xms2g -Xmx2g -Xmn1g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
修改为：
set "JAVA_OPT=%JAVA_OPT% -server -Xms256m -Xmx512m"

启动方式一： 修改broker.conf，添加autoCreateTopicEnable = true，直接双击mqnamesrv.cmd脚本启动NameServer。

启动方式二： 使用cmd命令启动，首先进入rocketMq的安装目录，再进入bin目录，执行‘start mqnamesrv.cmd’，启动NameServer。
看到 The Name Server boot success 字样，表示NameServer己启动成功。

第四步：启动Broker

Broker的启动脚本是mqbroker.cmd。与mqnamesrv.cmd脚本类似，mqbroker.cmd是调用runbroker.cmd脚本启动Broker的。同样的，优化一下runbroker.cmd的启动内存。
注释：rem set "JAVA_OPT=%JAVA_OPT% -server -Xms2g -Xmx2g -Xmn1g"
修改为：set "JAVA_OPT=%JAVA_OPT% -server -Xms256m -Xmx512m"
启动方式一： 修改mqbroker.cmd脚本，增加NameServer的地址。
rem 添加此行，指定NameServer的地址 set "NAMESRV_ADDR=127.0.0.1:9876" rem 在此行之前添加NameServer的地址 call "%ROCKETMQ_HOME%\bin\runbroker.cmd" org.apache.rocketmq.broker.BrokerStartup %*

双击mqbroker.cmd脚本启动Broker。

启动方式二：
不修改mqbroker.cmd脚本，直接使用cmd命令启动，首先跟启动NameServer一样先进入rocketmq安装目录的bin目录下面，然后执行‘start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true’启动broker
看到boot success 字样，表示Broker己启动成功

第五步：验证RocketMQ功能

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

启动消费者：使用cmd窗口
tools.cmd命令之前我们要指定NameServer地址。
采用命令行方式，依次执行：
set NAMESRV_ADDR=127.0.0.1:9876 tools.cmd org.apache.rocketmq.example.quickstart.Consumer
看到Consumer Started启动成功。

启动生产者：使用cmd窗口
采用命令行方式，依次执行：
set NAMESRV_ADDR=127.0.0.1:9876 tools.cmd org.apache.rocketmq.example.quickstart.Producer
启动成功后，生产者会发送1000个消息，然后自动退出。

第六步：RocketMQ控制台

下载rocketMq控制台源码：https://github.com/apache/rocketmq-externals.git
下载下来之后，分支切到asoc-runtime-configuration， git checkout asoc-runtime-configuration

修改端口号
进入rocketmq-console\src\main\resources，修改application.properties

使用cmd命令进入rocketmq-console项目，执行mvn clean package -Dmaven.test.skip=true 命令。
编译打包成功后在rocketmq-console项目下面就会出现一个target文件夹，进入该文件夹 就会看到我们打包好的jar包，然后执行命令 java -jar rocketmq-console-ng-1.0.0.jar 或者 mvn spring-boot:run 命令。
访问：http://127.0.0.1:8089/