RocketMQ中broker消息存储之如何实现拉取消息


这篇文章给大家分享的是有关RocketMQ中broker消息存储之如何实现拉取消息的内容。小编觉得挺实用的,因此分享给大家做个参考,一起跟随小编过来看看吧。在consumer拉取消息时,broker首先会根据待拉取的topic+queueId得到对应的ConsumeQueue,再根据消费offset从ConsumeQueue相应的偏移位置中获取该消息在commitlog里真实的offset/msgsize/tagscode信息,最后再从commitlog查出消息体。消息拉取在broker存储层的调用入口为DefaultMessageStore.getMessage方法。核心逻辑如下:ConsumeQueue中存储的是固定长度(每个消息20字节)的内容,因此访问比较简单:通过ConsumeQueue获取消息在commitlog中的偏移量以及消息大小之后,获取消息体的方法如下消息拉取整体流程如下感谢各位的阅读!关于“RocketMQ中broker消息存储之如何实现拉取消息”这篇文章就分享到这里了,希望以上内容可以对大家有一定的帮助,让大家可以学到 香港云主机更多知识,如果觉得文章不错,可以把它分享出去让更多的人看到吧!

相关推荐: U-Mail邮件系统存储加密功能保护隐私的示例分析

这期内容当中小编将会给大家带来有关U-Mail邮件系统存储加密功能保护隐私的示例分析,文章内容丰富且以专业的角度为大家分析和叙述,阅读完这篇文章希望大家可以有所收获。邮件被窃有几种可能,一是用户账号密码被盗;二是邮件在传输的过程中被人窃密;三是邮件存在公司邮件…

免责声明:本站发布的图片视频文字,以转载和分享为主,文章观点不代表本站立场,本站不承担相关法律责任;如果涉及侵权请联系邮箱:360163164@qq.com举报,并提供相关证据,经查实将立刻删除涉嫌侵权内容。

(0)
打赏 微信扫一扫 微信扫一扫
上一篇 09/23 19:05
下一篇 09/23 19:33

相关推荐