Rocketmq源碼解讀之消息拉取

最近閱讀了Rocketmq關於pullmessage的實現方式，分享出來html   衆所周知，Rocketmq在consumer端是拉取消息的方式，它會在客戶端維護一個PullRequestQueue，這個是一個阻塞隊列（LinkedBlockingQueue），內部的節點是PullRequest，每個PullRequest表明了一個消費的分組單元緩存   PullRequest會記錄一個top

>>阅读原文<<