SocketMQ Offset管理
因为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重启后就会重复消费
《正确的恋爱开始方式》日本剧高清在线免费观看:https://www.jgz518.com/xingkong/112968.html
《重返大福村》国产剧高清在线免费观看:https://www.jgz518.com/xingkong/34531.html
你的才华让人惊叹,你是我的榜样。 https://www.4006400989.com/qyvideo/88750.html
《吾凰在上 动态漫画》国产动漫高清在线免费观看:https://www.jgz518.com/xingkong/48992.html
《王昭君2007》国产剧高清在线免费观看:https://www.jgz518.com/xingkong/135150.html
《恶灵旅店2023》台湾剧高清在线免费观看:https://www.jgz518.com/xingkong/42889.html
你的文章让我学到了很多技能,非常实用。 http://www.55baobei.com/mJIVSdHDHi.html
《王昭君2007》国产剧高清在线免费观看:https://www.jgz518.com/xingkong/135150.html
《重返大福村》国产剧高清在线免费观看:https://www.jgz518.com/xingkong/34531.html
你的文章让我学到了很多技能,非常实用。 https://www.yonboz.com/video/71959.html
“明日传奇私服发布网如何确保游戏安全与稳定?”:https://501h.com/heji/2024-10-20/43528.html
你的文章总是能给我带来欢乐,谢谢你! https://www.yonboz.com/video/9398.html
揭秘传奇世界:如何把握私服市场新机遇:https://501h.com/danzhiye/2024-09-25/37668.html
不错不错,我喜欢看 www.jiwenlaw.com
想想你的文章写的特别好https://www.ea55.com/
看的我热血沸腾啊https://www.ea55.com/
叼茂SEO.bfbikes.com
叼茂SEO.bfbikes.com
博主真是太厉害了!!!