目录
1. rocketmq 中的角色介绍
2. 一条消息从生产者到消费者的所有流程(简版)
3. 一条消息从生产者到消费者的所有流程
1. rocketmq 中的角色介绍
- 生产者 producer
- 生产、创造消息,会把消息发送到 broker 中
- 消息代理服务 broker
- 负责消息代理中转,消息并非直接从生产者发送到消费者,而是要经过 broker 的处理、存储、中转最终到达消费者
- 消费者 consumer
- 负责消费消息,消费者会从 broker 拉取消息,并把消息提供给应用程序
- 主题 topic
- 表示一类消息的集合,每个主题包含若干条消息,每条消息只能属于一个主题,是RocketMQ进行消息订阅的基本单位。
- nameserver
- 相当于注册中心,broker 将自己的信息(ip,端口号等)上报给 nameserver,生产者和消费者就可以通过 broker name 去寻找对应的 broker ip 列表(broker 可能有多个节点)。多个 nameserver 实例组成集群,但是相互独立没有信息交换
2. 一条消息从生产者到消费者的所有流程(简版)
提供了生产者,broker,消费者,nameserver 之间的简要交互流程
3. 一条消息从生产者到消费者的所有流程
下面让我们先忽略 name server (仅提供服务发现,与核心消息流程无关),查看下详细的消费流程。