spring-boot-route(十五)整合RocketMQ
时间:2022-07-27
本文章向大家介绍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,消息队列的内容就暂时告一段落了,文章中只是演示了最简单的收发消息,在实际应用中需要考虑的问题远比这要多。
< END >
此是spring-boot-route系列的第十五篇文章,这个系列的文章都比较简单,主要目的就是为了帮助初次接触Spring Boot 的同学有一个系统的认识。本文已收录至我的github
,欢迎各位小伙伴star
!点击文末的阅读原文即可到达github
仓库!
github:https://github.com/binzh303/spring-boot-route
- Java枚举类型的原理
- 厚土Go学习笔记 | 27. 斐波纳契闭包
- 代码审计| APPCMS SQL-XSS-CSRF-SHELL
- 厚土Go学习笔记 | 33. 利用数据流实现密码代换功能
- 厚土Go学习笔记 | 32. Readers读取数据流
- GoStub框架二次开发实践
- 厚土Go学习笔记 | 31. 错误 通常函数会返回一个error值来判断是否出错
- 厚土Go学习笔记 | 30. Stringers的一个练习
- 黑客游戏| Owasp juice shop (一)
- 厚土Go学习笔记 | 29. 接口
- Golang中Interface类型详解
- 反序列化| 我欲修仙,法力无边。
- Go语言的网络编程简介
- golang基于redis lua封装的优先级去重队列
- java教程
- Java快速入门
- Java 开发环境配置
- Java基本语法
- Java 对象和类
- Java 基本数据类型
- Java 变量类型
- Java 修饰符
- Java 运算符
- Java 循环结构
- Java 分支结构
- Java Number类
- Java Character类
- Java String类
- Java StringBuffer和StringBuilder类
- Java 数组
- Java 日期时间
- Java 正则表达式
- Java 方法
- Java 流(Stream)、文件(File)和IO
- Java 异常处理
- Java 继承
- Java 重写(Override)与重载(Overload)
- Java 多态
- Java 抽象类
- Java 封装
- Java 接口
- Java 包(package)
- Java 数据结构
- Java 集合框架
- Java 泛型
- Java 序列化
- Java 网络编程
- Java 发送邮件
- Java 多线程编程
- Java Applet基础
- Java 文档注释
- 五分钟快速搭建Serverless免费邮件服务
- 基于qiankun落地部署微前端爬”坑“记
- Android推送的群魔乱舞
- 用百度接口实现图片文字识别,并打包成安装包软件
- 视野前端(二)V8引擎是如何工作的
- 【干货】Chrome插件(扩展)开发全攻略
- 超性感的React Hooks(一):为何她独具魅力
- 超性感的React Hooks(二)再谈闭包
- Python全栈(一)基础之11.函数(3)
- Python全栈(二)数据结构和算法之1.算法和数据结构引入
- Android开发(第一行代码 第二版) 常见异常和解决办法(基于Android Studio)(一)
- Python SQLite 基本操作和经验技巧(一)
- Python字典及基本操作(超级详细)
- Python matplotlab库使用方法及注意事项
- 超性感的React Hooks(三):useState