Spring boot framework中使用Apache Camel的ActiveMQ生成器的性能设置

Question

我们有一个Spring Boot应用程序，我们使用apache camel作为消息处理框架。我们正在尝试最好地优化应用程序设置，以使ActiveMQ队列上的消息快速入队，队列另一端的Logstash作为使用者接收这些消息。

文档分散在许多地方，并且有太多的配置可用。

Application.Properties：

################################################
# Spring Active MQ
################################################
spring.activemq.broker-url=tcp://localhost:61616
spring.activemq.packages.trust-all=true
spring.activemq.user=admin
spring.activemq.password=admin

阿帕奇骆驼

.to("activemq:queue:"dataQueue"?messageConverter=#queueMessageConverter");

问题：

.to("seda:somequeue?waitForTaskToComplete=Never");

.from("seda:somequeue?concurrentConsumers=20");

活动MQ：

.to("activemq:queue:dataQueue?disableReplyTo=true);

Application.Properties：

#Enable poolconnection factory
spring.activemq.pool.enabled=true
spring.activemq.pool.blockIfFull=true
spring.activemq.pool.max-connections=50

Answer 1

>

是的，您需要使用PooledConnectionFactory。尤其是搭配骆驼+Spring靴。或者使用camel-sjms组件。罪魁祸首是Spring的jmstemplate。超高延迟。

发送NON_PERSISTENT和AUTO_ACK，同时在连接工厂上打开sendAsync

当生产者流控制启动时（也就是队列或代理已满），您需要捕获路由中的javax.jms.ResourceAllocationException以进行重试

ActiveMQ根据字节而不是消息计数进行大小调整。请参见生产者流控制文档中的SystemUsage设置和基于字节限制队列大小的每目标策略策略。