客户端在拉取数据时，主要是通过 PullMessageService 类的 pullMessage 方法来实现的，它会不断的从broker上拉取数据，供消费端进行消费。

1. 在消费端是通过 ProcessQueue 对象来承接对应的MessageQueue的数据，它有以下的三个属性

在往ProcessQueue 里添加数据时，这三个属性的值也会相应的更新

2. pullMessage时，会对当前处理的ProcessQueue进行检查

总结

在RocketMQ消费端，通过两种方式，进行数据的拉取

1. 当前处理的队列中已拉取未被消费的数据数量超过1000
2. 当前处理的队列中已拉取未被消费的内存大小大于100M时
3. 按当前的已拉取的最大偏移量与最小偏移量的差进行处理

当消费慢时，可以通过以下的方式进行提速

1. 增加消费端(消费端的数量要小于等于队列的数量，否则多出来的不会消费数据)
2. 可以增加消费端的线程数