RocketMQ介绍

RocketMQ 是一款开源的分布式消息系统，基于高可用分布式集群技术，提供低延时的、高可靠的消息发布与订阅服务。同时，广泛应用于多个领域，包括异步通信解耦、企业解决方案、金融支付、电信、电子商务、快递物流、广告营销、社交、即时通信、移动应用、手游、视频、物联网、车联网等。

具备如下特点:

  • 能够保证严格的消息顺序
  • 提供丰富的消息拉取模式
  • 高效的订阅者水平扩展能力
  • 实时的消息订阅机制
  • 亿级消息堆积能力

下载和安装

下载地址

中文文档: https://github.com/apache/rocketmq/tree/master/docs/cn
下载地址: https://mirrors.tuna.tsinghua.edu.cn/apache/rocketmq/4.8.0/rocketmq-all-4.8.0-bin-release.zip

配置环境变量

  1. ROCKETMQ_HOME=D:\Software\rocketmq-all-4.8.0-bin-release

启动

在mq安装bin目录下 cmd 执行

  1. # 启动NAMESERVER
  2. start mqnamesrv.cmd
  3. # 启动BROKER
  4. start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true
  5. # 控制台
  6. java -jar rocketmq-console-ng-1.0.0.jar --server.port=8080 --rocketmq.config.namesrvAddr=192.168.171.129:9876

如果启动BROKER的时候,提示找不到主类,可以修改mq安装目录bin下的runbroker.cmd 修改之前: set CLASSPATH=.;%BASE_DIR%conf;%CLASSPATH 修改之后 set CLASSPATH=.;%BASE_DIR%conf;”%CLASSPATH%”

image.png

监控平台搭建

git地址：https://github.com/apache/rocketmq-externals
使用：https://blog.csdn.net/so_geili/article/details/90142461
下载后压缩在本地，主要用到的是rocketmq-console
image.png

  1. #编译
  2. mvn clean package -Dmaven.test.skip=true
  3. #启动
  4. java -jar rocketmq-console-ng-1.0.0.jar --server.port=8080 --rocketmq.config.namesrvAddr=127.0.0.1:9876

打开控制台地址localhost:8080
image.png

快速开始

1. 新建SpringBoot应用

2. 引入依赖

  1. <!-- 实现对 RocketMQ 的自动化配置 -->
  2. <dependency>
  3.   <groupId>org.apache.rocketmq</groupId>
  4.   <artifactId>rocketmq-spring-boot-starter</artifactId>
  5.   <version>2.0.4</version>
  6. </dependency>