RocketMQ(4.9.3)
下载
官方下载
安装及启动
安装jdk1.8及maven
已经安装的无需理会
将下载下的安装文件解压到本地磁盘(任意,此处解压到D:盘)
配置环境变量
- 变量名:ROCKETMQ_HOME
- 变量值:D:\www\java\rockmq\rocketmq-all-4.9.3-bin-release\bin
修改path,添加
启动
启动NAMESERVER
使用cmd打开命令窗口,进入到rocketmq的bin目录下,执行:start mqnamesrv.cmd,若成功会弹出如下提示框,请勿关闭此框。 可编写.bat脚本快速启动 D:\www\java\rockmq\rocketmq-all-4.9.3-bin-release 目录下创建文件mqnamesrv-start.bat ,内容如下:
@echo off
START %~dp0\bin\mqnamesrv.cmd
启动BROKER
同样在rocketmq的bin目录下,执行:start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true , 启动BROKER。成功后会弹出提示框,此框勿关闭。
如果弹出框提示‘错误: 找不到或无法加载主类 xxxxxx’。在bin下找到并打开runbroker.cmd,然后将‘%CLASSPATH%’加上英文双引号。保存并重新执行start语句。如下: 修改完毕后,再次启动即可出现成功弹框如下: 可编写.bat脚本快速启动 D:\www\java\rockmq\rocketmq-all-4.9.3-bin-release 目录下创建文件mqbroker-start.bat ,内容如下:
@echo off
START %~dp0\bin\mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true
安装可视化插件
下载并解压
github下载 我这里选择专有的rocketmq-console项目 rocketmq-console-1.0.0 解压后如下图所示
修改配置
进入\rocketmq-console\src\main\resources文件加,用编辑器打开application.properties文件,配置如下:
编译
进入rocketmq-externals\rocketmq-console 文件夹,执行:mvn clean package -Dmaven.test.skip=true,编译生成,编译成功如下: 编译成功后,在rocketmq-externals\rocketmq-console下会生成target文件夹 可编写.bat脚本快速编译 D:\www\java\rockmq\rocketmq-externals-rocketmq-console-1.0.0 目录下创建文件rocketmq-console-build.bat ,内容如下:
@echo off
CD %~dp0\rocketmq-console
mvn clean package -Dmaven.test.skip=true
执行文件
进入target后执行:java -jar rocketmq-console-ng-1.0.0.jar,这里是在启动jar工程。
启动完毕后,在浏览器输入:http://localhost:9999/ 进入控制台
可编写.bat脚本快速执行 D:\www\java\rockmq\rocketmq-externals-rocketmq-console-1.0.0 目录下创建文件rocketmq-console-start.bat ,内容如下:
@echo off
CD %~dp0\rocketmq-console\target
java -jar rocketmq-console-ng-1.0.0.jar
代码引入
java
maven引入
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-client</artifactId>
<version>4.9.3</version>
</dependency>
|