rocketMQ运行过程

1  nameserver运行主要流程

        1 broker 启动,请求nameserver(集群中所有的)建立长链接,心跳机制,并发送topic和broker对应关系给namserver,

        2 生产者消费者 启动 和 nameserver 建立长链接 心跳 获取到对应数据,进行发送和消费消息。

2 生产者生产普通消息发送到消费者整个流程

               生产者组:生产者组是一个虚拟的概念,一个组里可以有多个生产者,生产者组和topic是1:1关系,一个生产者组对应一个topic,如果要发这个topic消息,需要加入到生产者组里面。

                topic和tag:生产者组里面的生产者可以发本topic下的任意tag,发送到broker的队列里,发送过程中会做负载均衡和高可用

                主从同步:主收到消息会同步给从,有同步异步两种方式

                消费者组:一个消费者组只能对应一个topic-tag,消费者组里面有多个消费者,要消费这个topic-tag必须要加入到消费者组里面,单个消费者是可以消费broker集群里面topic所有队列里所有这个tag的消息的。总之订阅关系是 topic 有N 个 tag  那就必须对应N个消费者组。

3 消费者消费广播模式的消息对应关系

                每个消费者都会消费所订阅的Topic + Tag下的所有queue中的所有消息。

猜你喜欢

转载自blog.csdn.net/u010191034/article/details/121443262