美文网首页
broker 拉取消息的流程

broker 拉取消息的流程

作者: Britney_z | 来源:发表于2021-09-01 14:49 被阅读0次

首先判断offset是否正确,因为consumerqueue下有可能多个文件,所以我们根据offset寻找具体的文件

根据offset查询到具体的mappedFile

从offset到maxoffset的大小,为后面循环取消息 跳出循环做判断。

同时满足小于 剩余size 和获取的消息数

消息tag过滤 ,从comitlog获取消息

将不是该tag的堆外内存释放,将result加入数组

相关文章

网友评论

      本文标题:broker 拉取消息的流程

      本文链接:https://www.haomeiwen.com/subject/tipziltx.html