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

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

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

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

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

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

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

results matching ""

    No results matching ""