Spring JMS DefaultMessageListenerContainer轮询频率

Question

我使用DefaultMessageListenerContainer来消费ActiveMQ队列中的消息，如下所示。在这种实现中，是否有轮询机制，侦听器是否每隔1秒左右轮询队列以查看是否有新消息，或者是否在队列中有新消息时调用onMessage方法？如果使用轮询，我们如何增加或减少轮询频率（时间）。

DefaultMessageListenerContainer container = new DefaultMessageListenerContainer();
container.setMessageListener(new MessageJmsListener ());

public class MessageJmsListener implements MessageListener {
    
  @Override
    public void onMessage(Message message) {
        if (message instanceof TextMessage) {
            try {
                //process the message and create record in Data Base                
            } catch (Exception e) {
                throw new RuntimeException(e);
            }
        }
    }     
}

Answer 1

容器轮询JMS客户端，但代理将消息推送到客户端。

因此，不，容器不会直接轮询队列。

如果队列中没有消息，则容器将在接收超时后超时，并立即重新轮询，并在代理发送下一条消息后立即获取该消息。

预取决定了代理向消费者发送了多少消息；因此这可能会影响性能（但我认为，在最近的ActiveMQ版本中，默认情况下是1000）。

将预取设置为1将使您的传递速度最慢。

如果你想放慢速度，你可以添加一个线程。sleep（）在您的侦听器中。