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向consumer发送了多少条消息；因此这可能会影响性能（但我认为最近的 ActiveMQ 版本默认为 1000）。

将预取设置为 1 将为您提供最慢的传输速率。

如果你想放慢速度，可以在监听器中添加

Thread.sleep()

。