与骆驼的性能问题"active emq组件"

Question

我试着使用ActiveMQ组件（在Spring Boot内部），但最终得到了一些奇怪的结果。

1-我从SEDA发送了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队列发送消息时，你把它们放在数据库中。数据库位于你的硬盘驱动器上（瓶颈）。从数据库读取消息比向数据库写入消息要快”。

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

（而不是发送消息到队列我将它们发送到主题没有任何持久的订阅者）

主题没有持久订阅者==没有数据库

        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条消息，只需3秒即可生成和使用所有消息。

这些也是我在spring boot应用程序中设置的选项。属性为了充分利用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

仅此而已：））