首页 > 其他分享 >rocketmq的转发模型

rocketmq的转发模型

时间:2023-09-04 22:12:19浏览次数:37  
标签:存储 消费 模型 Broker Topic 消息 转发 Consumer rocketmq

1.模型

  

 

2.消息模型

  RocketMQ主要由 Producer、Broker、Consumer 三部分组成,其中Producer 负责生产消息,Consumer 负责消费消息,Broker 负责存储消息。Broker 在实际 部署过程中对应一台服务器,每个 Broker 可以存储多个Topic的消息,每个Topic 的消息也可以分片存储于不同的 Broker。Message Queue 用于存储消息的物理地 址,每个Topic中的消息地址存储于多个 Message Queue 中。ConsumerGroup 由多个Consumer 实例构成。

 

3.消费者

  从用户应用的角度而言提供了两种消费形 式:拉取式消费、推动式消费。

  RocketMQ 支持两种消息模式:集群消费 (Clustering)和广播消费(Broadcasting)。

  集群消费模式下, 相同Consumer Group的每个Consumer实例平均分摊消息。 广播消费模式下,相同Consumer Group的每个Consumer实例都接收全量的消 息。

 

4.主题topic

  Topic只是一个逻辑概念,并不实际保存消息。同一个Topic下的消息,会分片保 存到不同的Broker上,而每一个分片单位,就叫做MessageQueue。

 

5.nameserver

  Namesrv实例组成集群,但相互独立,没有信息交换。

 

 

二:常见问题

1.为什么RocketMQ不用Zookeeper而要自己实现一个NameServer来进行注册?

  没有脑裂问题

  zk保证cp,没有保证高可用,所有更加合适,偏向ap

 

  为啥不用nacos

  nacos除了服务发现,还有一些配合,nacos显得更加重,不利于单个产品推进,依赖冲突问题

 

2.Consumer分组有什么用?Producer分组呢?

  在brokwer,按照组进行记录消息

  

  product组,设计到事务消息机制

  

 

标签:存储,消费,模型,Broker,Topic,消息,转发,Consumer,rocketmq
From: https://www.cnblogs.com/juncaoit/p/17678224.html

相关文章

  • 《费曼学习法:理解更快、保留更高,27个高级学习模型》
    作者:彼得·霍林斯推荐指数:一般,但非常值得一读:缺点:条理不清晰:全书读完并不能确定27个高级学习模型是哪些;内容重复:前后章节一些内容是重复出现的,例如学习步骤;优点:观点清晰;技巧实用;  ......
  • 多线程|生产者消费模型
    在正式介绍生产者消费者模型之前,我们先来认识一下阻塞队列。阻塞队列是特殊的队列,是在先进先出的基础上加了一些特殊的功能:1)如果队列为空,线程要执行出队操作时,就会进入阻塞,阻塞直到另一个线程往队列里添加元素;2)如果队列满了,线程要进行入队操作时,就会进入阻塞,直到有另一个线程从......
  • 理论基础-BASE理论和分布式事务模型
       ......
  • Ziya-LLaMA-13B 模型在GPU 上部署
    Ziya-LLaMA-13B模型在GPU上部署Ziya-LLaMA-13B是IDEA-CCNL基于LLaMa的130亿参数的大规模预训练模型,具备翻译,编程,文本分类,信息抽取,摘要,文案生成,常识问答和数学计算等能力。目前姜子牙通用大模型已完成大规模预训练、多任务有监督微调和人类反馈学习三阶段的训练过程。1.部署准......
  • iptables、共享上网SNAT、端口转发DNAT
    iptables、共享上网SNAT、端口转发DNAT1.防火墙概述封端⼝,封ip实现NAT功能共享上⽹端⼝映射(端⼝转发),ip映射2.防火墙2.1防火墙种类以及使用说明硬件:整个企业入口软件:开源软件网站内部封ipiptables云防火墙安全组NAT网关waf应用防火墙2.2专有名词容器、表、链......
  • 使用自动模型
    本文通过文本分类任务演示了HuggingFace自动模型使用方法,既不需要手动计算loss,也不需要手动定义下游任务模型,通过阅读自动模型实现源码,提高NLP建模能力。一.任务和数据集介绍1.任务介绍前面章节通过手动方式定义下游任务模型,HuggingFace也提供了一些常见的预定义下游任务模型,如......
  • 云消息队列 RocketMQ 版
    云消息队列RocketMQ版(原ONS)是阿里云基于ApacheRocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。RocketMQ自诞生以来一直服务阿里集团13年,历经多次双十一万亿级数据洪峰稳定性验证。......
  • 云消息队列 RocketMQ 版
    云消息队列RocketMQ版(原ONS)是阿里云基于ApacheRocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。RocketMQ自诞生以来一直服务阿里集团13年,历经多次双十一万亿级数据洪峰稳定性验证。......
  • nginx 请求转发
    1、修改启动端口因为80端口容易冲突2、配置服务器地址在http中添加下面的配置http{server{listen9001;server_namelocalhost;location~/acl/{proxy_passhttp://l......
  • 9-3|使用Python的scikit-learn库来训练一个逻辑回归模型,检测句子是否含有侮辱性内容:
    当然可以。以下是一个简单的例子,使用Python的`scikit-learn`库来训练一个逻辑回归模型,检测句子是否含有侮辱性内容:```pythonfromsklearn.feature_extraction.textimportTfidfVectorizerfromsklearn.linear_modelimportLogisticRegressionfromsklearn.model_selectionim......