RocketMQ 执行流程

1、启动 Namesrv,Namesrv 起 来后监听端口,等待 Broker、Producer、Consumer 连上来,相当于一个路由控制中心。

2、Broker 启动,跟所有的 Namesrv 保持长连接,定时发送心跳包。

3、收发消息前,先创建 Topic 。创建 Topic 时,需要指定该 Topic 要存储在 哪些 Broker 上。也可以在发送消息时自动创建 Topic。

4、Producer 发送消息。

5、Consumer 消费消息

  
    展开阅读全文