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 客户端，但代理向客户端推送消息。

所以，不，容器不会直接轮询队列。

如果队列中没有消息，容器会在receiveTimeout之后超时并立即重新轮询，并在broker发送后立即获取下一条消息。

预取决定了broker向消费者发送了多少条消息；所以这可能会影响性能（但我认为，最近的 ActiveMQ 版本默认为 1000）。

将预取设置为 1 将使您的交付速度最慢。

如果您想放慢速度，可以在侦听器中添加Thread.sleep()。