pullResult方法干了什么？
1：首先processPullResult处理pullResult，实际上是增强了pullResult，进一步封装
2：其次ProcessQueue调用<b><font color="#e74f4c">putMessage方法（将消息存入treeMap中，自带顺序性，底层是红黑树结构）</font></b>
1：其次ReadWriteLock treeMapLock，加写锁
2：循环遍历pullResult中的List<MessageExt>将MessageExt放入到这个TreeMap<Long, MessageExt> msgTreeMap中,key是队列中的偏移量，value为消息，同时设置dispatchToConsume为true
3：释放锁
3：提交消费请求consumeMessageService.submitConsumeRequest（实际上是将ConsumeRequest这个线程提交到线程池consumeExecutor中）
consumeExecutor线程池的参数如下：
corePoolSize：20个
maximumPoolSize：20个
keepAliveTime：1000 * 60
TimeUnit.MILLISECONDS
consumeRequestQueue：new LinkedBlockingQueue<>()
线程名：ConsumeMessageThread_consumerGroupTag
ConsumeRequest这个线程干了什么？（顺序消费消息）
run方法中
1：对当前消息队列上锁，final Object objLock = messageQueueLock.fetchLockObject(this.messageQueue);
2：synchronized (objLock)，使用同步代码块，加锁
判断是不是广播模式或者processQueue的locked为true且没有过期，满足条件，则继续往下走
满足上面条件
判断集群模式下，该消息队列是不是被锁或者没有锁超时，没有被锁或者锁超时了，过会再加锁和重新消费tryLockLaterAndReconsume，延时10ms
获取最大能批量消费消息的大小，默认1次
通过处理队列，拿到这个队列上上的所有消息，List<MessageExt> msgs = this.processQueue.takeMessages(consumeBatchSize);
核心代码如下：加写锁->从msgTreeMap中pollFirstEntry获取并移除第一个元素，即消息->将消息存入List<MessageExt>中->释放锁
通过consumeLock继续加锁，这次加的是读锁
<b><font color="#e74f4c">调用监听器的消费消息方法，messageListener.consumeMessage(Collections.unmodifiableList(msgs), context);</font></b>自此消费者Consumer启动前注册的监听器就监听到了消息，设置自动提交标志位autoCommit为true，然后开始业务处理
消息消费成功后，释放锁
消息消费完成后，提交偏移量
如果消费不成功，比如超时，则提交一个SUSPEND_CURRENT_QUEUE_A_MOMENT，即阻塞当前队列一会，过会继续消费该消息，调用makeMessageToConsumeAgain，重新treeMapLock.writeLock().lockInterruptibly();对该队列加写锁，然后遍历每条消息，consumingMsgOrderlyTreeMap中移除当前的消息，重新往msgTreeMap中缓存消息，最后释放锁，接着submitConsumeRequestLater，重新提交消费请求
ConsumeRequest这个线程干了什么？（并发消费消息）
并发消息和顺序消费的区别点
①在从broker拉取完消息后，进行消息提交，即调用submitConsumeRequest方法
顺序消费消息：是将ConsumeRequest提交到线程池中，然后执行run方法，开始对消息队列进行加同步锁，然后从一个TreeMap<Long, MessageExt> msgTreeMap中pollFirstEntry，顺序拿到消息，接着调用监听器的消费消息方法，开始进行对消息的业务处理，如果消费成功，则提交偏移量，消费不成功，则会阻塞当前队列一段时间，过会继续重新将消息队列依次加入到上面的treeMap中，然后再延迟重新提交消费请求submitConsumeRequestLater
并发消费消息：①不用加锁，上来就获取批量消费消息大小，consumeBatchSize默认1次，然后用消息大小和consumeBatchSize批处理比较，如果消息大小小于等于consumeBatchSize，说明就一个消息，直接就将ConsumeRequest提交到线程池中，如果消息大小大于consumeBatchSize，那么则进行双层for循环处理
②执行并发消费的ConsumeRequest中的run方法时
直接调用监听器的消费消息方法listener.consumeMessage(Collections.unmodifiableList(msgs), context);
默认自动提交偏移量
