RocketMQ主要由Producer、Broker和Consumer三部分组成,如下图所示:
1.Producer:消费生产者,负责将消息发送到Broker
2.Brock:消息中转服务器,负责存储和转发消息。RocketMQ支持多个Broker构成集群,每个Broker都拥有独立的存储空间和消息队列。
3.Consumer:消息消费者,负责从Broker消费消息。
4.NameServer:名称服务,负责维护Broker 的元数据信息,包括Broker地址,TGopic和Queue等消息。Producer和Consumer在启动时需要连接到NameServer获取Broker的地址信息。
5.Topic:消息主题,是消息的逻辑分类单位。producer将消息发送到特定的Topic中,Consumer从指定的Topic中消费消息。
6.Message Queue:消息队列,是Topic的物理实现。一个Topic可以有多个Queue,每个Queue都是独立的存储单元,Producer 发送的消息会被存储到对应的Queue中,Consumer从指定的Queue中消费消息。