使用ActiveMQ调度程序降低性能的问题

Question

null

• 我们在所有队列（Q和S）中都有挂起的消息，而我们希望它们只在队列S中挂起
• 当在S中调度的消息唤醒时，它们将移动到T队列：这些消息将根据节流配置(1K消息/秒）进行处理
• 仍在Q和S中挂起的消息移动到T的速度非常慢（大约50条消息/秒）
• 如果我们在处理完所有宝贵的消息（再次使用生产者P）后尝试第二轮消息（没有时间窗口），我们仍然以50个消息/秒的速度发送消息，即使在这种情况下，我们根本没有使用调度区域

问题摘要

• ActiveMQ版本：5.9.0（配置了3GB的最大内存限制）
• 骆驼版本:2.15.1
• Spring版本:4.1.3.发布
• 1条消息的平均维度:4.5kib
• 关键路由：
  • q->S（计划区域）->T
  • q->T（使用计划区域后）
  null

  厄洛斯

Answer 1

版本5.4中的ActiveMQ在ActiveMQ消息代理ActiveMQ.apache.org/delay-and-schedule-message-delivery.html中内置了一个可选的持久调度器

因此，要提高性能，请尝试将下面的代码添加到ActiveMQConnectionFactory上的BrokerURL中

例如：

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616?jms.copyMessageOnSend=false&jms.dispatchAsync=true&jms.useAsyncSend=true");

看一看

http://activemq.apache.org/connection-configuration-uri.html http://activemq.apache.org/performance-tuning.html