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

已有 19 条评论

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

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

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

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

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

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

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

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

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

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

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

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

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

  14. 不错不错,我喜欢看 www.jiwenlaw.com

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

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

  17. 叼茂SEO.bfbikes.com

  18. 叼茂SEO.bfbikes.com

  19. 博主真是太厉害了!!!

添加新评论