RocketMq源碼-1

        廣播模式消費還是集羣模式消費,遠程去拉取 啓動consumerService\通信 啓動線程池的延時任務,清理過時的延時任務 每隔30s檢測broker是否還存活 消費成功的偏移量同步到broker 新開一個線程,長輪詢,循環阻塞拉取消息 真正pull,需要負載均衡放到下圖的pullRequestQueue 有消息就從pullRequestQueue獲取,沒有就阻塞在這裏

>>阅读原文<<