三分钟教你使用RocketMQ

发布于:2023-01-10 ⋅ 阅读:(415) ⋅ 点赞:(0)

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

本文含有隐藏内容,请 开通VIP 后查看

网站公告

今日签到

点亮在社区的每一天
去签到