SpringBoot整合RocketMQ(自动注册)

简介

本文介绍SpringBoot整合RocketMQ的方法。

1. spring-boot-starter-parent版本：2.4.13
2. RocketMQ版本：4.9.4。（写这篇文章时，5.X版本的Java客户端还没完善，无法使用）。

本文会展示的实例有：

1. 只指定topic发送和接收数据
2. 指定topic和tag发送和接收数据
3. 延迟消息
4. 项目启动时自动注册topic

前三个都是基本的api，很简单。第四个自动注册是一种技术思维，适合高级开发和对技术有追求的人。

结果展示

先展示一下整合后的结果。

RocketMQ页面

主页面

主题页面

 消费者页面

发送消息并消费

启动SpringBoot应用后，访问接口文档：http://localhost:8080/doc.html

结果：

1.测试只有topic的情景

后端结果（成功接收到消息）：

2023-11-22 19:18:44.213  INFO 37900 --- [topic_group_1_1] c.e.business.mqConsumer.TopicConsumer    : TopicConsumer收到消息：topic message:2023-11-22T19:18:43.991

2.测试指定topic和tag

后端结果（成功接收到消息）：

2023-11-22 14:20:15.183  INFO 37900 --- [d_tag_group_1_1] c.e.business.mqConsumer.TagConsumer      : TagConsumer收到消息：tag message:2023-11-22T14:20:15.175

3.测试延迟消息

后端结果（消息发送后，五秒钟之后收到了消息） ：

2023-11-22 14:21:24.436  INFO 37900 --- [delay_group_1_1] c.e.business.mqConsumer.DelayConsumer    : DelayConsumer收到消息：delay message:2023-11-22T14:21:19.382

1.启动RocketMQ服务器

安装和启动流程见：Docker Compose系列–安装RocketMQ–方法/示例 – 自学精灵

2.引入依赖