RocketMQ 4.x 入门教程之九

大纲

前言

学习资源

版本说明

本文所使用的各软件版本如下表所示:

组件版本说明
JDK11Java、SpringBoot、SpringCloud 项目案例使用的 JDK 版本
RocketMQ Server4.9.0RocketMQ 服务端(包括 NameServer 和 Broker),运行时依赖 JDK 1.8+
RocketMQ Client4.8.0RocketMQ 客户端(SDK),要求跟 RocketMQ Server 的版本严格匹配

RocketMQ 的应用

引入依赖

本文提供的 Java 代码,均基于以下版本的 RocketMQ Client SDK 实现,要求部署的 RocketMQ Server 版本是 4.9.0

1
2
3
4
5
6
7
8
<dependencies>
<!-- RocketMQ 客户端(SDK),对应 RocketMQ Server 4.9.0 版本 -->
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-client</artifactId>
<version>4.8.0</version>
</dependency>
</dependencies>

批量消息

批量发送消息