即使activemq中的队列不为空，JMS实现中的receiveNoWait也会返回null

Question

我试图在我的项目中实现JMS。我使用活动mq作为提供者，并使用持久队列。下面是从活动mq中检索元素的代码

            conn = GlobalConfiguration.getJMSConnectionFactory().createConnection();
            conn.start();
            session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
            MessageConsumer consumer = session.createConsumer(queue);
            ObjectMessage obj = (ObjectMessage) consumer.receiveNoWait();

这段代码有时会返回数据，有时会返回null，即使我可以在活动的mq管理控制台中将待处理消息的数量视为非零。我读了很多文章，很少有人提到JMS api没有强制您每次都要获取元素，并且您必须相应地编码。因为在我的场景中，我依赖于队列，一旦队列返回null，我就会杀死进程，所以我通过以下方式修改了代码

我没有调用receiveNoWait，而是在通过队列浏览器检查队列中是否存在元素后开始使用receive。以下是修改后的代码

public static <T> T retrieveObjectFromQueue(Queue queue, Class<T> clazz) {
synchronized (queue) {
    if(!queueHasMoreElements(queue))
        return null;
    Connection conn = null;
    Session session = null;
    try {
        conn = GlobalConfiguration.getJMSConnectionFactory().createConnection();
        conn.start();
        session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
        MessageConsumer consumer = session.createConsumer(queue);
        ObjectMessage obj = (ObjectMessage) consumer.receive();
        return clazz.cast(obj.getObject());
    } catch(Exception e) {
        throw new RuntimeException(e);
    }finally {
        closeSessionAndConnection(session, conn);
    }
}


public static boolean queueHasMoreElements(Queue queue) {
Connection conn = null;
Session session = null;
try {
    conn = GlobalConfiguration.getJMSConnectionFactory().createConnection();
    conn.start();
    session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
    QueueBrowser browser = session.createBrowser(queue);
    Enumeration enumeration = browser.getEnumeration();
    return enumeration.hasMoreElements();
} catch(Exception e) {
    throw new RuntimeException(e);
}finally {
    closeSessionAndConnection(session, conn);
}

现在，我的代码在处理了大约20-30个元素后被卡住了，我可以在管理控制台中再次看到挂起的元素。当我尝试使用调试模式时，我意识到，在检索20-30个元素之后，我的代码会在消费者处卡住。receive（），在队列为空的情况下是应该的，但当我检查管理控制台时，它显示了队列中的许多元素。

我使用jdbc（mysql）作为Activemq的持久存储。我使用的配置xml在Activemq配置示例中给出（Activemq/实例/conf/activemq-jdbc-performance.xml）

我正在使用tcp://localhost:61616?jms.prefetchPolicy.queuePrefetch=1作为activemq url。

请让我知道我做错了什么。我使用的是java8和apache activeMq 5.13.1

谢谢

Answer 1

我们看到了一个类似的问题(其中< code>receiveNoWait返回null，即使代理上有消息)。我认为这是由于activemq [1][2]中的预取缓冲区，这可以通过将预取极限设置为0来修复。

[1]https://ActiveMQ . Apache . org/what-is-the-prefetch-limit-for < br >[2]当消息可用时，JMS receiveNoWait()是否保证消息传递？

Answer 2

JMS规范也没有强制队列浏览器返回队列中的所有消息，您可能只能在它开始时获得那里的快照，这取决于许多因素。

您试图将它无法保证的语义强加给 JMS。您可以尝试将预取设置为零，这将导致客户端轮询代理以获取消息，并等待代理告诉存在或没有消息。但是，如果在轮询时消息尚未到达队列，您可能仍然一无所获，这只是您需要处理的事情。

您还可以使用定时接收方法，并施加一个超时，您愿意在返回和终止应用程序之前等待该超时。