首页 > 其他分享 >rocketmq

rocketmq

时间:2023-06-06 22:25:53浏览次数:35  
标签:队列 msgId 偏移量 消息 offsetMsgId 标识符 rocketmq

rocketmq

在 RocketMQ 中,msgId 和 offsetMsgId 是两个不同的概念。

msgId 是消息唯一标识符。具有全局唯一性,由 RocketMQ 在消息发送时自动生成。当消息被成功发送到 Broker 端后,msgId 会随着消息一起存储在 commitlog 文件中,并且在消息消费时也可以用来查找和定位该消息。通常情况下,生产者和消费者都不需要关心 msgId 的生成和使用。
offsetMsgId 是消息在队列中的偏移量标识符。当一个消息发送到 RocketMQ 集群中时,它首先会进入 Topic 下的某个队列(queue)中。每个队列都有自己的 offsetMsgId 序列号。生产者发送消息时,会收到一个 SendResult 对象,其中包含了消息在对应队列中的 offsetMsgId 偏移量标识符。消费者在消费消息时,也可以通过 offsetMsgId 来定位指定位置的消息,并从该位置开始消费。
总之,msgId 和 offsetMsgId 是两个不同用途的标识符,前者是消息的唯一标识符,而后者是消息在队列中的偏移量标识符。对于生产者和消费者而言,它们主要关注的是 offsetMsgId 及其相关的操作,而 msgId 则通常由系统自动处理。

标签:队列,msgId,偏移量,消息,offsetMsgId,标识符,rocketmq
From: https://www.cnblogs.com/caoxuekun/p/17461878.html

相关文章

  • RocketMQ:一个纯java的开源消息中间件--开发测试环境搭建
    一、简介  RocketMQ的前身是Metaq,当 Metaq 3.0发布时,产品名称改为RocketMQ    MetaQ2.x版本由于依赖了alibaba公司内部其他系统,对于公司外部用户使用不够友好,推荐使用3.0版本。   项目地址: https://github.com/alibaba/RocketMQ二、安装RocketMQ   安装Rocket......
  • RocketMQ入门(3)拉取消息
     http://www.changeself.net/archives/rocketmq%e5%85%a5%e9%97%a8%ef%bc%883%ef%bc%89%e6%8b%89%e5%8f%96%e6%b6%88%e6%81%af.html......
  • RocketMQ 脚本调优
    #!/bin/sh##ExecuteOnlyOnce#echo'vm.overcommit_memory=1'>>/etc/sysctl.confecho'vm.min_free_kbytes=5000000'>>/etc/sysctl.confecho'vm.drop_caches=1'>>/etc/sysctl.confecho'vm.zone_re......
  • 万字长文讲透 RocketMQ 4.X 消费逻辑
    RocketMQ是笔者非常喜欢的消息队列,4.9.X版本是目前使用最广泛的版本,但它的消费逻辑相对较重,很多同学学习起来没有头绪。这篇文章,笔者梳理了RocketMQ的消费逻辑,希望对大家有所启发。1架构概览在展开集群消费逻辑细节前,我们先对RocketMQ4.X架构做一个概览。整体架构中......
  • 万字长文讲透 RocketMQ 4.X 消费逻辑
    RocketMQ是笔者非常喜欢的消息队列,4.9.X版本是目前使用最广泛的版本,但它的消费逻辑相对较重,很多同学学习起来没有头绪。这篇文章,笔者梳理了RocketMQ的消费逻辑,希望对大家有所启发。1架构概览在展开集群消费逻辑细节前,我们先对RocketMQ4.X架构做一个概览。整体架构中......
  • 消息队列RocketMQ基本概念
     1消息模型(MessageModel)RocketMQ主要由Producer、Broker、Consumer三部分组成,其中Producer负责生产消息,Consumer负责消费消息,Broker负责存储消息。Broker在实际部署过程中对应一台服务器,每个Broker可以存储多个Topic的消息,每个Topic的消息也可以分片存储于不......
  • RocketMQ启动和端口介绍【转】
    关闭namesrv和broker关闭namesrv服务#进入binshmqshutdownnamesrv   如图关闭broker服务shmqshutdownbroker   如图通过jps验证下 如图第五节:防火墙配置宿主机需要远程访问虚拟机的rocketmq服务和web服务,需要开放相关的端口号,简单粗暴的方式是直接......
  • RocketMQ 多级存储设计与实现
    作者:张森泽随着RocketMQ5.1.0的正式发布,多级存储作为RocketMQ一个新的独立模块到达了TechnicalPreview里程碑:允许用户将消息从本地磁盘卸载到其他更便宜的存储介质,可以用较低的成本延长消息保留时间。本文详细介绍RocketMQ多级存储设计与实现。设计总览RocketMQ多级......
  • RocketMQ 多级存储设计与实现
    作者:张森泽随着RocketMQ5.1.0的正式发布,多级存储作为RocketMQ一个新的独立模块到达了TechnicalPreview里程碑:允许用户将消息从本地磁盘卸载到其他更便宜的存储介质,可以用较低的成本延长消息保留时间。本文详细介绍RocketMQ多级存储设计与实现。设计总览RocketMQ多级存储......
  • ROCKETMQ
    配置环境变量(ROCKETMQ_HOME)修改runserver.cmd1、进入bin目录下找到runserver.cmd文件,用编辑器打开,因为RocketMQ默认需要2g运行内存,做为测试用,就只要最低配置就好了,注释原有的NameServer的配置,在其前面加上rem注释掉,remset"JAVA_OPT=%JAVA_OPT%-server-Xms2g-Xmx2g-Xmn1......