基本概念介绍 #
本页将主要介绍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 的元数据信息。