RocketMQ——Consumer篇：PULL模式下的消息消费（DefaultMQPullConsumer）

1 应用层的使用方式 在应用层初始化DefaultMQPullConsumer类，而后调用该类的start方法启动Consumer；接下来的消费步骤以下：web 一、调用DefaultMQPullConsumer.fetchSubscribeMessageQueues(String topic)方法，根据topic获取对应的MessageQueue（便可被订阅的队列），在该方法中最终经过调用MQA

>>阅读原文<<