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后超时并立即重新轮询，并在代理发送后立即获取下一条消息。

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

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

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

Spring JMS DefaultMessageListenerContainer 轮询频率

Spring JMS DefaultMessageListenerContainer Polling frequency

activemq

jms

polling

spring-jms

message-listener