spring-boot-route(十五)整合RocketMQ
RocketMQ简介
RocketMQ是阿里巴巴开源的消息中间件。目前已经贡献给Apache软件基金会,成为Apache的顶级项目。
rocketMQ基本概念
1. Producer Group
生产者组:是一类生产者的集合,通常发送同一类消息并且发送逻辑一致。
2. Producer
生产者:负责发送消息,有三种消息发送模式。
- 同步发送:收到确认后再发送下一条消息
- 异步发送:发送后,不等待确认继续发送下一条
- 单向发送:只负责发送消息,无法确认并且没有回调,适合收集日志
3. Consumer Group
消费者组:是一类消费者的集合,通常消费同一类消息并且消费逻辑一致。
4. Consumer
消息者:负责消费消息,有两种消费模式
- 拉取型消费:主动从消息服务器拉取信息,只要批量拉取到消息,用户应用就会启动消费过程
- 推送型消费:实际上也是拉取消息,只不过是将拉取逻辑进行了封装,将消息到达时执行的回调接口留给用户来实现
5. Broker
消息服务器:存储消息
6. NameServer
作用和zookeeper类似,用来保存broker相关元素,并给producer和consumer查找broker消息,Producer 在发送消息前会根据 Topic 到 NameServer 获取到 Broker 的路由信息,Consumer 也会定时获取 Topic 的路由信息。
7. Topic
消息主题
8. Tag
标签,Topic的二级分类,也可以理解为消息队列,主题被划分为一个或多个子主题,即消息队列。一个 Topic 下可以设置多个消息队列,发送消息时执行该消息的 Topic ,RocketMQ 会轮询该 Topic 下的所有队列将消息发出去。
Spring Boot整合Rocketmq
1. 引入依赖
<dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-spring-boot-starter</artifactId> <version>2.1.0</version> </dependency>
2. 配置rocketmq信息
rocketmq: name-server: 127.0.0.1:9876 producer: group: my-producer-group
3. 构建生产者
@RestController public class Producer { @Autowired private RocketMQTemplate rocketMQTemplate; @GetMapping("send") public void send(){ rocketMQTemplate.convertAndSend("first-topic","你好,Java旅途"); } }
4. 构建消费者
@Component @RocketMQMessageListener(topic = "first-topic",consumerGroup = "my-consumer-group") @Slf4j public class Consumer implements RocketMQListener<String> { @Override public void onMessage(String message) { log.info("我收到消息了!消息内容为:"+message); } }
emmm,消息队列的内容就暂时告一段落了,文章中只是演示了最简单的收发消息,在实际应用中需要考虑的问题远比这要多。
此是spring-boot-route系列的第十五篇文章,这个系列的文章都比较简单,主要目的就是为了帮助初次接触Spring Boot 的同学有一个系统的认识。本文已收录至我的github,欢迎各位小伙伴
star!
github:https://github.com/binzh303/spring-boot-route
点关注、不迷路
如果觉得文章不错,欢迎关注、点赞、收藏,你们的支持是我创作的动力,感谢大家。
如果文章写的有问题,请不要吝啬,欢迎留言指出,我会及时核查修改。
如果你还想更加深入的了解我,可以微信搜索「Java旅途」进行关注。回复「1024」即可获得学习视频及精美电子书。每天7:30准时推送技术文章,让你的上班路不在孤独,而且每月还有送书活动,助你提升硬实力!
- 三分钟学会spring boot整合rocketmq
- SpringBoot(17)---SpringBoot整合RocketMQ
- Spring Boot (十五)—— 整合Thymeleaf
- RocketMQ最佳实践(三)开发spring-boot-starter-rocketmq实现与spring boot项目的整合
- SpringBoot2.0 整合 RocketMQ ,实现请求异步处理
- spring-boot-route(十四)整合Kafka
- spring boot 1.5.4 整合webService(十五)
- Springboot整合RocketMQ使用心得
- SpringBoot整合Rocketmq
- 企业级 SpringBoot 教程 (十五)Springboot整合RabbitMQ
- SpringBoot整合RocketMQ
- SpringBoot2.0 整合 RocketMQ ,实现请求异步处理
- SpringBoot2.0 整合 RocketMQ ,实现请求异步处理
- springboot 整合 rocketMQ
- Spring boot 整合 RocketMQ
- SpringBoot(十五):SpringBoot整合Mybatis-Plus
- springboot开发笔记(5.2 整合rocketmq)
- spring boot整合hessian(十二)
- 极简 Spring Boot 整合 Thymeleaf 页面模板
- springboot整合Redis