认识RocketMQ
2025-12-28 14:39:58 0 举报AI智能生成
RocketMQ是一个由阿里巴巴开源的消息中间件
作者其他创作
大纲/内容
快速实战以及核心概念
为什么选择RocketMQ
基本概念
主题（Topic）
消息类型（MessageType）
消息队列（MessageQueue）
消息（Message）
消息视图（MessageView
消息标签（MessageTag）
消息位点（MessageQueueOffset）
消费位点（ConsumerOffset）
消息索引（MessageKey）
生产者（Producer）
事务检查器（TransactionChecker）
事务状态（TransactionResolution）
消费者分组（ConsumerGroup）
消费者（Consumer）
消费结果（ConsumeResult）
订阅关系（Subscription）
消息过滤
重置消费位点
消息轨迹
消息堆积
事务消息
定时/延时消息
顺序消息
参数约束
Topic名称
Topic命名应该尽量使用简短、常用的字符，避免使用特殊字符。特殊字符会导致系统解析出现异常，字符过长可能会导致消息收发被拒绝。
ConsumerGroup名称
简短 常用
ACL Credentials
请求超时时间
消息大小
消息自定义属性
MessageGroup
消息发送重试次数
消息消费重试次数
事务异常检查间隔
半事务消息第一次回查时间
半事务消息最大超时时长
PushConsumer本地缓存
PushConsumer重试间隔时长
PushConsumer消费并发度
获取消息最大批次
SimpleConsumer最大不可见时间
领域模型
模型关系
主题（Topic）
消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息
作用
定义数据的分类隔离
定义数据的身份和权限
类型
Normal
普通消息
消息本身无特殊语义，消息之间也没有任何关联
FIFO
顺序消息
RocketMQ 通过消息分组MessageGroup标记一组特定消息的先后顺序，可以保证消息的投递顺序严格按照消息发送时的顺序。
Delay
定时\延时
通过指定延时时间控制消息生产后不要立即投递，而是在延时间隔后才对消费者可见。
Transaction
事务消息
RocketMQ 支持分布式事务消息，支持应用数据库更新和消息调用的事务一致性保障。
UNSPECIFIED
未指定
RETRY
重试
DLQ
死信消息
SYSTEM
系统消息
队列（MessageQueue）
客户端编程模型
功能特性（消息模型）
子主题
核心源码解读
集群高级特性
MQ常见问题
职业：暂无
0 条评论
下一页
