因为RocketMQ的消息存储在Broker中的CommitLog中，由索引文件ConsumerQueue来查询消息，ConsumerQueue中用来定位消息的就是CommitLog的Offset，所以消费者或者Broker通过管理Offset来管理消费进度。

消费模式

  • 广播消费

    
ConsumerGroup中的所有Consumer都可以消费Topic的所有消息，各自的消费进度没有交集，所以offset是consumer本地管理

  • 集群消费

    
ConsumerGroup中的所有Consumer互斥消费Topic的消息，即一个消息只能被一个Consumer消费，ConsumerGroup下所有Consumer共同维护一个消费进度，所以offset是在Broker端远程管理

Offset的提交方式

在集群消费模式下，Consumer向Broker提交offset的方式有两种：

  • 同步提交

    • Consumer处理完消息后会向Broker提交offset，然后等待Broker的成功响应，在超时时间内获取到响应则进行下一批消息获取，否则重新提交offset，直到获取响应，这个过程中Consumer是阻塞的

  • 异步提交

    • Consumer处理完消息后会向Broker提交offset，不等待Broker响应，直接获取下一批消息，提高了消费者的吞吐量，但是一旦Broker宕机了，offset没有持久化，当Broker重启后就会重复消费

标签: SocketMQ, MQ消费, Offset

已有 39 条评论

  1. wywyoiftlv wywyoiftlv

    这篇文章不错！

    回复
  2. fqazhgpdys fqazhgpdys

    选材新颖独特，通过细节描写赋予主题鲜活生命力。

    回复
  3. uadrerviij uadrerviij

    文章的叙述风格独特，用词精准，让人回味无穷。

    回复
  4. rpahxyraks rpahxyraks

    作者的情感表达细腻入微，让人在阅读中找到了心灵的慰藉。

    回复
  5. favpqttobn favpqttobn

    独特的构思和新颖的观点，让这篇文章在众多作品中脱颖而出。

    回复
  6. gmjvxljxag gmjvxljxag

    案例丰富且贴合主题，论证逻辑环环相扣。

    回复
  7. maraojchcz maraojchcz

    文章深入浅出，既有深度思考，又不乏广度覆盖，令人叹为观止。

    回复
  8. pfzxbmzqsz pfzxbmzqsz

    结论部分可提出实际应用建议，提升价值。

    回复
  9. mczxlmqdjl mczxlmqdjl

    故事线完整，伏笔巧妙，结局耐人寻味。

    回复
  10. vzmjqakbkv vzmjqakbkv

    终极关怀的缺失可尝试补充升华。

    回复
  11. yhuqleubks yhuqleubks

    学术术语使用精准，专业性突出。

    回复
  12. dyqjgfxwhk dyqjgfxwhk

    这是一篇佳作，无论是从内容、语言还是结构上，都堪称完美。

    回复
  13. udhvhuuhma udhvhuuhma

    这篇文章如同一幅色彩斑斓的画卷，每一笔都充满了独特的创意。

    回复
  14. fwmevlfkwe fwmevlfkwe

    这篇文章提供了宝贵的经验和见解，对读者有很大的启发和帮助。

    回复
  15. vybhjhlqoa vybhjhlqoa

    建议后续持续追踪此话题，形成系列研究。

    回复
  16. gobekhmrmz gobekhmrmz

    老话题新解读，展现了深刻的反思精神。

    回复
  17. plyokcoxvu plyokcoxvu

    哈哈哈，写的太好了https://www.lawjida.com/

    回复
  18. mbuhzxjhpo mbuhzxjhpo

    《深夜》泰国剧高清在线免费观看：https://www.jgz518.com/xingkong/7317.html

    回复
  19. veexkgfxxs veexkgfxxs

    《黑神话之大夏无神 黑神话之大圣归来》短片剧高清在线免费观看：https://www.jgz518.com/xingkong/141080.html

    回复
  20. mnrxcjozlk mnrxcjozlk

    《主播日记》国产剧高清在线免费观看：https://www.jgz518.com/xingkong/40622.html

    回复
  21. zkexpvtlwe zkexpvtlwe

    《正确的恋爱开始方式》日本剧高清在线免费观看：https://www.jgz518.com/xingkong/112968.html

    回复
  22. ypqvgjnqhn ypqvgjnqhn

    《重返大福村》国产剧高清在线免费观看：https://www.jgz518.com/xingkong/34531.html

    回复
  23. ifuvmllyae ifuvmllyae

    你的才华让人惊叹，你是我的榜样。 https://www.4006400989.com/qyvideo/88750.html

    回复
  24. hdqcohzxqp hdqcohzxqp

    《吾凰在上 动态漫画》国产动漫高清在线免费观看：https://www.jgz518.com/xingkong/48992.html

    回复
  25. geiuweggkm geiuweggkm

    《王昭君2007》国产剧高清在线免费观看：https://www.jgz518.com/xingkong/135150.html

    回复
  26. wdjblkinzl wdjblkinzl

    《恶灵旅店2023》台湾剧高清在线免费观看：https://www.jgz518.com/xingkong/42889.html

    回复
  27. muvmywhsrd muvmywhsrd

    你的文章让我学到了很多技能，非常实用。 http://www.55baobei.com/mJIVSdHDHi.html

    回复
  28. pltcefhkdw pltcefhkdw

    《王昭君2007》国产剧高清在线免费观看：https://www.jgz518.com/xingkong/135150.html

    回复
  29. ewdmwyzocn ewdmwyzocn

    《重返大福村》国产剧高清在线免费观看：https://www.jgz518.com/xingkong/34531.html

    回复
  30. dkmyzrdqpq dkmyzrdqpq

    你的文章让我学到了很多技能，非常实用。 https://www.yonboz.com/video/71959.html

    回复
  31. ncfpypkzyw ncfpypkzyw

    “明日传奇私服发布网如何确保游戏安全与稳定？”：https://501h.com/heji/2024-10-20/43528.html

    回复
  32. hcrqihtsre hcrqihtsre

    你的文章总是能给我带来欢乐，谢谢你！ https://www.yonboz.com/video/9398.html

    回复
  33. kikwonfqvq kikwonfqvq

    揭秘传奇世界：如何把握私服市场新机遇：https://501h.com/danzhiye/2024-09-25/37668.html

    回复
  34. iyrtbuaypq iyrtbuaypq

    不错不错，我喜欢看 www.jiwenlaw.com

    回复
  35. tnpqjipwjj tnpqjipwjj

    想想你的文章写的特别好https://www.ea55.com/

    回复
  36. dnxbfowfmq dnxbfowfmq

    看的我热血沸腾啊https://www.ea55.com/

    回复
  37. gmuazzbuvz gmuazzbuvz

    叼茂SEO.bfbikes.com

    回复
  38. qfnnggggha qfnnggggha

    叼茂SEO.bfbikes.com

    回复
  39. afvgaslowp afvgaslowp

    博主真是太厉害了！！！

    回复
取消回复

添加新评论