RocketMq源码-1

        广播模式消费还是集群模式消费,远程去拉取 启动consumerService\通信 启动线程池的延时任务,清理过时的延时任务 每隔30s检测broker是否还存活 消费成功的偏移量同步到broker 新开一个线程,长轮询,循环阻塞拉取消息 真正pull,需要负载均衡放到下图的pullRequestQueue 有消息就从pullRequestQueue获取,没有就阻塞在这里

>>阅读原文<<