Question

PriorityQueue是一种允许用户设置消息优先级的Queue，创建的时候需设置相应参数enablePriority为true。

相对应的，可以向PriorityQueue中发送带有优先级信息的消息。 优先级从高到低的取值范围为[1, 16]。

用户在使用PriorityQueue的时候需明确以下几点：

1. 消息优先级不是全局的，是局部的。 局部是指在某个Partition中优先级有效, 而不是在整个Queue中有效。 EMQ在返回消息的时候，如果选取的某个Partition中有高优先级的消息，那么这些高优先级消息会优先返回， 但是如果取的某个Partition中没有高优先级的消息，也会先返回这个Partition中现存的最高优先级的消息， 而与此同时，有可能在其他的Partition中有更高优先级的消息，但是这些消息不会返回。

2. 如果业务必需消息先进先出，即需要全局优先级，建议在消费消息后由用户进行重新排序。 这里暂时给一个优先队列的替代方案，后续我们会尝试寻找一个折中方案去实现优先队列，如下图：

这里priority level 1、priority level 2....只是普通的队列，但是我们定义它：第一个队列只存放优先级为1的消息；第二个队列只存放优先级为2的消息.....

细心的读者会发现，那还不是要在本地维护一个优先队列，万一机器重启了什么的，我在本地优先队列里的数据不就完全没了？对于这种情况，我们可以：在receive thread接收到消息时，先不ack(调用deleteMessage方法)，等到处理线程真正处理完这条消息，再ack，这样即使机器重启了，这些丢失的消息在一段时间后又会变的可见，就可以被重新接收到了。