首页 > 其他分享 >rocketmq--有哪些关键名词

rocketmq--有哪些关键名词

时间:2024-01-23 16:47:10浏览次数:28  
标签:RocketMQ 消费者 -- Broker Topic 名词 Tag 消息 rocketmq

RocketMQ是一个开源的分布式消息中间件,它具有高性能、高吞吐量、可扩展性和可靠性等特点。在使用RocketMQ时,你会遇到以下几个关键概念:

  1. NameServer(名称服务):
    NameServer是RocketMQ的注册中心,负责维护所有Broker的路由信息,供生产者和消费者查询。生产者和消费者启动时,需要连接到NameServer获取路由信息,以确定目标Broker。

  2. Broker(消息处理节点):
    Broker是消息存储和传输的节点,负责存储消息、消息的投递以及提供消息查询等功能。Broker可以是Master也可以是Slave,支持高可用的主从复制机制。

  3. Producer(生产者):
    生产者是消息的发送方,它负责创建消息并将消息发送到Broker。生产者需要指定消息的Topic(主题)和可选的Tag(标签),以便消费者可以基于这些信息过滤和接收消息。

  4. Consumer(消费者):
    消费者是消息的接收方,它负责从Broker订阅和接收消息。消费者可以是集群消费模式(负载均衡)或广播消费模式(每个消费者都收到所有消息)。

  5. Topic(主题):
    主题是消息分类的标识,生产者将消息发送到指定的Topic,消费者从指定的Topic接收消息。一个Topic可以有多个订阅者,但是每个消息只能属于一个Topic。

  6. Tag(标签):
    标签是对Topic进一步细分的标识,用于过滤消息。生产者在发送消息时可以指定Tag,消费者可以基于Tag进行消息过滤,只消费具有特定Tag的消息。

  7. Message Queue(消息队列):
    消息队列是存储消息的基本单位。一个Topic可以被分割成多个队列,队列是并发读写消息的基础。在集群消费模式下,多个消费者实例共同消费一个Topic的消息会被分配到不同的队列,实现负载均衡。

  8. Message(消息):
    消息是通信的基本单位,包含了要传输的数据以及相关的元数据,如:Key(业务标识符)、Tag、Topic等。

  9. Message Model(消息模型):
    RocketMQ支持两种消息模型:集群消费和广播消费。集群消费模式下,同一个消费者组的每个实例平均分摊消息负载;广播消费模式下,每个消费者实例都会接收到所有消息的副本。

  10. Offset(偏移量):
    偏移量是消费者跟踪其在消息队列中当前位置的标识。消费者可以基于偏移量重新消费消息或跳过某些消息。

这些概念构成了RocketMQ的基础架构和工作机制。了解这些概念有助于更好地使用RocketMQ进行消息的生产和消费。

标签:RocketMQ,消费者,--,Broker,Topic,名词,Tag,消息,rocketmq
From: https://www.cnblogs.com/xylfjk/p/17982811

相关文章

  • TCP request_sock_TCP
    https://blog.csdn.net/weixin_43380635/article/details/91457330#解决cpu性能占用过高https://www.jianshu.com/p/974a1cd21cfd#解决并发链接数 ......
  • inode爆满error is not recoverable exiting now
      查看    ......
  • android studio打开别人的项目,解决各种错误的方法
    1、as提示,gradle工具从官方地址下载不下来(非常常见):修改项目下Gradlescript的gradle-wrapper.properties因为天朝网络屏蔽,把官方地址修改为国内腾讯源即可让androidstudio正常自动下载https://mirrors.cloud.tencent.com/gradle/gradle-7.2-bin.zip,最后的gradle-7.2-bin.zip必......
  • Selenium爬取文章实例
    这一篇主要是解决一个问题:浏览器操作下拉才能显示更多的内容fromseleniumimportwebdriverfromselenium.webdriver.chrome.serviceimportServicefromselenium.webdriver.common.byimportByimporttimethepaper_dict={}web=webdriver.Chrome(service=Service('......
  • Camera基础(Linux之V4L2驱动框架)
    摄像头的基本工作原理如图所示,一个景象的反射光被镜头所捕捉(镜头的光圈可以调节进光量,马达用来调节对焦),最终将聚焦好的图像精准对焦到图片传感器上边(色彩滤波会产生三基色),光信号转化为数字信号,通过模数转换最终得到原始码流数据。问题:那我们可以直接使用这个包含图像信息和颜色信......
  • 「云渲染C4D」C4D如何进行云渲染?
    云渲染C4D的过程可现实一键式完成,目前云渲染平台随着技术的发展,平台的使用越发容易操作,无论是渲染文件的传输性、安全性、高效性都有较大的提升,本次为大家简单说明下关于云渲染操作方法。(图源网络)C4D云渲染流程第一步:准备渲染文件通过本地电脑上完成个人建模,确保C4D项目文件......
  • 2024.1.23-每日进度笔记
    今天,我尝试在mysql插入数据后获取自增字段的值。 参考:百度文心一言的回复。 publicstaticintinsertTimu(StringtimuLeixing,StringtimuWenti,StringtimuDaan,StringtimuXuanxiang)throwsException{intres=0;Connectionconnection=uti......
  • kafka常用命令
    进入kafka服务bin目录查看主题./kafka-topics.sh--list--bootstrap-server10.1.1.2:9092创建主题./kafka-topics.sh--bootstrap-server10.1.1.2:9092--create--topicmytopic--partitions1查看消费者列表-list./kafka-consumer-groups.sh--bootstrap-server10.1.1.2......
  • linux5_32位安装PAE支持3G以上内存
    安装PAE:[root@10_32_66_86yum.repos.d]#yuminstallkernel-PAELoadedplugins:rhnplugin,securityThissystemisnotregisteredwithRHN.RHNsupportwillbedisabled.SettingupInstallProcessResolvingDependencies-->Runningtransactioncheck--->Pack......
  • elasticsearchjava客户端
    elasticsearchjava客户端1.引用maven配置<dependency><groupId>org.elasticsearch.client</groupId><artifactId>elasticsearch-rest-high-level-client</artifactId><exclusions><exclusion>&l......