基本概念

基本概念介绍 #

本页将主要介绍CatMQ 中涉及到的基本概念,以便于用户可以更好的了解本系统

主题(Topic) #

主题表示某一类消息的聚合,用来区分不同的业务消息,主题和消息是一对多的逻辑,是CatMQ在消息订阅的最小单位。

在基于主题的系统中,消息被发布到主题或命名通道上。消费者将收到其订阅主题上的所有消息,生产者负责定义订阅者所订阅的消息类别。这是一个基础的概念模型,而在实际的应用中,结构会更复杂。例如为了支持高并发和水平扩展,中间的消息主题需要进行分区,同一个Topic会有多个生产者,同一个信息会有多个消费者,消费者之间要进行负载均衡等。

消息(Message) #

消息是catmq最小的数据传输单元,生产者将业务数据包装成消息发送到服务端,服务端按照相关语义将消息投递到消费端进行消费。

消费者组(ConsumerGroup) #

消费者组是一个抽象出来的概念,一个消费者组下面有多个消费者。一个消费者组共同订阅者一个topic。消息会按照设定好的动态算法分配到不同的消费者上,从而提高系统的容错性和可扩展性。

生产者/消费者(product/consumer) #

生产者负责生产消息,一般由业务方负责生产消息,消息生产者会将消息发送到消息系统的服务端(Broke)。 消费者负责消费信息,一般是下游的业务方,从消费系统服务端拿到消息。

队列(Queue) #

队列是消息实际存储的地方,也是最小的消息存储单元。catmq 中所有的主题都是由多条队列组合而成。

消息偏移(MessageQueueOffset) #

消息偏移是记录消息在队列中的位置,由于系统会持久化信息,所以消息消费以后,旧的消息不会消失,系统会自动记录最新的消息消费位置,下一次消息消费的时候,消息就是从这个消费偏移的位置开始消费。

消息标签(MessageTage) #

消息便签是catmq提供的细粒度的消费分类属性,消费者可以根据MessageType进行更加细粒度的消息控制。

消息订阅(subscribe) #

消息订阅是消费者获取消息、处理消息的规则和状态配置。消费者订阅一个 topic 后, Topic中的消息都会发送给消费者。

服务端(Broke) #

CatMQ 的基本运行工作单位,是无状态运行,可以轻易的水平扩容,上线下线。

管理端(Portal) #

CatMQ的前端运维管理画面,通过可视化操作,权限控制等功能,方便用户更加简单和直观的运维管理CatMQ 的元数据信息。