栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

rocketMQ运行过程

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

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中的所有消息。

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/571831.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号