如何防止ActiveMQ优先级队列上的低优先级消息饥饿？

Question

我正在开发一个需要实现优先队列的系统。我们有不同优先级的消息，我们需要根据优先级处理消息。现在，出于多种原因，我们希望使用 ActiveMQ 作为我们的队列技术，其中之一是支持优先级队列。

对于 ActiveMQ 中的优先级队列，处理饥饿问题的最佳方法是什么？具体来说，我们需要确保即使较高优先级的消息继续充斥队列，低优先级的消息最终也能得到处理。 ActiveMQ 有内置的东西吗？或者我们是否需要构建自己的东西来随着消息的老化而提高优先级？

Answer 1

做到这一点的基本方法是当消息变旧时提高优先级，

这样，一小时前的低优先级消息的优先级高于

public class Message implements Comparable<Message>{

    private final long time;//timestamp from creation (can be altered to insertion in queue) in millis the lower this value the older the message (and more important that it needs to be handled)
    private final int pr;//priority the higher the value the higher the priority

    /**
     * the offset that the priority brings currently set for 3 hours 
     *
     * meaning a message with pr==1 has equal priority than a message with pr==0 from 3 hours ago
     */
    private static final long SHIFT=3*60*60*1000; 

    public Message(int priority){
        this.pr=priority;
        this.time = System.currentTimeMillis();
    }

    //I'm assuming here the priority sorting is done with natural ordering
    public boolean compareTo(Message other){
        long th = this.time-this.pr*SHIFT;
        long ot = other.time-other.pr*SHIFT;
        if(th<ot)return 1;
        if(th>ot)return -1;
        return 0;
    }

}

评论中指出的新的高优先级消息，但是来自低优先级消息的洪水几个小时前将暂时缺乏新的高优先级消息，并且将这些消息正确地隔开将需要更复杂的方法，

---

另一种方法是使用多个队列，每个优先级一个，并从低优先级队列中取出多个队列。优先级队列

最后一种方法仅适用于少量情况优先级，而我提供的第一个方法可以处理任意数量的优先级