栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 面试经验 > 面试问答

Spring Boot时动态扩展JMS使用者

面试问答 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

Spring Boot时动态扩展JMS使用者

您正在谈论的消费者,是的不同线程

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



转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/635602.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号