所有分类
  • 所有分类
  • 未分类

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.引入依赖

此内容查看价格为0.5自学币立即购买,VIP免费
1

评论0

请先

显示验证码
没有账号?注册  忘记密码?

社交账号快速登录