因为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

已有 20 条评论

  1. mnrxcjozlk mnrxcjozlk

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

    回复
  2. zkexpvtlwe zkexpvtlwe

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

    回复
  3. ypqvgjnqhn ypqvgjnqhn

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

    回复
  4. ifuvmllyae ifuvmllyae

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

    回复
  5. hdqcohzxqp hdqcohzxqp

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

    回复
  6. geiuweggkm geiuweggkm

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

    回复
  7. wdjblkinzl wdjblkinzl

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

    回复
  8. muvmywhsrd muvmywhsrd

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

    回复
  9. pltcefhkdw pltcefhkdw

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

    回复
  10. ewdmwyzocn ewdmwyzocn

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

    回复
  11. dkmyzrdqpq dkmyzrdqpq

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

    回复
  12. ncfpypkzyw ncfpypkzyw

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

    回复
  13. hcrqihtsre hcrqihtsre

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

    回复
  14. kikwonfqvq kikwonfqvq

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

    回复
  15. iyrtbuaypq iyrtbuaypq

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

    回复
  16. tnpqjipwjj tnpqjipwjj

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

    回复
  17. dnxbfowfmq dnxbfowfmq

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

    回复
  18. gmuazzbuvz gmuazzbuvz

    叼茂SEO.bfbikes.com

    回复
  19. qfnnggggha qfnnggggha

    叼茂SEO.bfbikes.com

    回复
  20. afvgaslowp afvgaslowp

    博主真是太厉害了！！！

    回复

添加新评论