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/