RocketMQ是由阿里捐赠给Apache的一款低延迟、高并发、高可用、高可靠的分布式消息中间件。经历了淘宝双十一的洗礼。RocketMQ既可为分布式应用系统提供异步解耦和削峰填谷的能力,同时也具备互联网应用所需的海量消息堆积、高吞吐、可靠重试等特性。
核心概念
Topic:消息主题,一级消息类型,生产者向其发送消息。
Message:生产者向Topic发送并最终传送给消费者的数据消息的载体。
消息属性:生产者可以为消息定义的属性,包含Message Key和Tag。
Message Key:消息的业务标识,由消息生产者(Producer)设置,唯一标识某个业务逻辑。
Message ID:消息的全局唯一标识,由消息队列RocketMQ系统自动生成,唯一标识某条消息。
Tag:消息标签,二级消息类型,用来进一步区分某个Topic下的消息分类
Producer:也称为消息发布者,负责生产并发送消息至Topic。
Consumer:也称为消息订阅者,负责从Topic接收并消费消息。
分区:即Topic Partition,物理上的概念。每个Topic包含一个或多个分区。
消费位点:每个Topic会有多个分区,每个分区会统计当前消息的总条数,这个称为最大位点MaxOffset;分区的起始位置对应的位置叫做起始位点MinOffset。