深入理解RocketMQ：Consumer消费消息原理
前言
RocketMQ版本：4.8
Consumer類型：DefaultMQPushConsumer
原理解析
consumer 啟動時做了哪些事情？
定時從NameSrv獲取最新的Topic+Queue+Broker路由信息，獲取頻率默認30秒，可以通過參數(shù) pollNameServerInterval 進行設(shè)置
創(chuàng)建類型為LinkedBlockingQueue的隊列pullRequestQueue，用于存放PullRequest請求對象。
創(chuàng)建線程RebalanceService，主要用于執(zhí)行負載均衡。 默認根據(jù)平均分配原則，為當前consumer分配對應(yīng)數(shù)量的queue。隨后遍歷queue分別創(chuàng)建PullRequest，放入隊列pullRequestQueue。
PS：這項工作默認20秒執(zhí)行一次，可以通過System.setProperty(“rocketmq.client.rebalance.waitInterval”) 修改
Queue分配完畢后，如果線程是第一次運行，會向Broker發(fā)送請求獲取當前Consumer對應(yīng)每個Queue的消費進度。取值結(jié)果受Consumer消費策略 consumeFromWhere 影響，默認是獲取上次消費的進度。
創(chuàng)建線程PullMessageService，不斷地從pullRequestQueue拉取數(shù)據(jù)。取到PullRequest就通過Netty發(fā)送類型為RemotingCommand的消息，code=RequestCode.PULL_MESSAGE
總結(jié)
以上是生活随笔為你收集整理的深入理解RocketMQ：Consumer消费消息原理的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： RocketMQ源码解析：Produce
- 下一篇： Canal实时同步数据到RocketMQ