首页 > 其他分享 >rocketMQ客户端和nameService、broker之间的信息交互

rocketMQ客户端和nameService、broker之间的信息交互

时间:2022-09-18 21:58:03浏览次数:71  
标签:队列 nameService broker 信息 topic rocketMQ 客户端

客户端(包含生产者和消费者)定时任务里updateTopicRouteInfoFromNameServer方法,定时向nameService获取topic(当前客户端所包含的所有消费者者消费的和生产者要发送的)的信息

对于一个topic来说,可能会在多个broker上有队列,所以broker信息会是一个列表,唯一标识是brokerName!!,对应一个(如果是主从结构,会是多个,brokerId为0的是master)brokerAddress,至于队列的消息,只需要知道当前topic在当前broker上有几个队列即可。

而做为客户端,信息直接同步给broker而不是nameService,从nameService那里获取到broker的信息之后,会向所有的broker发送自己的信息,其中包括,consumerGroup、producerGroup,订阅的topic和tag信息、messageModel等。

标签:队列,nameService,broker,信息,topic,rocketMQ,客户端
From: https://www.cnblogs.com/chuliang/p/16705593.html

相关文章

  • RocketMQ实战与原理解析-杨开元.pdf
    这是一本学习RocketMQ实战与实现原理的非常好的资料,内容言简意赅,非常适合初学者和对RocketMQ有一定使用经验的人,能够快速从全局层面掌握RocketMQ设计思想与核心实现。点击......
  • 读完 RocketMQ 源码,我学会了如何优雅的创建线程
    RocketMQ是一款开源的分布式消息系统,基于高可用分布式集群技术,提供低延时、高可靠的消息发布与订阅服务。这篇文章,笔者整理了RocketMQ源码中创建线程的几点技巧,希望大......
  • RocketMq使用过程中问题场景和解决方案
    MQ使用过程中可能出现的问题以及解决方案一、MQ如何避免消息堆积的问题:1)产生背景:producer发送消息的速率远大于consumer消费消息的速率,从而导致消息堆积在mq服务端中;2)......
  • 十问 RocketMQ:十年再出发,到底有何不同?
    背景作为一种实时数据的处理平台,消息系统的发展跟业务架构的变迁一直息息相关,那么我们可以透过业务架构的变化来看消息系统的发展历程和未来趋势。经过十多年的发展,Rocket......
  • RocketMQ:RocketMQ常见面试题整理
    RocketMQ常见面试题整理MQ优缺点:优点:异步;解耦;削峰。RocketMQ默认端口号:9876。RocketMQ三大功能:缺点:系统可用性降低;系统复杂性提高;存在消息(数据)一致性问题。消息可靠......
  • RocketMQ
    一、RocketMQ整体架构设计整体的架构设计主要分为四大部分,分别是:Producer(生产者)、Consumer(消费者)、Broker(服务器)、NameServer(注册中心)。 NameServer Na......
  • 面试题之RocketMQ
    1、为什么要使用MQ?因为项目比较大,做了分布式系统,所有远程服务调用请求都是同步执行经常出问题,所以引入了MQ,MQ具有异步解耦和削峰填谷的作用2、RocketMQ由哪些角......
  • MQ系列5:RocketMQ消息的发送模式
    MQ系列1:消息中间件执行原理MQ系列2:消息中间件的技术选型MQ系列3:RocketMQ架构分析MQ系列4:NameServer原理解析在之前的篇章中,我们学习了RocketMQ的原理,以及RocketMQ中......
  • rocketmq安装
    4、启动(1)启动NAMESERVER使用cmd打开命令窗口,进入到rocketmq的bin目录下,执行:startmqnamesrv.cmd,若成功会弹出如下提示框,请勿关闭此框。(2)启动BROKER同样在rocketmq的bin......
  • RocketMQ 的详解
    https://blog.csdn.net/qq_57558631/article/details/124239371https://www.cnblogs.com/happydreamzjl/articles/11951245.htmlhttps://cdn.modb.pro/db/72488https://......