RocketMQ消費\生產消息的過程

這幾天在看RocketMQ的知識，跟蹤了下源碼，弄清楚了MQ生產和消費消息的流程，這裏記錄下MQ消費消息的過程。多線程 1：RebalanceService線程構造PullRequest並將request放入pullRequestQueue,而PullRequest的具體信息來源於topicSubscribeInfoTableapp 2:PullRequest放入pullRequestQueue後

>>阅读原文<<