RocketMQ消息消費源碼分析(一消費者的啓動、消息拉取)

消息消費方式 Consumer分爲兩種，PullConsumer和PushConsumer。從名字就能夠看出一種是拉取的方式，一種是主動Push的方式。具體實現以下：java PullConsumer，由用戶主動調用pull方法來獲取消息，沒有則返回 PushConsumer，在啓動後，Consumer客戶端會主動循環發送Pull請求到broker，若是沒有消息，broker會把請求放入等待隊列，

>>阅读原文<<