Mi Galaxy EMQ Book

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

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

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

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

  2. 如果业务必需消息先进先出,即需要全局优先级,建议在消费消息后由用户进行重新排序。