RocketMQ 4.x架构设计有哪些特点？

本文共计683个文字，预计阅读时间需要3分钟。

RocketMQ消息模型与其他消息队列类似，都是通过producer生产消息到topic，由consumer消费消息。消息的存储、分片等都是基于topic的业务处理。

RocketMQ消息模型跟其他的消息队列一样 都是 producer - > topic->consumer

producer 生产消息 也就是发送者

topic 消息主题 按topic发送消息 以后消息的存储 分片等都是基于topic做业务处理的

consumer 消息消费者 也是基于topic来进行消息的消费 支持推和拉模式(其实内部都是pull模式的变种)。

扩展集群消息模型

为了支持高并发、提高可扩展性、提高消息堆积能力。

一个topic可以有多个队列 而且还可以在不同的物理机器，这就为高吞吐、水平扩展支持打了基础。

在消费端consumer支持组(group)概念。一组consumer里面有多个消费者实例，一组consumer来消费某个topic 这样消费能力就得到了水平扩展

consumer组支持​​集群消费模式​​、​​广播消费模式​​

• 集群消费下同组consumer实例会去拉取对应topic的不同队列上数据进行消费。‘
• 广播模式是每个消费者都会拉取对应topic中所有队列的消息来消费。