RocketMQ消费\生产消息的过程

这几天在看RocketMQ的知识,跟踪了下源码,弄清楚了MQ生产和消费消息的流程,这里记录下MQ消费消息的过程。多线程 1:RebalanceService线程构造PullRequest并将request放入pullRequestQueue,而PullRequest的具体信息来源于topicSubscribeInfoTableapp 2:PullRequest放入pullRequestQueue后
相关文章
相关标签/搜索