RocketMQ的架构及概念
- 如上图所示,整体可以分成4个角色,分别是:NameServer,Broker,Producer,Consumer。
-
Broker(邮递员)
- Broker是RocketMQ的核心,负责消息的接收,存储,投递等功能
-
NameServer(邮局)
- 消息队列的协调者,Rocker向它们注册路由信息,同时Producer和Consumer向其获取路由信息
-
Producer(寄件人)
- 消息生产者,需要从NameServer获取Broker信息,然后与Broker建立连接,向Broker发送消息
-
Consumer(收件人)
- 消息的消费者,需要从NameServer获取Broker信息,然后Broker建立连接,从Broker获取消息
-
Topic(地区)
- 用来区分不同类型的消息,发送和接收消息前都需要先创建Topic,针对Topic来发送和接收消息
-
Message Queue
- 为了提高性能和吞吐量,引入了Message Queue,一个Topic可以设置一个或多个Message QUeue,这样消息就可以并行往各个Message Queue发送消息,消费者也可以并行从多个Message Queue读取消息
-
Message
- Message是消息的载体
-
Producee Group
- 生产者组,简单来说就是多个发送同一类消息的产生者称之为一个生产者组
-
Consumer Group
- 消息者组,和生产者类似,消费同一类消息的多个consumer实例组成一个消费者组
网友评论