1、ReketMQ启动
1.1.下载RocketMQ
下载地址:Release Notes - Apache RocketMQ - Version 4.2.0 - Apache RocketMQ Release Notes - Apache RocketMQ - Version 4.2.0 - Apache RocketMQ
1.2.配置ROCKETMQ_HOME
解压压缩包,配置 ROCKETMQ_HOME
1.3.启动MQ
1.3.1启动NameServer
1.3.1.1Cmd命令框执行进入至MQ文件夹\bin
下,然后执行 start mqnamesrv.cmd
,启动NameServer。 成功后会弹出提示框,此框勿关闭。
1.3.1.2进入至MQ文件夹\bin
下,修改Bean目录下的 runbroker.cmd
中JVM占用内存大小 (可以不改,看自己电脑配置)
CMD执行start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true
,启动Broker。
1.4.RocketMQ存储结构
Commitlog : 消息是存储,在commitlog目录中,以mapperdFile文件顺序存储消息。
Config : 存放运行期间的配置文件
Consumerqueue : 该目录中存放的是队列,consume queue存放着commitlog中的消息的索引位置
Index :存放着消息索引文件 indexFile,用来实现根据key进行消息的快速查询
Abort : 该文件在broker启动后自动创建,正常关闭abort会消失
Checkpoint :记录 Commitlog ,Consumerqueue 和index 文件的最后刷盘时间戳
-
2.RocketMQ插件
2.1 RocketMQ可视化管理插件下载地址:Releases · apache/rocketmq-externals · GitHub
2.2.修改配置
解压后,修改配置:src/main/resource/application.properties ,这里需要指向Name Server 的地址和端口 如下:
2.3.打包插件
回到安装目录(pom.xml所在目录),执行: mvn clean package -Dmaven.test.skip=true
,然后会在target目录生成打包后的jar文件
2.4.启动插件
进入 target 目录,CMD执行 java -jar rocketmq-console-ng-1.0.0.jar
, 访问 http://localhost:8080