骆驼“activemq组件”的性能问题

Question

我尝试使用 ActiveMQ 组件（在 Spring-Boot 内），但结果有些奇怪 结果。

1- 我从 SEDA 向 destinationQueue 发送了 2000 条消息

我是这样做的：

from("file:G:/highlight").to("seda:warehouse");
// took less than a millisecond to complete



from("seda:warehouse?concurrentConsumers=20").to("activemq:queue:destinationQueue") 
// Completion time : 58 seconds

Completion time : 58 seconds

2- 现在我尝试使用来自destinationQueue 的这些文件 这就是我要这样做的方式：

        from("activemq:queue:line1").process(new Processor() {
            @Override
            public void process(Exchange exchange) throws Exception {
                System.out.println(exchange.getIn().getBody(String.class));
            }
        });  
// The completion time : around 1 second!

The completion time : around 1 second!

所以我的问题是：

1- 为什么我将文件发送到队列时速度很慢？但我可以消费那些 消息如此之快（在这个测试中，它快了 50 倍以上）！！！

• 我确实在笔记本电脑上消费和生产。

任何帮助将不胜感激:))

Answer 1

感谢@Alexey-yakunin，我找到了它:)

当您使用 ActiveMQ 时，如果您的目的地是“队列”，那么生成消息的速度到 队列比从队列中消费要慢得多。 这是因为，就像@Alexey-yakunin 所说的那样“当您向 ActiveMQ 队列发送消息时，您将它们放入数据库中。数据库位于您的硬盘驱动器上（瓶颈）。从数据库读取比写入它更快” .

所以为了证明这个理论，我做了这个测试：

（我没有将消息发送到queue，而是将它们发送到topic，没有任何持久订阅者）

No durable subscribers to the topic == No databse

        from("file:G:/highlight").to("activemq:topic:newVersion");
        from("activemq:topic:newVersion").process(new Processor() {
            @Override
            public void process(Exchange exchange) throws Exception {
                long time = System.currentTimeMillis();
                Date date = new Date(time);
                System.out.println(date);

            }
        });

对于2000 messages，只需要3 seconds 就可以产生和消费所有消息。

这些也是我在 spring boot application.properties 中设置的选项，以便充分利用 activemq：

camel.component.activemq.broker-u-r-l=tcp://localhost:61616

// By default it is set to false so make sure you set this to true
camel.component.activemq.use-pooled-connection=true 

camel.component.activemq.transacted=false

//Remember, the messages will be lost if the broker crashes or is restarted.
camel.component.activemq.delivery-persistent=false

camel.component.activemq.wait-for-provision-correlation-to-be-updated-thread-sleeping-time=50

还有另外两个选项可以刺激你改变它们的价值，但我找到了它们 充其量设置为默认值时：

camel.component.activemq.concurrent-consumers
camel.component.activemq.max-concurrent-consumers

就是这样:))