概述

消息队列rocketmq是Apache旗下的开源项目（原是Alibaba开源的项目），当springboot盛行后，Apache团队开源了rocketmq-spring来帮助我们在springboot中快速集成rocketmq，只需引入rocketmq-spring-boot-starter即可。rocketmq-spring不仅实现了自动配置功能，最主要还是封装了spring-message风格的rocketmq操作，使得我们在spring中，能够像使用rabbitmq一样方便快捷的使用rocketmq。

Springboot整合RocketMQ

引入pom依赖

引入pom依赖，需要的其他依赖，自行引入

 <!-- rocketmq --><!-- https://mvnrepository.com/artifact/org.apache.rocketmq/rocketmq-spring-boot-starter --><dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-spring-boot-starter</artifactId><version>2.1.1</version></dependency>

yaml文件

#rocketmq配置信息
rocketmq:#nameservice服务器地址（多个以英文逗号隔开）name-server: 127.0.0.1:9876#生产者配置producer:#组名group: my-producer-group

简单实例

简单生产


@RestController
@RequestMapping("/api")
@Api(tags = "RocketMq开发测试")
public class RocketMqController {@Autowiredprivate RocketMQTemplate rocketMQTemplate;@GetMapping("/pushMessage")public String pushMessage(@RequestParam("str") String str) {rocketMQTemplate.convertAndSend("first-topic","你好,RocketMq =>" + str);return "success";}}

简单消费

@Slf4j
@Component
@RocketMQMessageListener(topic = "first-topic",consumerGroup = "my-consumer-group")
public class Consumer implements RocketMQListener<String> {@Overridepublic void onMessage(String message) {// 打印出消息内容log.info("==============================================>");System.out.println(message);}
}

测试结果

消费成功

本文小结

本文简单介绍了Springboot整合RocketMQ，以及如何最简单的生产和消费消息。

Springboot整合RocketMQ实战相关推荐

SpringBoot整合kafka实战之带回调的生产者
本文来说下SpringBoot整合kafka部分知识内容文章目录带回调的生产者方式一方式二本文小结带回调的生产者前面我们说了简单的生产和消费,本文说下带回调的生产者.kafkaTempl ...
springboot整合rocketMQ记录实现发送普通消息，延时消息
一.为什么选择RocketMQ消息队列?(可跳过看三的整合代码实例) 首先RocketMQ是阿里巴巴自研出来的,也已开源.其性能和稳定性从双11就能看出来,借用阿里的一句官方介绍:历年双 11 购物狂 ...
Springboot整合Rocketmq系列教程
Springboot整合Rocketmq系列教程本教程是基于Springboot2.6.3整合Rocketmq5.0,其中涉及了Rocketmq的安装,消息的发送及消费的代码实现. 本文不会对roc ...
Springboot整合Swagger实战（一）
Springboot整合Swagger实战(一) 记录一下自己在开发过程中,遇到的问题及安装环境的步骤(最讨厌安装环境了),希望可以帮到大家. 我在遇到问题的时候也是查找了好多文章,奈何呀,全是问题, ...
RocketMQ 实战-SpringBoot整合RocketMQ
1. 消息生产者 1.1 maven 依赖 <?xml version="1.0" encoding="UTF-8"?> <project x ...
Springboot 整合 Netty 实战(附源码)
作者:pjmike_pj juejin.im/post/5bd584bc518825292865395d 前言这一篇文章主要介绍如何用Springboot 整合 Netty,由于本人尚处于学习Net ...
SpringBoot整合RabbitMq实战(一)
1 Spring AMQP 简介 Spring AMQP项目是一个引入Spring核心概念用于基于高级消息队列(AMQP)的解决方案的开发,它提供了一个模板用于发送和接受消息的高级抽象.它对基于消息驱 ...
SpringBoot整合RocketMQ，三种测试附带源码【rocketmq-spring-boot-starter】
我们整合boot项目的时候都是引入 xxx-start 依赖,但是现在大多数的整合RocketMQ都还不是这样. 我花了一天时间使用rocketmq-spring-boot-starter整合,使得操 ...
SpringBoot 整合 Socket 实战案例，实现单点发送、广播群发，1对1，1对多
点击关注公众号,实用技术文章及时了解作者:小目标青年来源:https://blog.csdn.net/qq_35387940 本篇内容: 后端 + 前端简单HTML页面功能场景点: 群发,所有人 ...

Springboot整合RocketMQ实战

文章目录

概述

Springboot整合RocketMQ

引入pom依赖

yaml文件

简单实例

本文小结

Springboot整合RocketMQ实战相关推荐

最新文章

热门文章