Rocketmq源码解读之消息拉取

最近阅读了Rocketmq关于pullmessage的实现方式,分享出来html   众所周知,Rocketmq在consumer端是拉取消息的方式,它会在客户端维护一个PullRequestQueue,这个是一个阻塞队列(LinkedBlockingQueue),内部的节点是PullRequest,每个PullRequest表明了一个消费的分组单元缓存   PullRequest会记录一个top
相关文章
相关标签/搜索