RocketMQ中有以下几个核心概念:
- Producer:消息生产者,负责产生消息并发送到Broker。
- Consumer:消息消费者,负责从Broker中消费消息。
- Broker:消息中间件服务器,负责存储消息并投递给Consumer。
- Topic:消息主题,用于区分不同类型的消息。Producer发送消息时指定Topic,Consumer订阅消息也指定Topic。
- Tag:消息标签,一条消息可以有多个Tag,用于消息的二级索引。消费者可以根据Tag过滤消息。
- Message:消息,由消息体和相关属性组成,消息体是不透明的Byte数组,属性用来描述消息。
- Message Queue:消息队列,属于Topic的队列集合。每个队列对应一个物理文件,用于存储消息。
- Commit Log:消息日志,保存Producer发送到Broker的原始消息数据。
- ConsumeQueue:消费队列,按消息关键属性排序的队列,用于提高消息消费的性能。
- Broker Name:Broker的名字,用于区分不同的Broker实例。
- Cluster Name:集群名称,用于区分不同的集群。一个集群内的Broker可以有相同的Topic和Message Queue。
- NameServer:名称服务,维护Broker的路由信息,Producer和Consumer通过NameServer查询Broker的信息。
- Producer Group:生产者组,将多个生产者绑定在一起,只有该组内的某一个生产者可以发送消息。用于顺序发送的场景。
- Consumer Group:消费者组,将多个消费者绑定在一起消费同一个Topic的消息。消息会被组内的消费者平均分摊消费。
RocketMQ通过以上这些概念实现了异步解耦、削峰填谷、顺序化等功能。熟练掌握这些概念,可以让我们更好地使用RocketMQ解决实际业务场景中的问题。