《云原生》一文搞懂RocketMQ队列概述
| 阿里云国内75折 回扣 微信号：monov8 |
| 阿里云国际，腾讯云国际，低至75折。AWS 93折 免费开户实名账号 代冲值 优惠多多 微信号：monov8 飞机：@monov6 |
目录
序
接上一篇对rabbitMQ队列进行了梳理 《一文搞懂rabbitMQ消息队列概述》。
本篇对另一种消息队列rocketMQ进行概述理解。
注本文依据当前最新版本5.x为基础展开
概念简述
分为三个方面进行分析理解
- 客户端概念
- 消息传输模型
- 实践应用
一、客户端概念
1. Topic-主题
主题是RocketMQ消息传输和存储的顶层容器标识同一类业务消息逻辑数据。只是一个逻辑容器并不是实际的消息容器。
messageType(消息类型)控制台创建主题时需要设置一种消息类型后续向该主题传输消息该主题只会接收对应的消息类型不匹配的则会直接拒绝接收。
- Normal(普通消息)没有特殊语义消息自己没有任何关联
- FIFO顺序消息MQ通过消息分组messageGroup标记一组特定消息的先后顺序可以保证消息的投递顺序可以严格按照消息的发送顺序进行投递。
- Delay定时/延时消息通过设置延时时间控制消息生产后不立即投递而是等延时间隔时间后对消费者可见。
- Transaction事务消息rocketMQ支持分布式事务支持应用数据库消息和消息回调事务一致性保障。
queue队列控制台创建主题时需要设置主题的队列数量不用单独创建队列MQ服务器会自动创建。抛开不同服务商的实现对于队列本身来说单个queue 具有自然顺序性
注1对于RocketMQ的队列还具备一个独一无二的的特性流式操作语义队列的存储模型可确保消息从任意位点offset读取任意数量的消息以此实现类似聚合读取、回溯读取等特性。
2.ConsumerGroup消费者组
概念是Apache RocketMQ中存在多个消费行为一直的消费者负载均衡分组。
投递顺序性控制台创建消费者分组时需要设置一种消费者投递的顺序。
- 顺序投递消费顺序和发送顺序完全一致。
- 并发投递并发消费尽可能按时间顺序处理。
注2按消费者是否设置消费者组对于投递顺序性有不同的特性详细可参考RocketMQ官网消费者组详解
消费重试策略控制台创建消费者分组时设置。保证消费者消费消息异常或失败后出去的重试策略。
- 重试次数
- 死信队列设置
- 重试时间间隔
- ...
注3根据消费者类型不同重试触发时机存在差异
1PushConsumer异常时返回失败状态码立即重试
2SimpleConsumer静默等待超时服务器自动重试
注4建议通过减少重试次数+延长重试间隔来降低系统压力避免出现无限重试或大量重试的情况。
在控制台中 topic主题 与 consumerGroup消费者组 没有直接的关联
概念一览图
二、消息传输模型
MQ的消息传输模型大致分为两类点对点消息模型、发布/订阅消息模型
Apache RocketMQ只支持一种消息模型发布/订阅消息模型
注5Apache RabbitMQ两种消息传输模型都支持
三、实践应用
1.配置文件
- nameServer:服务器地址(控制台获取)
- AccessKey控制台获取
- SecretKey控制台
- producer groupId(客户端自定义设置)
2.生产者
- topic:主题控制台获取
- messageKey消息唯一索引键客户端自定义设置
- messageBody:消息内容体客户端自定义设置
- messageTag:消息过滤标签客户端自定义设置
3.消费者
- topic主题控制台获取
- consumerGroup消费者组控制台获取
- messageTag:消息过滤标签客户端自定义设置与生产者过滤标签对应
消费者订阅关系
上面说到控制台topic与consumerGroup没有直接的关联其实是在客户端通过消费者产生的联系。
项目中集成RocketMQ可参考 springboot 整合 腾讯云RocketMq版消息队列服务
配置一览图
最后的话
至此rocketMQ的基本概念大致清楚了但是想要生产运用不仅仅止步于表面自己更需要去深耕框架底层的逻辑实现才能真正掌握并达到事半功倍的效果。
行动起来