简述RocketMQ的消息模型(Mess ?age Model)

RocketMQ的消息模型主要包括Producer、Broker和Consumer三部分。

Producer主要负责生产消息,一般由业务系统负责生产消息。它会把业务应用系统里产生的消息发送到broker服务器。RocketMQ提供多种发送方式,同步发送、异步发送、顺序发送、单向发送。

Broker负责存储消息,在实际部署过程中对应一台服务器,每个Broker可以存储多个Topic的消息,每个Topic的消息也可以分片存储于不同的Broker。Broker还提供了MessageQueue用于存储消息的物理地址,每个Topic中的消息地址存储于多个MessageQueue中。

Consumer负责消费消息。ConsumerGroup由多个Consumer实例构成。

发表评论

后才能评论