Rocketmq中的启动流程(二)
总体启动流程
PS:该图来源于Rocketmq官网
通过上图,我们可以看到Rocketmq的启动流程有以下几个步骤
- 1.启动NameServer
在上一篇文章中,我们说过Rocketmq中的NameServer类似于一个注册中心,它里面包含基本的路由信息
- 2.启动Broker
从启动图上可以看出Broker在启动以后,会向NameServer注册一些信息,哪些信息呢?例如broker自己的ip,topice信息等等。
- 3.创建topic
topic 是Rocketmq的最小单元,换句话说,你如果想玩Rocketmq,最起码要把它先搞出来。就像人体有细胞组成,没有细胞哪来的人体
- 4.启动Producer
Producer是为了发送消息,那么在发送消息之前,会先从本地获取对应的路由信息,如果获取不到就从NameServer上拉取,其中有个比较重要点就是怎么规避异常的Broker(Rockermq对这个进行了特别的处理)
- 5.启动Consumer
Consumer向NameServer发送请求,获取当前订阅Topic存在哪些Broker上,然后开始消费消息。
参考文档
http://rocketmq.apache.org/
以上是 Rocketmq中的启动流程(二) 的全部内容, 来源链接: utcz.com/z/514031.html