Spring JMS DefaultMessageListenerContainer 轮询频率

问题描述

我使用 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);
            }
        }
    }     
}

解决方法

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

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

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

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

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

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