Spring Boot时动态扩展JMS使用者
我正在尝试构建一个Spring Boot" title="Spring Boot">Spring Boot应用程序,该应用程序将从activeMQ生产者读取数据。我想最大限度地利用客户可用的资源。在我的Spring Boot应用程序中,我想配置多个使用者,所有这些使用者将连接到一个队列。
他们是我可以在sprint-boot应用程序上动态扩大和缩小消费者的一种方法吗?
回答:
您正在谈论的消费者,是的不同线程DefaultMessageListenerContainer
还是的不同实例DefaultMessageListenerContainer
?
您可以通过更改来动态增加和减少DefaultMessageListenerContainer的线程数
org.springframework.jms.listener.DefaultMessageListenerContainer.concurrentConsumers
和
org.springframework.jms.listener.DefaultMessageListenerContainer.maxConcurrentConsumers
相应地
如果您使用多个使用者和/或线程,则需要调整prefetchPolicy。
persistent queues (default value: 1000)non-persistent queues (default value: 1000)
persistent topics (default value: 100)
non-persistent topics (default value: Short.MAX_VALUE - 1)
所有消息都被调度到第一个连接的使用者,而当另一个连接时他没有收到消息,因此,如果您有一个队列的并发使用者,则要更改此行为,需要将prefetchPolicy设置为比默认值低的值。例如,将其添加jms.prefetchPolicy.queuePrefetch=1
到activemq.xml的uri配置中,或像这样在客户端网址上进行设置
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://172.16.143.99:61616?jms.prefetchPolicy.queuePrefetch=1");
建议使用较大的预取值,以实现高性能和高消息量。但是,对于较低的消息量,其中每条消息都需要花费很长时间进行处理,因此应将预取设置为1。这样可以确保使用者一次只处理一条消息。但是,将预取限制指定为零将导致使用者一次轮询一次消息,而不是将消息推送到使用者。
看看http://activemq.apache.org/what-is-the-prefetch-limit-
for.html
和
http://activemq.apache.org/destination-
options.html
以上是 Spring Boot时动态扩展JMS使用者 的全部内容, 来源链接: utcz.com/qa/415651.html