百技8组 第三题

[yu961549745]

全局排序 Pull Consumer 实现

1. 将MQPullConsumer的pull操作封装在BufferedMq中, 提供peek和poll方法, 自动根据指定的bufferSize刷新消息.
2. 基于java.util.PriorityQueue实现多路归并, 按照MessageExt.getBornTimestamp进行排序.

   public MessageExt receive() {
   if (priorityQueue.isEmpty()) {
       return null;
   }
   BufferedMq mq = priorityQueue.poll();
   MessageExt msg = mq.poll();
   if (mq.peek() != null) {
       priorityQueue.add(mq);
   }
   return msg;
   }